Golang并发错误处理技巧

goroutine 中的 error 无法直接返回给主 goroutine，必须通过 channel 或 errgroup.Group 等线程安全方式显式传递；需配合 WaitGroup 或 context 防泄漏，panic 需 recover 转为 error 发送。

goroutine 中的 error 无法直接返回给主 goroutine

Go 的 goroutine 是独立执行的，函数调用一旦用 go 启动，就脱离了当前调用栈。这意味着你在 goroutine 里 return err 是无效的——主 goroutine 根本收不到。

常见错误现象：
– 主函数提前退出，没等所有 goroutine 执行完
– 错误被打印但没被处理，或直接被忽略
– 多个 goroutine 同时写同一个 error 变量导致竞态（data race）

正确思路：必须显式传递错误出口，且保证线程安全。推荐方式是用 channel 或带锁结构体。

用带缓冲的 error channel 收集所有 goroutine 错误

定义一个 chan error，容量等于并发数（避免阻塞），每个 goroutine 执行完后把 err 发送到该 channel。主 goroutine 用 for range 等待所有结果。

• 缓冲大小设为 len(tasks)，防止某个 goroutine panic 导致 channel 阻塞住其他 goroutine
• 即使某个 goroutine 返回 nil，也建议统一发 nil 到 channel，方便主 goroutine 统一计数
• 务必配合 sync.WaitGroup 或 context.WithTimeout 防止 goroutine 泄漏

tasks := []string{"a", "b", "c"}
errCh := make(chan error, len(tasks))
var wg sync.WaitGroup
for _, t := range tasks {
wg.Add(1)
go func(task string) {
defer wg.Done()
err := doWork(task)
errCh <- err // 即使 err == nil 也要发送
}(t)
}
wg.Wait()
close(errCh)
var errs []error
for err := range errCh {
if err != nil {
errs = append(errs, err)
}
}

使用 errgroup.Group 替代手写 WaitGroup + channel

golang.org/x/sync/errgroup 是官方维护的扩展包，封装了并发错误收集逻辑：首个非 nil 错误会取消其余 goroutine（可选），并自动等待全部完成。

• 默认行为是“遇到第一个 error 就返回”，适合“任一失败即终止”的场景
• 若需收集全部错误，得自己加 channel 或改用 errgroup.WithContext(context.Background()) 并禁用 cancel
• 注意：如果不用 WithContext，Go 方法内部不会检查 context，也就不会主动中断正在运行的 goroutine

import "golang.org/x/sync/errgroup"
g := new(errgroup.Group)
for _, task := range tasks {
task := task // 避免循环变量捕获问题
g.Go(func() error {
return doWork(task)
})
}
err := g.Wait() // 返回第一个非 nil error，或 nil（全部成功）

并发中 panic 会导致 error channel 无法接收，必须 recover

如果 goroutine 内部发生 panic，它不会自动转成 error 发到 channel，而是直接崩溃，主 goroutine 的 range errCh 会永远卡住（除非 channel 关闭）。

所以，任何不可信的并发任务都应包裹 defer/recover：

g.Go(func() error {
    defer func() {
        if r := recover(); r != nil {
            // 转成 error，比如 fmt.Errorf("panic: %v", r)
            errCh <- fmt.Errorf("panic: %v", r)
        }
    }()
    return doWork(task)
})

真正容易被忽略的是：recover 只对当前 goroutine 有效；你不能在主 goroutine 里 recover 别的 goroutine 的 panic —— 必须每个 goroutine 自己处理。