不能直接 close(channel) 后退出生产者，因为 close 是广播“永不写入”信号，若消费者尚未读完，会导致读取已关闭 channel 时 ok=false，产生逻辑错误或提前终止；正确做法是确保所有生产者完成且无新数据后才关闭。
Go 语言里用
+
实现生产者消费者，根本不需要第三方库，也不该套 Java 那套锁+队列的思路——直接用原生并发原语，写错的关键往往出在 channel 关闭时机和 goroutine 泄漏上。
为什么不能直接 close(channel) 后就退出生产者
关闭
是广播信号，不是“我干完了”，它意味着“不会再有新数据”。但消费者可能还在读，如果生产者提前
，而某个消费者刚执行到
就会立刻变
，导致提前退出，漏处理数据。
正确做法是：所有生产者都完成后再统一
，常用
协调
更稳妥的是用
控制生命周期，尤其当生产者可能因错误提前终止时
绝对不要在多个 goroutine 里并发调用
，会 panic：
消费者怎么安全地从 channel 持续读取
用
最简洁，但它隐含依赖
被关闭——没关就永远阻塞。实际生产中，消费者常需响应中断、超时或外部指令，硬写
反而难控制。
推荐显式循环 +
：
避免用
处理带超时或取消逻辑的场景
如果消费者要并行处理（比如启 3 个 goroutine 读同一 channel），
依然安全；但若每个消费者有自己的退出条件，必须用
+
判断
缓冲 channel 和无缓冲 channel 怎么选
选哪个不看“性能”，而看**背压是否由 channel 承担**。无缓冲 channel 是同步点，生产者必须等消费者准备好才能发；缓冲 channel 把等待转移到 buffer 内存里，但 buffer 满了也会阻塞。
go语言参考手册 中文CHM版
Go 是一个开源的编程语言，它能让构造简单、可靠且高效的软件变得容易。本文给大家带来Go参考手册，需要的可以来下载！ Go是从2007年末由Robert Griesemer, Rob Pike, Ken Thompson主持开发，后来还加入了Ian Lance Taylor, Russ Cox等人，并最终于2009年11月开源，在2012年早些时候发布了Go 1稳定版本。现在Go的开发已经是完全开放的，并且拥有一个活跃的社区。 Go 语言特色 简洁、快速、安全 并行、有趣、开源 内存管理、v数组安全、编译
下载
立即学习
“
go语言免费学习笔记（深入）
”；
实时性要求高（如日志采集）、上下游处理速度接近 → 用无缓冲
生产快、消费慢，且允许短暂积压（如批量写 DB）→ 设合理缓冲
；但别设太大，否则内存爆掉都收不到 OOM 信号
缓冲大小不是拍脑袋定的：观察监控里的 channel 长度（
）和阻塞频率，再调整
最易被忽略的一点：生产者消费者模型里，真正难的从来不是“怎么发/怎么收”，而是“谁负责回收 goroutine”和“错误如何透出”。一个没
的生产者 goroutine，或者没处理
的消费者，跑几天就内存泄漏。别只盯着 channel 通不通，得盯住整个 goroutine 生命周期。
channelgoroutinechannelclose(ch)val, ok := 的 okfalseclose(ch)sync.WaitGroupcontext.WithCancelclose(ch)panic: close of closed channelfor range chchannelfor rangeselectfor {
select {
case val, ok := <-ch:
if !ok {
return // channel closed
}
process(val)
case <-ctx.Done():
return // 被取消
}
}for val := range chfor rangeselectokch := make(chan int)ch := make(chan int, 100)len(ch)WaitGroup.Done()ctx.Err()