如何在Golang中实现任务结果收集_使用channel或WaitGroup汇总

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 更简洁。关键是要保证对共享数据的访问是线程安全的。

• 声明 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 安全遍历