Go中实现生产者-消费者模型应使用channel+goroutine：生产者向chan T发送数据，消费者从中接收，避免共享变量加锁，契合“不通过共享内存通信”原则。
Go 里实现生产者-消费者模型，最直接、最符合语言设计哲学的方式是用 channel + goroutine，而不是加锁或条件变量。它天然支持解耦、背压和优雅退出。
用 chan 做数据管道，别用共享变量
错误做法是让多个 goroutine 读写同一个 slice 或 map 并加 sync.Mutex —— 这违背 Go 的“不要通过共享内存来通信”原则。正确路径是把 channel 当作唯一的数据交接点：
- 生产者只往
chan T发送（ch ） - 消费者只从
chan T接收（item := ） - channel 容量决定是否阻塞：无缓冲 channel 同步传递；有缓冲（如
make(chan int, 100)）可缓解瞬时生产过快 - 关闭 channel 表示“不再生产”，消费者可通过
for item := range ch自动退出，或用val, ok := 判断是否已关闭
close() 只能由生产者调用，且只能调一次
这是最容易出 panic 的地方。如果多个生产者共用一个 channel，谁关、何时关、关几次，必须明确约定。常见错误：
- 消费者误调
close(ch)→ panic: close of closed channel - 多个生产者各自
close(ch)→ 第二次 close 直接 panic - 生产者还没发完就提前 close → 消费者提前退出，数据丢失
推荐方案：用 sync.WaitGroup 等待所有生产者结束，再由主 goroutine 统一 close：
var wg sync.WaitGroup
ch := make(chan int, 10)
<p>// 启动生产者
for i := 0; i < 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
for j := 0; j < 5; j++ {
ch <- id*10 + j
}
}(i)
}</p><p>// 启动消费者
go func() {
wg.Wait()
close(ch) // 所有生产者完成后再关
}()</p><p>// 消费
for val := range ch {
fmt.Println("got:", val)
}需要多消费者时，直接启动多个 goroutine 读同一 channel
channel 本身支持多路并发读（只要没缓冲或缓冲未满，发送不会阻塞），无需额外分发逻辑。但要注意：
- 没有内置的“负载均衡”，Go 运行时按 goroutine 就绪顺序调度，实际是随机分发
- 若需严格轮询或权重分发，得自己加一层 dispatcher goroutine，用
select转发到多个下游 channel - 消费者数量远大于生产速率时，空转 goroutine 会浪费资源；可用
default分支做非阻塞尝试，或结合time.After防止忙等
退出控制要用 context.Context，别靠 channel 关闭硬等
真实场景中，你往往需要“随时中断整个流程”，比如超时、信号中断、上游取消。仅靠 close(ch) 不够灵活 —— 它无法通知正在阻塞在 上的 goroutine “别等了，退出”。这时必须引入 <code>context.Context：
- 生产者用
ctx.Done()检查是否被取消，提前退出循环 - 消费者用
select { case val := 实现可中断接收 - 避免用
time.Sleep或空for {}等待，那会卡死 goroutine 且无法响应 cancel
真正麻烦的是上下文传播和错误归并 —— 比如一个消费者 panic 了，如何让其他 goroutine 也快速退出？这需要组合 errgroup.Group 或手动管理 cancel 函数。
