Go 语言 Channel 阻塞行为详解
本文分析 Go 语言中 Channel 的阻塞行为,特别是针对带缓冲区的 Channel 在写入操作时的非预期阻塞现象。
问题:
在使用带缓冲区的 Channel 时,第一次写入操作未发生预期阻塞,而第二次写入才阻塞,这与预期不符。
代码示例:
package main import ( "fmt" "time" ) func produce() chan int { chs := make(chan int, 10) go func() { for i := 0; i < 10; i++ { chs <- i fmt.Printf("生产者发送:%d\n", 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("消费者接收:%d\n", v) default: fmt.Println("消费者阻塞") } time.Sleep(time.Second * 2) } }
预期结果:
实际结果:
第一次写入操作未阻塞,后续写入操作在缓冲区满时才阻塞。
关键点:
Channel 的阻塞行为取决于缓冲区状态和读写操作的先后顺序。 带缓冲区的 Channel,写入操作只有在缓冲区已满时才会阻塞;读取操作只有在缓冲区为空时才会阻塞。 本例中,生产者协程先运行,向缓冲区写入数据,由于缓冲区未满,所以写入不会阻塞。 消费者在 select 语句中使用 default 分支,避免了阻塞,因此生产者可以继续写入直到缓冲区满。
通过对 Channel 缓冲区机制的理解,可以准确预测和避免因阻塞行为导致的程序错误。
以上就是Go 语言Channel阻塞:缓冲区非空时写入为何不阻塞?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号