本文详解 go 中使用单个缓冲通道配合多个 goroutine 读取时避免死锁的关键技巧，包括正确关闭通道的时机、接收端对关闭状态的健壮处理，以及 sync.waitgroup 的协同使用。
本文详解 go 中使用单个缓冲通道配合多个 goroutine 读取时避免死锁的关键技巧，包括正确关闭通道的时机、接收端对关闭状态的健壮处理，以及 sync.waitgroup 的协同使用。
在 Go 并发编程中，一个常见误区是：向多个 goroutine 广播数据时，误以为只要发送方写完数据、等待所有接收方完成即可安全退出。但若通道未及时关闭，或接收方未正确响应关闭信号，极易触发 fatal error: all goroutines are asleep - deadlock。
核心问题在于：通道必须由发送方显式关闭，且关闭操作需发生在所有接收方开始读取之后、但又不能晚于 wg.Wait() 调用之前。否则，部分接收 goroutine 会永远阻塞在
以下是修复后的完整可运行示例：
package main
import (
"fmt"
"strconv"
"sync"
)
func sender(wg *sync.WaitGroup, cs chan int) {
defer wg.Done()
for i := 0; i <p>✅ <strong>关键改进说明</strong>：</p>
- 关闭时机：close(cs) 移至 sender 函数末尾，在 defer wg.Done() 之前，确保发送完成后立刻通知所有接收者；
- 接收逻辑简化：使用 for x := range cs 替代手动 x, ok :=
- wg.Done() 位置优化：在 receiver 中使用 defer wg.Done()，避免因通道已关闭导致首次接收失败而遗漏 Done() 调用；
- 移除冗余 close(cs)：主函数中 wg.Wait() 后的 close(cs) 已无意义且危险（重复关闭 panic），必须删除。
⚠️ 注意事项：
- 切勿在多个 goroutine 中尝试关闭同一通道（仅发送方有权关闭）；
- 若需“广播”而非“分发”（即每个 receiver 都应收到全部数据），则需使用 sync.Map + chan struct{} 或 github.com/uber-go/ratelimit 等更高级模式，标准 channel 本质是队列，数据一旦被某 receiver 接收即从通道中移除；
- 缓冲大小应合理预估；若不确定数据量，可考虑使用 make(chan int, 0)（无缓冲）并配合 select + default 实现非阻塞尝试，但本场景下缓冲通道更合适。
总结：多 reader 单 writer 场景下，关闭通道是打破阻塞的唯一出口，而 range 是最安全、最惯用的接收范式。掌握这一组合，即可稳健构建高并发数据分发管道。
