Go 中汇总并发任务结果需协调 goroutine 生命周期并安全收集返回值:channel 适合传结果或处理不确定任务,WaitGroup 适合仅需“全部完成”的轻量场景,二者可组合;用带缓冲 channel(容量为 N)收集确定数量结果,注意防泄漏和死锁。

在 Go 中汇总并发任务的结果,核心是协调 goroutine 的生命周期并安全收集返回值。channel 和 sync.WaitGroup 各有适用场景:channel 更适合需要传递结果、控制流或处理不确定数量/耗时的任务;WaitGroup 更轻量,适合只关心“全部完成”而不需中间结果的场景。两者也可组合使用。
用 channel 收集确定数量的任务结果
当启动 N 个 goroutine 并期望收到 N 个结果时,可创建带缓冲的 channel(容量为 N),每个 goroutine 发送结果后关闭 channel 或由主协程接收完即止。注意避免 goroutine 泄漏和死锁。
- 启动前初始化 buffered channel:
results := make(chan int, numTasks) - 每个 goroutine 执行完后 发送结果:
results (无需 close) - 主 goroutine 用 for 循环 + range 安全接收全部结果:
for i := 0; i (推荐,不依赖 close) - 避免直接
for range results,除非明确会在所有 sender 结束后close(results)
用 channel 处理不确定数量或带错误的任务
当任务可能失败、耗时差异大,或需提前终止时,建议用结构体封装结果,并配合 select + 超时或取消控制。
- 定义结果类型:
type Result struct { Value int; Err error } - 使用 无缓冲 channel 或带缓冲 channel 接收结果,主 goroutine 用
select处理成功、错误、超时: select { case r :=- 配合
context.Context可实现更灵活的取消传播(如某个任务失败就中止其余)
用 WaitGroup + 共享变量汇总(简单场景)
如果只需等待完成、结果可写入预先分配的切片或 map,且无并发写冲突风险,WaitGroup 更简洁。关键是要保证对共享数据的访问是线程安全的。
立即学习“go语言免费学习笔记(深入)”;
- 声明
var wg sync.WaitGroup和线程安全容器(如sync.Map)或加锁的切片 - 每个 goroutine 执行
defer wg.Done(),并在临界区写入结果(例如用mu.Lock()/Unlock()) - 主 goroutine 调用
wg.Wait()后再读取汇总数据 - ⚠️ 不要仅靠 WaitGroup 等待就认为结果已就绪——必须确保写操作已完成且可见(锁或原子操作是必要保障)
Channel 和 WaitGroup 混合使用(推荐模式)
实际项目中常将两者结合:WaitGroup 管理 goroutine 生命周期,channel 传递结果,兼顾安全性与表达力。
- 启动 goroutine 前
wg.Add(1),内部defer wg.Done() - 结果通过 channel 发送,主 goroutine 在
wg.Wait()后仍可从 channel 接收(若未关闭,需配合计数) - 更稳健做法是:用 channel 收集结果,同时用 WaitGroup 确保所有 sender 已退出,再
close(channel),然后range安全遍历










