Go中协程间共享数据应优先使用channel而非全局变量或加锁;buffered channel天然实现线程安全FIFO队列,支持阻塞读写、关闭通知、非阻塞操作及封装扩展。

在 Go 中,协程(goroutine)间共享数据时,不推荐直接使用全局变量或共享内存加锁,而应优先通过 channel 进行通信。队列场景下,channel 本身就是一个天然的、线程安全的先进先出(FIFO)缓冲区,无需额外同步机制。
用 buffered channel 模拟带容量的队列
声明一个带缓冲的 channel 即可作为线程安全的队列:
-
queue := make(chan int, 10)创建容量为 10 的整数队列,写入和读取自动阻塞/唤醒,保证并发安全 - 发送操作
queue 在满时阻塞,接收操作在空时阻塞,天然实现生产者-消费者节奏控制 - 无需
sync.Mutex或sync.WaitGroup即可安全地被多个 goroutine 同时读写
关闭 channel 表示队列“已耗尽”
当生产者完成投递,应显式关闭 channel,通知消费者不再有新数据:
- 生产者调用
close(queue)(只能由发送方关闭) - 消费者用
for v := range queue自动退出循环;或用v, ok := 判断是否已关闭(ok == false表示已关闭且无剩余数据) - 注意:向已关闭的 channel 发送会 panic,务必确保只有生产者关闭,且只关一次
用 select + default 避免阻塞,实现非阻塞队列操作
若需“尝试入队/出队而不等待”,可用 select 配合 default:
立即学习“go语言免费学习笔记(深入)”;
- 非阻塞入队:
select { case queue - 非阻塞出队:
select { case v := - 适合做限流、快速失败、或与超时逻辑结合(如加
time.After)
复杂队列行为?封装成结构体 + channel 组合
当需要长度查询、清空、或动态调整容量等能力,可封装 channel 和辅助字段:
- 定义结构体包含
ch chan T和mu sync.RWMutex(仅用于保护非 channel 字段,如len计数器) - 但注意:真实长度仍应以
len(ch)为准(仅在未被其他 goroutine 并发操作瞬间有效),一般业务无需精确长度,依赖 channel 自身阻塞语义更可靠 - 避免为“看起来像传统队列”而过度封装——Go 的哲学是“用 channel 通信,不要用共享内存通信”










