先看看无缓存管道的例子:
a := make(chan bool)
go func() {
log.Println("goroutine")
<-a
}()
a <- true
这里主协程会等待子协程执行完,但是如果把第一行改成 a := make(chan bool, 1),那么主协程写完消息直接退出了,子协程没有机会执行(只有一个 cpu 时)。但是改成如下子协程又可以执行了:
a := make(chan bool, 1)
go func() {
log.Println("goroutine")
<-a
}()
a <- true
a <- true
a := make(chan bool, 1)
go func() {
close(a)
}()
for {
select {
case _, ok := <-a:
log.Println(ok)
}
}
而用 for range 是不能获取 close 信号的,如下:
a := make(chan bool, 1)
go func() {
a <- true
close(a)
}()
for {
for v := range a {
log.Println(v)
}
}
1
user8341 2020-12-05 00:51:07 +08:00
range 是循环到 chan 被关闭为止。当然如果一开始就是关闭的,循环就不执行。
|