用chan实现生产者消费者模型的关键在于正确管理关闭时机、缓冲区大小及多goroutine协作：禁止消费者close channel，多生产者需WaitGroup协调关闭；带缓冲channel更适用，大小依吞吐量权衡；range仅在channel关闭且无数据时退出；多消费者需显式控制数量并配合context或done channel确保数据处理完毕。
直接说结论：用 chan 实现生产者消费者模型不难，但真正容易出错的不是语法，而是关闭时机、缓冲区大小选择、以及多 goroutine 下的协作节奏。
为什么不能在消费者里 close(ch)？
因为 close() 只能由发送方调用，否则会 panic：panic: close of closed channel 或更隐蔽的 send on closed channel。更危险的是，如果多个生产者并发写入，谁来关、何时关就成了问题。
- 单生产者：在发送完所有数据后，由生产者调用
close(ch) - 多生产者：不能靠某个生产者自行 close —— 必须等全部发完，通常用
sync.WaitGroup计数，再由单独 goroutine 关闭 - 绝对禁止消费者调用
close()，哪怕它“看起来已经收完了”
带缓冲 vs 无缓冲 channel 怎么选？
关键看你的生产/消费速率是否稳定。无缓冲 channel（make(chan int)）要求发送和接收必须同步就绪，适合强耦合、需严格顺序控制的场景；而带缓冲 channel（make(chan int, N)）才是生产者消费者模型的默认选择。
- 缓冲大小设为 0 → 阻塞式通信，一发一收，适合信号通知或简单同步
- 缓冲大小设为 1–10 → 适合小批量任务，比如日志采集、配置变更事件
- 缓冲大小设为 100+ → 要小心内存堆积，尤其当消费者卡住时，channel 会持续吃内存
- 别迷信“越大越好”：缓冲区本质是内存队列，不是性能银弹；超大 buffer 可能掩盖消费者瓶颈
range ch 为什么会自动退出？
for val := range ch 的退出条件只有一个：channel 被关闭，且内部已无待读数据。它不是“检测到 close 就立刻停”，而是“等最后一项被取出后，下一次迭代发现已关闭，才退出循环”。这意味着：
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
立即学习“go语言免费学习笔记（深入）”；
- 如果生产者提前
close(ch)，但缓冲区还有数据，range会继续读完所有剩余值 - 如果生产者没 close，
range会永远阻塞等待 —— 这是常见 hang 问题根源 - 不要在
range循环里再起 goroutine 处理val后就不管了：若处理慢，主循环会卡在下一次range，导致 channel 堆积
多生产者 + 多消费者怎么避免数据丢失或 panic？
真实服务里几乎不会只有 1 生 1 消。这时必须引入协调机制，否则要么 channel 提前关闭丢数据，要么消费者 goroutine 提前退出漏处理。
- 用
sync.WaitGroup管理所有生产者完成状态，再由主 goroutine 或专用 goroutine 关闭 channel - 消费者数量要显式控制（比如固定 3 个 worker），不能每个任务都起一个 goroutine
- 如果需要超时或取消，必须把
context.Context传进消费者函数，用select监听ctx.Done()，而不是依赖 channel 关闭 - 别在消费者里直接
recover()捕获 panic —— 它大概率来自你误关了 channel 或重复 close，该修逻辑，不是加 recover
最常被忽略的一点：channel 关闭不是“结束信号”，而是“不再有新数据”的声明。它不保证所有已发送数据都被消费完毕 —— 那得靠你设计好消费者退出逻辑，比如用第二个 done channel 或 WaitGroup 等消费者真正处理完最后一条。
