当前位置：首页 > 文章列表 > Golang > Go教程 > Golang并发重试与错误处理技巧

Golang并发重试与错误处理技巧

2026-01-10 14:41:38 0浏览收藏

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《Golang并发重试技巧与错误处理实践》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

不会，未被recover捕获的panic仅终止当前goroutine；须在每个goroutine入口用defer+recover兜底，不可跨goroutine捕获；重试应结合context与select避免泄漏和卡死。

如何使用Golang实现并发任务重试_Golang goroutine错误处理与重试实践

goroutine 中 panic 会导致整个程序崩溃吗

不会，但默认不捕获就会向上抛出到 goroutine 起始函数，最终被 runtime.Goexit 终止该 goroutine，不波及主线程或其他 goroutine。关键点在于：未被 recover 捕获的 panic 仅杀死当前 goroutine。

常见错误是以为启动了 goroutine 就“自动兜底”，结果 HTTP handler 或定时任务里 panic 后任务静默消失，日志里只有一行 panic: xxx 而无堆栈——因为没在 goroutine 内部做 defer + recover。

必须在每个独立 goroutine 的入口函数最外层加 defer func() { if r := recover(); r != nil { log.Printf("goroutine panic: %v", r) } }()
不要在外部统一 recover：goroutine 是并发执行单元，无法跨 goroutine 捕获 panic
recover 只在 defer 函数中有效，且仅对同 goroutine 的 panic 生效

用 channel 控制重试次数和超时的典型结构

直接用 for + time.After 做重试容易失控：比如每次重试都新建 timer，旧 timer 不 stop 会泄漏；或没考虑上下文取消，导致 goroutine 卡死。

推荐用 context.Context 配合 time.AfterFunc 或 select 多路复用，把重试逻辑封装成可取消、可超时的循环。

func doWithRetry(ctx context.Context, fn func() error, maxRetries int, baseDelay time.Duration) error {
    var err error
    for i := 0; i     err = fn()
    if err == nil {
        return nil
    }

    if i == maxRetries {
        break
    }

    delay := time.Duration(float64(baseDelay) * math.Pow(2, float64(i)))
    select {
    case <-time.After(delay):
    case <-ctx.Done():
        return ctx.Err()
    }
}
return err

}

每次重试前检查 ctx.Done()，避免无效执行
指数退避用 math.Pow 计算，注意 float64 转 time.Duration 时截断风险（建议加 time.Microsecond 级别最小值保护）
不用 timer.Reset：goroutine 场景下每次重试都是新延迟，直接 time.After 更清晰安全

并发任务失败后如何统一收集错误而不阻塞

多个 goroutine 并发执行任务，部分失败时，如果用 sync.WaitGroup + 全局 error 变量，会面临竞态；若用 errgroup.Group，默认是“任一失败即返回”，不满足“全部执行完再汇总”的需求。

正确做法是让每个 goroutine 把结果（成功/失败+error）发到同一个 chan error，主 goroutine 收集并判断阈值。

results := make(chan error, numTasks)
for i := 0; i var failedCount int
for i := 0; i < numTasks; i++ {
if err := <-results; err != nil {
log.Printf("task failed: %v", err)
failedCount++
}
}
if failedCount > 0 {
return fmt.Errorf("failed %d of %d tasks", failedCount, numTasks)
}