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