關(guān)于讀取后觸發(fā)寫模塊
func?main(){ ????... ????go?lp.read.Read(lp.chanRead) ????go?lp.Process() ????go?lp.write.Write(lp.chanWrite) ????time.Sleep(10?*?time.Second) ????... }
在main函數(shù)中開啟goroutine 執(zhí)行了 read、process、write三個方法,process、write方法只執(zhí)行了一次。
為何每次讀到新數(shù)據(jù),都會再次觸發(fā) lp.Process() 和 lp.write.Write() ?
2020-06-30
有新數(shù)據(jù)來的時候,會通過監(jiān)聽的通道將數(shù)據(jù)送入Process協(xié)程,處理完又通過另一通道將處理好的數(shù)據(jù)送入Write協(xié)程,各協(xié)程均準備就緒,通道處于監(jiān)聽狀態(tài)
2019-05-17
沒有吧,后來加for循環(huán)和slect才可以的