分享
【golang】sync.WaitGroup{}的wait()调用位置不同导致意想不到错误
dongzaidong · · 1862 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
协程go多了,总觉的天下我有,没事就喜欢go一个协程,信手拈来,在项目中写个如下类似代码:
wh := sync.WaitGroup{}
out := make(chan string)
go func() {
wh.Wait()
close(out)
}()
go func() {
for i := 0; i < 2; i++ {
wh.Add(1)
go tt(out)
wh.Done()
}
}()
想着开个协程去wait所有协程组,测试一下通了,没问题,好牛逼,协程呀!!
可多测试即便就会出现:
send close channel
或者协程定死在某一个,还自已为是的认为自己写的子方法估计不小心关闭了channel,找了半天只找到在wg.wait()后进行了关闭。就这样扣了好久,还没想到自己画蛇添足的错误,经大佬一指点,原来开一个协程,还没等后一个协程进行wg.add(1)操作,wg.wait()就已经过了,关闭了channel。
只好老老实实写:
wh := sync.WaitGroup{}
out := make(chan string)
go func() {
for i := 0; i < 2; i++ {
wh.Add(1)
go tt(out)
wh.Done()
}
wh.Wait()
close(out)
}()
其实就是一个小小的同步问题,旁观者清呀!!!
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信1862 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
协程go多了,总觉的天下我有,没事就喜欢go一个协程,信手拈来,在项目中写个如下类似代码:
wh := sync.WaitGroup{}
out := make(chan string)
go func() {
wh.Wait()
close(out)
}()
go func() {
for i := 0; i < 2; i++ {
wh.Add(1)
go tt(out)
wh.Done()
}
}()
想着开个协程去wait所有协程组,测试一下通了,没问题,好牛逼,协程呀!!
可多测试即便就会出现:
send close channel
或者协程定死在某一个,还自已为是的认为自己写的子方法估计不小心关闭了channel,找了半天只找到在wg.wait()后进行了关闭。就这样扣了好久,还没想到自己画蛇添足的错误,经大佬一指点,原来开一个协程,还没等后一个协程进行wg.add(1)操作,wg.wait()就已经过了,关闭了channel。
只好老老实实写:
wh := sync.WaitGroup{}
out := make(chan string)
go func() {
for i := 0; i < 2; i++ {
wh.Add(1)
go tt(out)
wh.Done()
}
wh.Wait()
close(out)
}()
其实就是一个小小的同步问题,旁观者清呀!!!