使用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.WaitGroupfor 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。
Shopxp购物系统历经多年的考验，并在推出shopxp免费购物系统下载之后，收到用户反馈的各种安全、漏洞、BUG、使用问题进行多次修补，已经从成熟迈向经典，再好的系统也会有问题，在完善的系统也从在安全漏洞，该系统完全开源可编辑，当您下载这套商城系统之后，可以结合自身的技术情况，进行开发完善，当然您如果有更好的建议可从官方网站提交给我们。Shopxp网上购物系统完整可用，无任何收费项目。该系统经过
使用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.WaitGroupfor 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，能高效安全地完成并发结果合并。
