ellydebug
2019-05-13 11:06
func main(){ ... go lp.read.Read(lp.chanRead) go lp.Process() go lp.write.Write(lp.chanWrite) time.Sleep(10 * time.Second) ... }
在main函数中开启goroutine 执行了 read、process、write三个方法,process、write方法只执行了一次。
为何每次读到新数据,都会再次触发 lp.Process() 和 lp.write.Write() ?
有新数据来的时候,会通过监听的通道将数据送入Process协程,处理完又通过另一通道将处理好的数据送入Write协程,各协程均准备就绪,通道处于监听状态
没有吧,后来加for循环和slect才可以的
Go并发编程案例解析
15207 学习 · 53 问题
相似问题