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 等待所有结果。
立即学习“go语言免费学习笔记(深入)”;
- 缓冲大小设为
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 自己处理。










