捕获阶段：并发场景中的错误来源与识别
Go 的错误模型与并发的关系
在 Golang 中，错误是值类型，通过返回值向上层传递，而在并发场景下需要将每个 goroutine 的错误整合到主控制流中，避免遗漏。panic 是一种极端情况，通常用于不可恢复的编程错误，而 recover 则提供在一定边界内的保护才能继续执行。为了实现稳定的并发错误处理，必须在每个并发单元中尽早对可能的错误进行检测与封装。
正确理解错误捕获的关键在于区分两条路径：一条是显式返回的 error 值，另一条是隐式的 panic 引发的崩溃。前者适合作为业务流程的正常分支，后者需要在边界处通过 recover 转换为可处理的错误信息。下面的代码演示了在并发场景中捕获错误的基本模式：
func worker(id int) error {// 可能返回一个错误if id%2 == 0 {return fmt.Errorf("worker %d failed", id)}return nil
}
异常与错误的区分与处理策略
在高并发场景中，应将异常从错误中分离：错误值用于正常流程的失败回传，panic通常用于不可预期的异常。为避免程序因为一次错误而中断，应该在每个并发单元内尽量捕获并将结果回传给调度端，避免未捕获的 panics 脱出。下面的要点帮助你在捕获阶段打好基础：局部保护、明确返回、统一封装。
下面展示一个简化的捕获示例，展示如何在并发单元内将错误封装后传回上层：
func main() {n := 5errCh := make(chan error, n)for i := 0; i < n; i++ {go func(id int) {if err := worker(id); err != nil {errCh <- fmt.Errorf("worker %d: %w", id, err)return}errCh <- nil}(i)}// 收集错误var firstErr errorfor i := 0; i < n; i++ {if err := <-errCh; err != nil {if firstErr == nil {firstErr = err}}}if firstErr != nil {// 将错误向上传播fmt.Println("runtime error:", firstErr)}
}
传播阶段：将错误从 goroutine 到主控流的传递与聚合
通道传递错误的基本模式
在并发模型中，通道（channel）是最直接的错误传播载体。通过为错误设定一个缓冲区或一个专用错误通道，可以让每个 goroutine 把自己的结果或错误发回，主控流再统一聚合处理。实现要点包括：容量控制、避免阻塞、以及对早期错误的 快速终止。
下面给出一个使用通道传播错误的模板：
func main() {n := 3errCh := make(chan error, n)for i := 0; i < n; i++ {go func(id int) {if err := doWork(id); err != nil {errCh <- errreturn}errCh <- nil}(i)}// 聚合错误，处理完所有通道后再决定后续动作var errs []errorfor i := 0; i < n; i++ {if err := <-errCh; err != nil {errs = append(errs, err)}}if len(errs) > 0 {// 将聚合后的错误向上传播fmt.Printf("collected errors: %#v\n", errs)}
}
结合 errgroup 的并发错误传播策略
golang.org/x/sync/errgroup 提供了一种简单而强大的并发错误传播方案：将多个 goroutine 放入一个组中，任意一个返回错误就取消其他任务并在等待结束时统一返回。该模式在实际项目中非常常见，尤其是需要对多个独立任务并发执行并在任一任务失败时快速回滚的场景。
如下示例展示了如何使用 errgroup 进行并发执行并传播错误：
import ("context""fmt""golang.org/x/sync/errgroup"
)func main() {urls := []string{"https://a.example", "https://b.example", "https://c.example"}g, ctx := errgroup.WithContext(context.Background())for _, u := range urls {u := ug.Go(func() error {// 可能出现错误return fetchWithContext(ctx, u)})}if err := g.Wait(); err != nil {fmt.Println("group error:", err)}
}
恢复阶段：利用 recover 将异常转换为可控的错误流
recover 的正确使用场景与边界
Golang 中 recover 只在 defer 函数中才有效，用于保护边界、阻止当前 goroutine 的崩溃将传播到其他 goroutines。一个常见的做法是在可能发生 panic 的代码周围建立一个保护层，将 panic 转换为一个可处理的错误值（通常通过命名返回值或通道回传）。
需要注意的是，recover 不是一个错误处理的替代品，它只是阻止崩溃并把异常信息转化为错误信息供后续处理。它的使用应尽可能局部、可控，以避免隐藏程序中的逻辑错误。
下面给出一个包含 recover 的模板：
func safeCall() (err error) {defer func() {if r := recover(); r != nil {// 将 panic 转换为错误，向上传递err = fmt.Errorf("panic recovered: %v", r)}}()// 可能触发 panic 的业务逻辑mayPanic()return nil
}
将恢复嵌入并发执行中的示例
在并发执行中单独对每个任务进行恢复，确保一个任务的 panic 不会影响其他任务的执行，是一种常见的稳健做法。通过在工作单元中嵌入 recover，可以将 panics 转换为可处理的错误，随后进行聚合与传播。
func workerWithRecovery(id int) (err error) {defer func() {if r := recover(); r != nil {err = fmt.Errorf("worker %d panic: %v", id, r)}}()// 这里的代码可能会 panicif id%5 == 0 {panic("boom")}return nil
}
现代模式与工具：将捕获、传播、恢复整合到稳定的并发结构中
结合 context、errgroup 与 recover 的实战模式
在实践中，使用 context.Context 结合 errgroup，可以实现对取消信号的传递、错误的聚合以及对 panic 的局部恢复。这样不仅能在出现错误时尽快停止无关工作，还能避免资源泄露和 goroutine 漏洞。下面给出一个综合模板：
import ("context""fmt""net/http""golang.org/x/sync/errgroup"
)func fetchAll(urls []string) error {g, ctx := errgroup.WithContext(context.Background())for _, u := range urls {u := ug.Go(func() error {// 每个任务都带有恢复保护if err := func() (err error) {defer func() {if r := recover(); r != nil {err = fmt.Errorf("panic on %s: %v", u, r)}}()req, _ := http.NewRequestWithContext(ctx, "GET", u, nil)resp, err := http.DefaultClient.Do(req)if err != nil {return err}resp.Body.Close()return nil}(); err != nil {return err}return nil})}if err := g.Wait(); err != nil {return err}return nil
}
实战示例：从捕获到传播再到恢复的完整流程
场景描述与设计要点
在一个需要同时请求多个外部接口并处理结果的并发任务中，我们需要：捕获各任务的错误、统一传播给调用方、并在出现异常的情况下进行恢复处理，确保整个流程尽可能健壮。该场景的核心是使用 errgroup、context 与 recover 的组合。
下列示例整合了以上模式，演示一个简单的并发请求流程：
package mainimport ("context""fmt""net/http""io/ioutil""golang.org/x/sync/errgroup"
)func fetchURL(ctx context.Context, url string) (string, error) {// 使用 recover 将可能的 panic 转换为错误var body stringerr := func() (err error) {defer func() {if r := recover(); r != nil {err = fmt.Errorf("panic recovered for %s: %v", url, r)}}()req, _ := http.NewRequestWithContext(ctx, "GET", url, nil)resp, err := http.DefaultClient.Do(req)if err != nil {return err}defer resp.Body.Close()data, _ := ioutil.ReadAll(resp.Body)body = string(data)return nil}()if err != nil {return "", err}return body, nil
}func main() {urls := []string{"https://example.com/a","https://example.com/b","https://example.com/c",}g, ctx := errgroup.WithContext(context.Background())for _, u := range urls {u := ug.Go(func() error {data, err := fetchURL(ctx, u)if err != nil {return err}fmt.Printf("url: %s, len: %d\n", u, len(data))return nil})}if err := g.Wait(); err != nil {// 捕获并传播错误fmt.Println("operation failed:", err)return}fmt.Println("all requests succeeded")
}
