Go并发错误处理需通过channel传递错误，使用errgroup统一管理并取消任务，结合错误包装增加上下文，避免panic导致崩溃，确保错误不被忽略。
Go语言通过goroutine和channel实现了简洁高效的并发模型，但在并发场景下处理错误比单线程复杂得多。由于goroutine是独立执行的，直接在goroutine中panic或return error并不会被主流程捕获，因此需要专门的机制来传递和处理错误。
1. 使用通道（Channel）收集错误
最常见的方式是通过一个专门用于传递错误的channel，在多个goroutine之间汇总错误信息。
定义一个error类型的channel，每个并发任务完成后将错误发送到该channel。主协程通过接收这些错误进行统一处理。
示例：func worker(id int) error {
// 模拟任务执行
if id == 3 {
return fmt.Errorf("worker %d failed", id)
}
return nil
}
func main() {
errCh := make(chan error, 5) // 缓冲通道避免阻塞
for i := 0; i < 5; i++ {
go func(i int) {
errCh <- worker(i)
}(i)
}
var errs []error
for i := 0; i < 5; i++ {
if err := <-errCh; err != nil {
errs = append(errs, err)
}
}
if len(errs) > 0 {
for _, err := range errs {
log.Println("Error:", err)
}
}
}
使用带缓冲的error channel可以防止goroutine因无法发送错误而阻塞退出。等待所有goroutine完成后再读取错误，确保不遗漏。
2. 利用errgroup简化错误管理
errgroup.Group 是官方扩展包golang.org/x/sync/errgroup提供的工具，能自动传播第一个返回的非nil错误，并取消其他正在运行的goroutine（配合context使用）。
示例：import "golang.org/x/sync/errgroup"
func main() {
var g errgroup.Group
urls := []string{"https://www./link/374cad868cb62202553d308252bc4040", "https://www./link/ae9f22c1a98cf769e89facdc1cd7dec9"}
for _, url := range urls {
url := url
g.Go(func() error {
resp, err := http.Get(url)
if err != nil {
return err
}
resp.Body.Close()
return nil
})
}
if err := g.Wait(); err != nil {
log.Printf("Failed to fetch URLs: %v", err)
}
}
errgroup会等待所有任务完成，只要有一个返回错误，其余仍在执行的任务应通过context感知取消信号及时退出，避免资源浪费。
3. 错误包装与上下文信息添加
并发中发生的错误往往缺乏上下文，建议使用errors.Wrap或fmt.Errorf("%w")方式包装原始错误，加入goroutine标识、操作类型等信息，便于排查。
g.Go(func() error {
if err := doSomething(); err != nil {
return fmt.Errorf("worker %d: doSomething failed: %w", id, err)
}
return nil
})
这样在最终打印错误栈时，能清楚知道是哪个worker在哪一步出错，提升可维护性。
4. 避免panic导致程序崩溃
goroutine中的未捕获panic会导致整个程序崩溃。对于不可控的外部调用，建议使用recover进行兜底处理，并将panic转为error返回。
g.Go(func() error {
defer func() {
if r := recover(); r != nil {
log.Printf("Panic recovered: %v", r)
}
}()
// 可能panic的操作
result := riskyOperation()
return process(result)
})
注意：recover只能在defer中生效，且recover后无法恢复执行，只能做清理和记录。更推荐从设计上避免依赖panic。
基本上就这些。Go的并发错误处理核心在于“传递”而非“忽略”。合理使用channel、errgroup、错误包装和recover机制，可以让并发程序既高效又健壮。关键是提前规划错误上报路径，不要让错误消失在goroutine中。
log.Printf("Panic recovered: %v", r)
}
}()
