必须由单独goroutine在wg.Wait()后close(ch)因多生产者共用通道时自行关闭易致数据丢失、panic或消费者阻塞单生产者看似可自关但扩展后风险高无缓冲chan是同步点带缓冲chan可解耦生产消费节奏。为什么不能让生产者自己调用 close(ch)因为多个生产者共用一个 ch 时谁关、何时关、关几次Go 不会帮你协调——关早了数据丢关两次直接 panicpanic: close of closed channel关晚了消费者卡在 range 里等不到结束信号。唯一安全的关闭时机是所有生产者都发完、都调过 wg.Done() 之后必须由一个单独 goroutine 负责监听 wg.Wait() 后再 close(ch)不能混在任意一个生产者函数里如果只有一个生产者看似可以自己关但一旦后续扩展为多个就立刻埋雷带缓冲 vs 无缓冲 chan 怎么选无缓冲 chan int 是同步点生产者 ch 会卡死直到有消费者正好执行 code。这适合强顺序控制或调试但实际服务中容易导致 goroutine 积压、吞吐骤降。生产速率波动大、消费耗时不确定 → 用带缓冲比如 make(chan Task, 10)缓冲大小不是越大越好make(chan int, 1000) 可能掩盖背压积压大量未处理任务OOM 风险上升经验值按「峰值 QPS × 平均处理延迟」估算例如每秒 50 个任务、每个耗时 200ms缓冲设为 10–15 比较稳妥多个消费者怎么避免漏数据或重复消费Go 的 channel 天然支持多路并发读多个消费者 for range ch 读同一个 ch不会重复也不会遗漏——运行时按就绪顺序分发不是轮询也不是广播。不需要 dispatcher 或分发 goroutine除非你明确要轮询/加权/限流不要用 select 多个 case 在同一个 goroutine 里“抢”数据那只是伪并发还可能漏若需监控积压量可用 len(ch) 查当前队列长度注意不是 cap但别在热路径频繁调用如何安全加超时和取消支持真实场景中你几乎总会遇到“这个任务卡住了”或“上游已经不要结果了”硬等 range ch 结束不行得靠 context.Context。 VWO 一个A/B测试工具