WaitGroupGo中如何处理任务错误

用 sync.WaitGroup.Go 启动任务后，错误不会自动回到调用方：Go 接收的是 func()，没有 error 返回值，而且回调函数不能 panic。实用做法是把错误显式写入一个带缓冲的 channel，用 sync.Once 只保留首个错误，再用 context.CancelFunc 通知其他任务尽快收尾；主 goroutine 最后调用 Wait，关闭错误通道并返回结果。

WaitGroup.Go 只解决“所有任务何时结束”，不解决“哪个任务失败、失败后是否取消”。错误收集和取消策略必须由业务代码单独设计。

WaitGroup.Go 为什么不能直接处理 error

WaitGroup.Go 的签名是 func (wg *WaitGroup) Go(f func())。它会增加任务计数，回调返回后自动减少计数；Wait 只等待计数归零。把下面这种写法当成错误处理是不成立的：

// Go 回调没有返回值，err 不会传回外层函数
wg.Go(func() {
    err := loadConfig()
    _ = err // 这里只是丢掉错误，不是处理错误
})

不要在回调里直接 panic，也不要让多个 goroutine 无保护地写同一个外层 err。前者违反 API 约定，后者会产生数据竞争。错误应通过并发安全的通信路径汇总。

用错误通道保留首个失败原因

错误通道容量至少为 1，这样第一个失败任务可以在没有接收者时把错误交给主流程；sync.Once 则保证取消函数和错误写入只执行一次。下面的函数展示了完整骨架：

package main

import (
    "context"
    "fmt"
    "sync"
)

func runTasks(parent context.Context, jobs []func(context.Context) error) error {
    ctx, cancel := context.WithCancel(parent)
    defer cancel() // 无论成功或失败，都释放派生 context

    errs := make(chan error, 1) // 只保存首个错误，避免发送方阻塞
    var once sync.Once
    var wg sync.WaitGroup

    for _, job := range jobs {
        job := job // 为每个闭包固定当前函数值
        wg.Go(func() {
            if err := job(ctx); err != nil {
                once.Do(func() {
                    errs 

这个实现有两个关键点：每个任务都必须检查 ctx.Done() 或把 ctx 传给下游调用，取消才有意义；close(errs) 必须发生在 wg.Wait() 返回之后，否则仍在执行的回调可能向已关闭的 channel 写入。

任务内部怎样响应取消

取消只是一条通知，不会强行终止 goroutine。可取消的任务要在循环、网络请求或批量处理的边界主动检查：

func importOne(ctx context.Context, rows []string) error {
    for _, row := range rows {
        select {
        case 

若下游函数支持 context，优先直接传入；若只是 CPU 循环，则在合理的批次边界检查一次。已经完成的任务不需要回滚，回滚、重试和部分成功结果应由业务层另行定义。

几个容易误用的边界

• 需要全部错误时：不要用首错通道覆盖信息，可让每个任务发送结构体，再在 Wait 后统一读取并排序。
• 需要限制并发数时：WaitGroup.Go 不提供并发上限，另加 semaphore channel 或使用任务池。
• 需要 panic 恢复时：先在任务函数内部明确 recover 与错误转换策略，但不要把 panic 当成 WaitGroup.Go 的正常返回值。
• 兼容旧 Go 版本时：改用 Add(1)、defer Done() 的传统写法，不能假设旧工具链存在 WaitGroup.Go。

判断方案是否完整，可以只问三件事：错误是否有明确出口，首错后其他任务是否能停止，所有 goroutine 是否一定在返回前结束。三项都满足时，WaitGroup.Go 才真正适合承载这组并发任务。

相关问题

WaitGroup.Go 能返回 error 吗？不能。它的回调类型是 func()，需要自行通过 channel、结果结构或其他并发安全方式传递错误。

首个错误出现后可以马上返回吗？只有在任务生命周期由其他机制托管时才可以。普通函数应先取消 context，再等待已启动的任务退出，避免 goroutine 泄漏。