本文详解 Go 语言中如何在支持取消（context cancellation）的并发任务中安全、无泄漏地收集所有已完成的通道结果，重点纠正常见错误写法（如误写 output <- results），并给出健壮的循环控制逻辑与完整示例。
本文详解 go 语言中如何在支持取消（context cancellation）的并发任务中安全、无泄漏地收集所有已完成的通道结果，重点纠正常见错误写法（如误写 `output
在 Go 并发编程中，select 是协调多个通道操作的核心机制。当结合 context.Context 实现可取消的批量计算（如并行 FFT）时，一个关键挑战是：既要及时响应取消信号，又必须确保所有已启动但尚未返回的结果被完整收集，避免 goroutine 泄漏和内存泄漏。
原问题中的代码片段意图良好，但存在两处关键缺陷：
-
通道误用导致 panic 或死锁
case res <- results: // ❌ 错误：results 是 chan T 类型，不能作为接收值 outstanding-- output <- results // ❌ 更严重：再次向 results 发送，类型不匹配且语义错误正确写法应为：
case res := <-results: // ✅ 接收结果值（res 是 T 类型） outstanding-- output <- res // ✅ 转发接收到的具体结果 循环终止条件设计不当，导致结果丢失
原循环 for !done && outstanding > 0 在 ctx.Done() 触发后立即退出，未等待仍在运行的 goroutine 完成并发送结果。此时 outstanding > 0 仍为真，但循环已终止，results 通道中残留的数据将无人接收，造成 goroutine 永久阻塞（泄漏）。
✅ 正确的循环条件应为：
for !done || outstanding > 0 {
select {
case signals := <-input:
outstanding++
go func(s []float64) { // 显式传参，避免闭包变量捕获问题
results <- FFT(s)
}(signals)
case res := <-results:
outstanding--
output <- res // 注意：此处是 res，不是 results！
case <-ctx.Done():
done = true
// 不退出循环，继续处理 results 中已就绪的结果
}
}该逻辑确保：
- 只要还有未完成任务（outstanding > 0）或尚未收到取消信号（!done），循环持续运行；
- 即使 ctx.Done() 触发，只要 results 通道中有待接收数据，select 仍会进入 case res := <-results 分支，逐个消费并转发结果；
- 当所有 goroutine 完成、results 通道空闲、且 done == true 时，循环自然终止，零泄漏。
? 重要注意事项：
- 永远不要在 select 的 case 中对通道变量名与值名混淆（如 res <- results vs res := <-results）；
- 启动 goroutine 时，若引用循环变量（如 signals），务必通过函数参数显式传递，否则可能因闭包延迟捕获导致数据错乱；
- 若需严格保证“所有已启动任务必完成”，建议配合 sync.WaitGroup 或 errgroup.Group 进行更精细的生命周期管理；
- 生产环境推荐使用 golang.org/x/sync/errgroup 封装此类模式，它天然支持 context 取消 + 结果聚合 + 错误传播。
以下是一个最小可运行示例（含模拟 FFT 和测试）：
func ProcessSignals(ctx context.Context, input <-chan []float64, output chan<- []complex128) {
var done bool
outstanding := 0
results := make(chan []complex128, 100) // buffered to prevent sender block
for !done || outstanding > 0 {
select {
case signals, ok := <-input:
if !ok {
done = true
continue
}
outstanding++
go func(s []float64) {
results <- FFT(s) // 模拟计算
}(signals)
case res, ok := <-results:
if !ok {
continue
}
outstanding--
output <- res
case <-ctx.Done():
done = true
}
}
close(output)
}总结：Go 中安全的并发结果收集 ≠ 简单的“启动+接收”，而是一套闭环控制逻辑——以 select 为调度中枢，以 outstanding 计数器为状态锚点，以 !done || outstanding > 0 为守门条件。唯有如此，才能兼顾响应性、正确性与资源安全性。
