17370845950

使用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获取全部结果

示例代码结构：

results := make(chan Result, numTasks)
var wg sync.WaitGroup
for i := 0; i < numTasks; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
result := doTask(id)
results <- result
}(i)
}
go func() {
wg.Wait()
close(results)
}()
for result := range results {
// 处理每个结果
}

使用扇出-扇入（Fan-in）模式

当有多个生产者goroutine时，可以将它们的结果汇聚到一个公共channel中，这称为扇入模式。

特别适合将多个独立数据源的结果合并为一个流。

• 每个任务启动一个goroutine，各自写入自己的结果channel
• 另起一个goroutine负责将所有结果channel的内容转发到一个统一的输出channel
• 主协程只从这个统一channel读取即可

常见做法是定义一个函数：func merge(cs ...，它返回一个合并后的channel。

使用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
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()

基本上就这些常见模式。选择哪种方式取决于是否需要错误控制、性能要求、结果顺序是否重要等因素。合理组合channel、WaitGroup、Mutex和errgroup，能高效安全地完成并发结果合并。