chan 不是队列，而是同步通信原语，缺乏扩容、Peek/Cancel/Size 等操作，close 后写入 panic，空读阻塞，缓冲通道满时发送阻塞，多 goroutine range 同 channel 会导致竞争与饥饿，无法跳过任务或动态调优消费者。
为什么直接用 chan 做队列容易出错
Go 的 chan 本身不是队列，而是同步通信原语。它没有长度自动扩容、不支持 Peek/Cancel/Size 等常见队列操作，且 close 后再写会 panic，未关闭时读空会阻塞——这些在任务调度、批量消费等场景下极易引发死锁或 panic。
- 用
make(chan T, N)模拟队列？缓冲区满后send会阻塞，无法优雅降级或重试 - 多个 goroutine 同时
range同一个 channel？只有第一个能读到全部数据，其余全被饿死 - 想“跳过”某个任务或动态调整消费者数量？原生 channel 不提供控制接口
用 chan + goroutine 实现可取消的 Worker Pool
真正实用的并发队列处理，核心是「生产者只管发，消费者池按需拉取，失败可重入，整体可停止」。下面是一个最小可用模式：
func startWorkerPool(tasks <-chan string, workers int, done chan<- struct{}) {
var wg sync.WaitGroup
for i := 0; i < workers; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for {
select {
case task, ok := <-tasks:
if !ok {
return
}
process(task)
case <-done:
return
}
}
}()
}
go func() {
wg.Wait()
close(done)
}()
}
func process(task string) {
// 模拟可能失败的操作
if strings.Contains(task, "error") {
log.Printf("failed: %s", task)
return
}
log.Printf("done: %s", task)
}
关键点：select 中同时监听 tasks 和 done，确保任意时刻都能响应退出信号；done 是单向接收通道，由外部控制生命周期。
buffered channel 的真实适用边界
缓冲通道只适合「生产节奏稳定、消费能力恒定、允许少量积压」的简单流水线，比如日志采集器的本地暂存。一旦涉及以下情况，就该换方案：
立即学习“go语言免费学习笔记（深入）”；
- 任务执行时间差异大（如混合 IO/计算型任务）→ 缓冲区迅速耗尽或长期闲置
- 需要按优先级分发（如 admin 任务 > user 任务）→
chan无优先级机制 - 要统计当前待处理数或监控堆积水位 → 必须额外加锁维护计数器，失去 channel 的简洁性
此时更稳妥的做法是：用 sync.Map 或 container/list 配合 sync.Mutex 实现有界队列，再用 chan struct{} 触发 worker 唤醒，而非直接把任务塞进 channel。
别忽略 context.Context 对取消传播的必要性
上面示例中 done chan 是简化版。实际项目中必须用 context.Context 替代，否则无法传递超时、层级取消或携带值：
func startWorkerPoolWithContext(ctx context.Context, tasks <-chan string, workers int) {
var wg sync.WaitGroup
for i := 0; i < workers; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for {
select {
case task, ok := <-tasks:
if !ok {
return
}
if err := processWithContext(ctx, task); err != nil {
// ctx.Err() 可能是 DeadlineExceeded 或 Canceled
return
}
case <-ctx.Done():
return
}
}
}()
}
go func() { wg.Wait() }()
}注意：processWithContext 内部所有 IO 操作（如 HTTP 调用、DB 查询）都必须接受并传递 ctx，否则取消信号无法穿透到底层。这是最容易漏掉的一环。
