channel实现一生产,多消费,如何死锁呢(在不closechan的情况下)

yaxiaomu · · 593 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

```golang package main import ( "fmt" "sync" ) func main() { wg:=&sync.WaitGroup{} ch:=make(chan int ,100) send:= func() { for i:=0;i<100;i++{ ch<-i } //不开启close,如何不死锁? //close(ch) } recv:= func(id int) { defer wg.Done() for i:=range ch{ fmt.Printf("cusumerV1 #%d get %d\n", id, i) } fmt.Printf(" >>>>>>consumerV1 #%d exit,\n", id) for{ if i,ok := <-ch;ok{ fmt.Printf("cusumerV2 #%d get %d,closed is %v\n", id, i,ok) }else{ fmt.Printf(" >>>>>>consumerV2 #%d exit,closed is %v\n", id,ok) return } } } wg.Add(3) go recv(0) go recv(1) go recv(2) go send() wg.Wait() fmt.Println("all done") } ``` 对close的行为很迷惑,只是一个标记位,为啥不close会死锁呢。。

有疑问加站长微信联系(非本文作者))

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

593 次点击  
加入收藏 微博
7 回复  |  直到 2021-11-30 17:13:53
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传