为了账号安全,请及时绑定邮箱和手机立即绑定

关于读取后触发写模块


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() ?

正在回答

2 回答

有新数据来的时候,会通过监听的通道将数据送入Process协程,处理完又通过另一通道将处理好的数据送入Write协程,各协程均准备就绪,通道处于监听状态

0 回复 有任何疑惑可以回复我~

没有吧,后来加for循环和slect才可以的

0 回复 有任何疑惑可以回复我~

举报

0/150
提交
取消

关于读取后触发写模块

我要回答 关注问题
意见反馈 帮助中心 APP下载
官方微信