
Go 语言 Channel 阻塞行为详解
本文分析 Go 语言中 Channel 的阻塞行为,特别是针对带缓冲区的 Channel 在写入操作时的非预期阻塞现象。
问题:
在使用带缓冲区的 Channel 时,第一次写入操作未发生预期阻塞,而第二次写入才阻塞,这与预期不符。
代码示例:
package mainimport ( "fmt" "time")func produce() chan int { chs := make(chan int, 10) go func() { for i := 0; i < 10; i++ { chs <- i fmt.Printf("生产者发送:%dn", i) time.Sleep(time.Second) } close(chs) }() return chs}func main() { ch := produce() for i := 0; i < 12; i++ { select { case v, ok := <-ch: if !ok { fmt.Println("Channel 已关闭") break } fmt.Printf("消费者接收:%dn", v) default: fmt.Println("消费者阻塞") } time.Sleep(time.Second * 2) }}
预期结果:
当 Channel 缓冲区为空时,写入操作应该阻塞,直到有读取操作发生。当缓冲区有可用空间时,写入操作不应该阻塞。
实际结果:
第一次写入操作未阻塞,后续写入操作在缓冲区满时才阻塞。
关键点:
Channel 的阻塞行为取决于缓冲区状态和读写操作的先后顺序。 带缓冲区的 Channel,写入操作只有在缓冲区已满时才会阻塞;读取操作只有在缓冲区为空时才会阻塞。 本例中,生产者协程先运行,向缓冲区写入数据,由于缓冲区未满,所以写入不会阻塞。 消费者在 select 语句中使用 default 分支,避免了阻塞,因此生产者可以继续写入直到缓冲区满。
通过对 Channel 缓冲区机制的理解,可以准确预测和避免因阻塞行为导致的程序错误。
以上就是Go 语言Channel阻塞:缓冲区非空时写入为何不阻塞?的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1383813.html
微信扫一扫
支付宝扫一扫