Go中生产者消费者模式核心是用channel作安全数据管道，配合goroutine并发执行；无缓冲channel实现强同步，带缓冲channel提升吞吐；生产者发送任务并close，消费者用range安全遍历。
用 Go 实现生产者消费者模式，核心是利用 channel 作为协程间安全的数据管道，配合 goroutine 并发执行，无需额外加锁即可保证任务数据传递的安全性。
用 channel 作为任务队列
channel 天然支持并发读写，是 Go 中最简洁、最安全的任务传递机制。定义一个带缓冲或无缓冲的 channel，类型为待处理任务（如 chan int 或自定义结构体）：
- 无缓冲 channel：生产者会阻塞直到消费者接收，适合强同步场景
- 带缓冲 channel（如
make(chan Task, 100)）：提升吞吐，避免生产者频繁阻塞
启动生产者和消费者 goroutine
生产者向 channel 发送任务，消费者从 channel 接收并处理。注意用 close() 通知消费者结束，消费者用 range 遍历更简洁安全：
- 生产者示例：
for i := 0; i ，完成后close(ch) - 消费者示例：
for task := range ch { process(task) }，自动退出循环
控制并发数量与优雅退出
多个消费者可并行处理任务，但需避免无限 goroutine 泛滥。常用做法是固定 worker 数量，并通过 done channel 或 context 支持取消：
立即学习“go语言免费学习笔记（深入）”；
- 用
sync.WaitGroup等待所有 worker 完成 - 用
context.WithCancel在外部触发停止，worker 检查ctx.Done()提前退出 - 避免在已关闭的 channel 上发送数据，否则 panic；可在发送前加判断或用
select+default非阻塞尝试
处理任务失败与重试（可选增强）
真实场景中任务可能失败，可引入结果 channel 或错误重入机制：
- 消费者处理完后，将结果或错误发到另一个
chan Result，由主 goroutine 统一收集 - 对失败任务，可重新发回原 channel（需限制重试次数），或投递到死信队列（单独 channel）
- 使用
select配合超时控制单个任务处理时长，防止某个任务卡死整个 worker
不复杂但容易忽略。关键就是 channel 的声明、关闭时机、range 语义和 worker 生命周期管理。
