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 的阻塞行为取决于缓冲区状态和读写操作的先后顺序。 带缓冲区的 Channel，写入操作只有在缓冲区已满时才会阻塞；读取操作只有在缓冲区为空时才会阻塞。 本例中，生产者协程先运行，向缓冲区写入数据，由于缓冲区未满，所以写入不会阻塞。 消费者在 select 语句中使用 default 分支，避免了阻塞，因此生产者可以继续写入直到缓冲区满。
通过对 Channel 缓冲区机制的理解，可以准确预测和避免因阻塞行为导致的程序错误。
