Go 通道多协程结果收集方法

本文深入探讨了Go语言中利用channel安全高效收集多协程（goroutine）执行结果的核心实践，强调其本质是“并发写、顺序读”，并指出常见陷阱如未显式关闭channel导致range阻塞、多处close引发panic等；推荐结合sync.WaitGroup确保所有goroutine完成后再统一关闭缓冲channel，并通过结构体封装结果与错误以提升健壮性，适用于HTTP请求聚合、数据库并行查询、分片计算等典型场景，为Go并发编程中结果收集提供了清晰、可靠、生产就绪的解决方案。

channel 用来收集多协程结果，本质是「并发写 + 顺序读」

Go 中用 channel 收集多个 goroutine 的结果，核心不是“怎么启动协程”，而是确保所有结果能安全、完整、按需地被主协程拿到。最常见错误是：忘了关闭 channel 导致 range 卡死，或没做同步直接读空 channel。

典型场景是「发多个 HTTP 请求」「查多个数据库表」「并行计算分片数据」——每个子任务产出一个值（或结构体），主协程等全部完成再统一处理。

• 必须用 close() 显式关闭发送端，否则 for range ch 永远阻塞
• 不要在多个 goroutine 里都调 close(ch)，会 panic：close of closed channel
• 如果某个 goroutine 可能 panic 或提前退出，需用 recover 或 defer 确保关闭逻辑执行

用 sync.WaitGroup 配合 channel 关闭最稳妥

靠超时或计数器判断完成不可靠；WaitGroup 是 Go 官方推荐的等待协程结束的方式，它和 channel 关闭天然契合：所有任务结束 → 关闭 channel → 主协程退出 range。

results := make(chan int, 10)
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go func(n int) {
defer wg.Done()
results <- n * n // 模拟计算
}(i)
}
// 单独 goroutine 等待并关闭
go func() {
wg.Wait()
close(results)
}()
for res := range results {
fmt.Println(res) // 输出 0 1 4 9 16
}

• 缓冲区大小建议设为任务数（如 make(chan T, N)），避免发送阻塞影响协程退出
• 关闭操作必须在独立 goroutine 里做，不能放循环后——否则主协程还没开始 range 就关了
• 不用 select + default 读 channel，那会漏数据；range 是唯一安全遍历方式

带错误的结果收集：用结构体封装 value 和 error

实际业务中，不是所有子任务都成功。若用两个 channel 分别传结果和错误，主协程要同时 select，逻辑复杂且易漏处理。更简洁的做法是定义结果结构体，统一走一个 channel。

type Result struct {
    Value int
    Err   error
}
results := make(chan Result, 5)
// ... 启动 goroutine，每个都 send Result{Value: x, Err: err}
// 主协程：
for r := range results {
if r.Err != nil {
log.Printf("task failed: %v", r.Err)
continue
}
process(r.Value)
}

• 避免用 interface{} 或 map[string]interface{} 做泛型结果，类型丢失导致后续难维护
• 如果错误需要中断整个流程（比如认证失败），可在发送前加判断，或让主协程收到特定错误后 break
• 注意：nil error 在 struct 里默认就是 nil，不用额外初始化

当结果量大或耗时长时，考虑带超时的 select 读取

如果某些子任务可能卡住（如网络请求 hang 住），不能无限制等下去。这时要在主协程用 select 控制单次读取时间，而不是依赖 range ——因为 range 无法中断。

timeout := time.After(3 * time.Second)
for i := 0; i 

• 用 time.After 而非 time.NewTimer，简单场景够用；注意它是一次性 timer
• 如果只是防止单个结果延迟，用这个模式；如果要整体超时（比如最多等 3 秒收齐所有结果），则应在 WaitGroup 等待时加超时
• 不要在 select 里重复使用同一个 timeout channel，它会只触发一次；需要重置就用 time.AfterFunc 或新建 timer

关键点其实就两个：谁关 channel、什么时候关。很多人卡在“为什么 range 不退出”，答案往往就藏在 close() 是否被执行、是否被执行了多次、是否在正确时机执行。

本篇关于《Go 通道多协程结果收集方法》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！