答案：Go并发错误处理需根据场景选择策略。使用channel可基础收集错误，errgroup实现快速失败，结合mutex的切片收集全部错误，引入context控制超时与取消，确保程序健壮性。
在Go语言开发中，错误处理是程序健壮性的关键环节。当程序进入并发场景，尤其是使用大量goroutine时，如何有效捕获并汇总错误变得尤为重要。单纯地在每个goroutine中打印错误或忽略返回值，会导致关键问题被遗漏。下面介绍几种在并发环境下处理和收集错误的实用方式。
基础错误传递：使用channel收集error
最直接的方式是通过一个专门用于传递错误的channel，将各个goroutine中产生的错误发送回主协程进行统一处理。
建议定义一个带缓冲的error channel，或者使用
sync.WaitGroup配合无缓冲channel，确保所有goroutine完成后再关闭channel，避免读取已关闭的channel。
示例：
立即学习“go语言免费学习笔记（深入）”；
errCh := make(chan error, 10) // 缓冲channel避免阻塞 var wg sync.WaitGroupfor i := 0; i < 5; i++ { wg.Add(1) go func(id int) { defer wg.Done() if err := doWork(id); err != nil { errCh <- fmt.Errorf("goroutine %d failed: %w", id, err) } }(i) }
go func() { wg.Wait() close(errCh) }()
var errors []error for err := range errCh { errors = append(errors, err) }
if len(errors) > 0 { for _, e := range errors { log.Println("Error:", e) } }
使用errgroup简化并发错误管理
golang.org/x/sync/errgroup包提供了更简洁的并发控制方式。它自动管理goroutine生命周期，并在任意一个任务返回非nil错误时取消其他任务（如果使用了context）。
适合需要“快速失败”策略的场景——一旦某个goroutine出错，立即中止整个操作。
用法示例：
import "golang.org/x/sync/errgroup"var g errgroup.Group
for i := 0; i < 5; i++ { i := i g.Go(func() error { return doWork(i) // 如果任意一个返回error，g.Wait()将返回该error }) }
if err := g.Wait(); err != nil { log.Printf("At least one goroutine failed: %v", err) }
注意：errgroup默认不会等待所有任务完成，第一个错误就会导致其余任务被取消（前提是任务响应context取消信号）。
收集所有错误而非仅第一个
有些业务场景需要知道所有子任务的执行结果，包括所有失败项，而不是遇到第一个错误就退出。
此时可以结合
sync.Mutex保护一个共享的错误切片，确保并发写安全。
示例：
立即学习“go语言免费学习笔记（深入）”；
var (
mu sync.Mutex
errors []error
)
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
if err := doWork(id); err != nil {
mu.Lock()
errors = append(errors, fmt.Errorf("task %d: %w", id, err))
mu.Unlock()
}
}(i)
}
wg.Wait()
if len(errors) > 0 {
for _, e := range errors {
log.Println("Failed:", e)
}
}
这种方式牺牲了“快速失败”的特性，但能完整收集所有错误信息，适用于数据校验、批量导入等场景。
上下文取消与超时控制
在并发任务中，长时间阻塞的goroutine应能被及时终止。结合
context可实现超时或主动取消，防止资源泄漏。
推荐将context传入每个goroutine，并在关键阻塞点检查
ctx.Done()。
与errgroup结合使用效果更佳：
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second) defer cancel()g, ctx := errgroup.WithContext(ctx)
for i := 0; i < 5; i++ { i := i g.Go(func() error { return longRunningTask(ctx, i) }) }
if err := g.Wait(); err != nil { log.Printf("Task failed or timed out: %v", err) }
这样既能收集错误，又能控制整体执行时间。
基本上就这些。根据业务需求选择合适的错误收集策略：需要快速失败用errgroup；需要全量错误用带锁的切片；强调响应性则加上context控制。关键是避免goroutine泄漏和错误被静默吞掉。
