Go中实现生产者消费者模型需用channel与goroutine协作：无缓冲channel同步传递，有缓冲channel解耦节奏并防阻塞；多goroutine并发生产/消费，配合close()和range优雅退出。
在 Go 语言中实现生产者消费者模型，核心是利用 channel 和 goroutine 的天然协作能力，无需锁或复杂同步逻辑。关键在于合理设计 channel 的缓冲区、控制 goroutine 生命周期，以及避免死锁和资源泄漏。
用无缓冲/有缓冲 channel 控制数据流
channel 是生产者与消费者之间的“管道”。无缓冲 channel 要求生产者和消费者必须同时就绪才能传递数据（同步），适合强顺序或低吞吐场景；有缓冲 channel（如 make(chan int, 100)）可解耦两者节奏，提升吞吐量，但需注意缓冲区满时生产者会阻塞。
- 若生产速度远高于消费速度，建议设置合理缓冲容量，并配合超时或丢弃策略（如 select + default）防止无限阻塞
- 若要求严格顺序或实时性高，可用无缓冲 channel，配合
range配合close()优雅退出
启动多个 goroutine 并发生产和消费
生产者和消费者都应作为独立 goroutine 运行。常见模式是：一个或多个生产者 goroutine 向 channel 发送数据；一个或多个消费者 goroutine 从 channel 接收并处理数据。
- 用
for i := 0; i 启动多个生产者 - 用
for i := 0; i 启动多个消费者 - 主 goroutine 可通过
sync.WaitGroup等待所有生产者完成，再关闭 channel（仅由生产者方 close，且只 close 一次）
安全关闭 channel 并通知消费者退出
channel 关闭后，消费者仍可读取剩余数据，但再次读取会立即返回零值和 false。正确关闭方式是：生产者全部结束前调用 close(ch)，消费者用 for v, ok := 或 <code>for v := range ch 自动退出。
立即学习“go语言免费学习笔记（深入）”；
- 切勿在消费者中 close channel，易引发 panic
- 多个生产者时，用
sync.WaitGroup计数，最后一个生产者负责 close - 若需中断运行，可用额外的
done chan struct{}配合 select 实现取消机制
加一层抽象：封装成可复用的 Worker Pool
实际项目中常将消费者抽象为工作池（Worker Pool），统一管理 goroutine 数量和任务分发。例如定义 type Job func()，用 channel 分发任务，固定数量 worker 持续消费。
- worker 数量通常设为 CPU 核心数或根据 I/O 密集度调整（如网络请求多可适当增加）
- 任务 channel 建议带缓冲，避免提交任务时阻塞调用方
- 支持 graceful shutdown：发送关闭信号 → 等待正在执行的任务完成 → 关闭结果 channel
基本上就这些。Go 的并发模型让生产者消费者变得轻量又可靠，重点是理解 channel 的生命周期和 goroutine 的协作边界，不复杂但容易忽略细节。
