使用channel、WaitGroup、扇入模式、errgroup和Mutex等方法可高效合并Go并发任务结果，选择取决于错误处理、性能和顺序需求。
在Golang中处理并发任务时，经常需要将多个协程的结果合并并统一处理。由于Go语言原生支持并发（goroutine 和 channel），实现结果合并的方式灵活多样。以下是几种常见的并发结果合并方法，适用于不同场景。
使用Channel收集结果
最基础也最常用的方法是通过一个带缓冲或无缓冲的channel来接收各个goroutine的执行结果。
每个任务完成后，把结果发送到channel，主协程从channel中读取所有结果。
关键点： 确保所有发送操作完成后关闭channel，避免死锁。- 创建一个result channel，例如 chan ResultType
- 每个goroutine执行完任务后向channel发送结果
- 使用WaitGroup等待所有goroutine完成，并在最后关闭channel
- 主协程range遍历channel获取全部结果
示例代码结构：
立即学习“go语言免费学习笔记（深入）”；
results := make(chan Result, numTasks)
var wg sync.WaitGroup
<p>for i := 0; i < numTasks; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
result := doTask(id)
results <- result
}(i)
}</p><p>go func() {
wg.Wait()
close(results)
}()</p><p>for result := range results {
// 处理每个结果
}</p>使用扇出-扇入（Fan-in）模式
当有多个生产者goroutine时，可以将它们的结果汇聚到一个公共channel中，这称为扇入模式。
特别适合将多个独立数据源的结果合并为一个流。
- 每个任务启动一个goroutine，各自写入自己的结果channel
- 另起一个goroutine负责将所有结果channel的内容转发到一个统一的输出channel
- 主协程只从这个统一channel读取即可
常见做法是定义一个函数：func merge(cs ...，它返回一个合并后的channel。
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
使用errgroup.Group进行错误传播与结果收集
对于需要统一处理错误的并发任务，golang.org/x/sync/errgroup 提供了更高级的控制能力。
它不仅能并发执行任务，还能在任意任务出错时取消其他任务，并返回首个错误。
- 通过 group.Go() 启动任务
- 每个任务函数返回error，用于错误判断
- 结合channel或其他共享变量收集成功结果
- 调用 group.Wait() 阻塞直到所有任务结束
注意：errgroup不直接返回结果，需配合闭包或带锁的slice/map存储结果。
使用sync.Mutex保护共享结果集合
当多个goroutine需要往同一个slice或map中写入结果时，必须使用互斥锁防止竞态条件。
虽然性能不如纯channel方式，但在某些聚合逻辑中更直观。
- 声明一个全局或闭包内的结果切片和Mutex
- 每次写入前调用 mutex.Lock()，写入后立即解锁
- 配合WaitGroup确保所有写入完成
示例：
var results []Result
var mu sync.Mutex
var wg sync.WaitGroup
<p>for i := 0; i < n; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
res := doTask(i)
mu.Lock()
results = append(results, res)
mu.Unlock()
}(i)
}
wg.Wait()</p>基本上就这些常见模式。选择哪种方式取决于是否需要错误控制、性能要求、结果顺序是否重要等因素。合理组合channel、WaitGroup、Mutex和errgroup，能高效安全地完成并发结果合并。
