我的golang版本是1.14
就是学习通道的时候看到一段代码,我运行了一下,发现结果有两种:
package main
import "fmt"
func main() {
chanInt := make(chan int)
defer close(chanInt)
go func() {
for {
res, ok := <-chanInt
if !ok {
break
}
fmt.Println(res, ok)
}
}()
chanInt <- 1
chanInt <- 10
}
代码很简单,新开一个goroutine通过for循环读取通道的数据。
然后我执行的时候发现有两种结果:
而且第二种结果的概率要小一点。
还有我试着把代码的无缓冲改为有缓冲的情况,chanInt := make(chan int, 2)
其他不变,发现运行之后什么打印结果也没有,空空如也。
思索许久还是不明白代码的情况,希望大伙帮忙解答一下两个问题:
- 为什么无缓冲的时候,打印结果会有两种情况?【我的理解是:第二种情况应该是:chanInt <- 10之后,携程就读取了res, ok := <-chanInt,还没到打印,主协程就结束了】
- 当有缓冲通道的时候为什么打印不出任何东西?
这个其实挺简单的,这里一方面就是你说的,
还没打印,主协程就结束了
,这个可以说是前情提要了,再有一个概念就是协程启动也需要消耗时间的
,然后就说到了关于两种通道了:阻塞通道
、缓冲通道
。阻塞嘛,那么你发送数据,只要没被接收,那么肯定是阻塞的,这里发送了两次
chanInt <- 1
和chanInt <- 10
,那么,你启动的协程肯定要接收完chanInt <- 1
才能继续发送chanInt <- 10
,那么这个接收协程肯定会接收到一次的,也就是主协程肯定要等你这个接收协程执行一次。然后呢,这个执行期间,每次阻塞的等待时间肯定是不一样的,毕竟一台电脑又不可能只执行你这个程序,会受到其他干扰因素影响的,那么如果chanInt <- 1
发送完后,这里等待接收的协程执行的时间如果稍微长一点,那么第二个接收协程就启动成功了,然后再继续发送chanInt <- 10
的时候,也可以显示出来,从你这表现看,大部分时候都能把这两个显示出来,说明这种阻塞情况时间长一些的情况占据更多。这个缓冲通道,那么来说,根本不存在阻塞,我主协程根本不管你子协程启动没启动,反正有缓存,我直接把数据赛道缓冲通道,然后再关闭通道就不管你了,我主协程任务就完成了,这个子协程根本都没办法启动起来,他那还没开始呢,连准备都没有你就结束了。这里就是
协程启动消耗的时间比主协程执行时间要更长
导致的,那么对于缓冲通道的情况下,如果你不做个定时器time.Sleep(time.Duration(1))
阻塞一下主协程的话,那么来说,如果,我是说如果啊,有种可能,就是这种有缓冲的情况下如果某些情况导致主协程结束得比子协程慢,也是有可能会产生第一种情况的显示结果的。后续:
为了验证,可以试一下以
阻塞通道
和2个容量缓冲通道
为例,然后验证一下发送>=3
次可见,发送的次数或发送的次数-1
发送的次数减去缓冲容量至发送的次数这个区间