Go 中 channel range 的深度理解

红客联盟
• 阅读 8497

我们来看下两端代码:
代码段1

func main() {
    channels := make([]chan int, 10) 
    for i := 0; i < 10; i++ {
         go func(ch chan int) {
          time.Sleep(time.Second)
          ch <- 1 
         }(channels[i])
    }

    for ch := range channels { 
    fmt.Println("Routine ", ch, " quit!")
    }
    fmt.Println("结束")
}

猜想下这上面会打印什么结果。

代码段2

func main() {
    ch := make(chan int, 10)
    for i := 0; i < 10; i++ {
        go func() {
            ch <- i
        }()
    }

    for range ch {
        <-ch
    }
    fmt.Println(1111)
}

猜想下代码2会打印什么结果。

自己可以运行下,
代码段1会正常运行, 代码段2会死锁, 纳尼,不一样吧,的确就是不一样。
请注意:代码段1 channels 是一个切片类型哦。

####总结一下:
channel 支持 for range 的方式进行遍历,需要注意两个细节。
1.在遍历时,如果 channel 没有关闭,则回出现 deadlock 的错误。
2.在遍历时,如果 channel 已经关闭,则会正常遍历数据,遍历完后,就会退出遍历。
3.对于nil channel,无论收发都会被阻塞。
4.写完 chan 之后一定要关闭close chan,否则主协程读的时候,会发生被阻塞。
5.已关闭的Channel(有缓冲的),如果继续读数据,得到的是零值(对于int,就是0), 如果没有关闭,读不到数据了。

select语句中除default外,每个case操作一个channel,要么读要么写。
select语句中除default外,各case执行顺序是随机的。
select语句中如果没有default语句, 则会阻塞等待任一case。
select语句中读操作要判断是否成功读取,关闭的channel也可以读取.

遍历 chan 与 遍历切片类型是不一样的。

点赞
收藏
评论区
推荐文章
双十一预售活动分析
2022年双十一促销活动已经开始,大家应该都提前开始关注今年双十一活动的时间表了吧?2022年10月24日晚8:00天猫双11预售时间,第一波销售时间10月31日晚8:0,第二波销售时间11月10日晚8:00;天猫双11的优惠力度是跨店每满30050
Jacquelyn38 Jacquelyn38
4年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
科工人 科工人
4年前
初学Go语言,对channel、并发的思考
初学go语言,对channel、并发感觉不太好理解。希望高人指点下。下面的代码是我看到一本书上的,就是讲解channel的。packagemainimport("fmt""math/rand")functest(chchanint,iint){ch<rand.Int()fmt.Println(i
Wesley13 Wesley13
3年前
FLV文件格式
1.        FLV文件对齐方式FLV文件以大端对齐方式存放多字节整型。如存放数字无符号16位的数字300(0x012C),那么在FLV文件中存放的顺序是:|0x01|0x2C|。如果是无符号32位数字300(0x0000012C),那么在FLV文件中的存放顺序是:|0x00|0x00|0x00|0x01|0x2C。2.  
Stella981 Stella981
3年前
Python的优雅技巧
枚举不要这么做:i0foriteminiterable:printi,itemi1而是这样:fori,iteminenumerate(iterable):printi,itemEnum
Wesley13 Wesley13
3年前
PHP创建多级树型结构
<!lang:php<?php$areaarray(array('id'1,'pid'0,'name''中国'),array('id'5,'pid'0,'name''美国'),array('id'2,'pid'1,'name''吉林'),array('id'4,'pid'2,'n
Easter79 Easter79
3年前
TurnipBit开发板DIY呼吸的吃豆人教程实例
  转载请以链接形式注明文章来源(MicroPythonQQ技术交流群:157816561,公众号:MicroPython玩家汇)  0x00前言  吃豆人是耳熟能详的可爱形象,如今我们的TurnipBit也集成了这可爱的图形,我们这就让他来呼吸了~。  0x01效果展示  先一起看下最终的成品演示视频:  http:/
Wesley13 Wesley13
3年前
MBR笔记
<bochs:100000000000e\WGUI\Simclientsize(0,0)!stretchedsize(640,480)!<bochs:2b0x7c00<bochs:3c00000003740i\BIOS\$Revision:1.166$$Date:2006/08/1117
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
九路 九路
3年前
go并发模式
一、生成器gofuncmessageGen(namestring)<chanstringc:make(chanstring)i:0gofunc()fortime.Sleep(10001000)c<name""strconv.Itoa(i)i()returncgo//方法一:此种方法,可以不必知道具体有多少个chan,参数里面也可以传一个chan的数组,如下面的fanInSlicefuncfanIn(c1,c2
美凌格栋栋酱 美凌格栋栋酱
5个月前
Oracle 分组与拼接字符串同时使用
SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(
红客联盟
红客联盟
Lv1
戍客望边邑,思归多苦颜。
文章
4
粉丝
0
获赞
0