如何在超时后中断errgroup.Wait的等待操作？

你的代码问题在于：errgroup.WithContext 只是把上下文传递给 goroutine，但你的 goroutine 并没有监听上下文的取消信号，同时 g.Wait() 本身不会因为上下文超时自动返回——它会一直等待所有 goroutine 执行完成，或者有 goroutine 返回错误。

问题拆解 #

1. 你用 context.WithTimeout 创建了超时上下文，但 goroutine 里只执行 time.Sleep(5*time.Second)，完全不理会 ctx 的状态，所以即使 ctx 超时，goroutine 仍会运行到结束。
2. g.Wait() 是阻塞调用，不能直接放到 select 的 case 里，因为 select 只支持 channel 操作。

正确实现方案 #

要实现超时中止等待，需要把 g.Wait() 放到 goroutine 中，通过 channel 传递结果，再用 select 同时监听超时信号和 Wait() 的结果。同时，必须让 goroutine 响应上下文的取消，避免超时后 goroutine 仍占用资源。

完整代码示例：

import (
    "context"
    "sync/errgroup"
    "time"
)

func myfunc(timeout time.Duration) error {
    ctx, cancelFunc := context.WithTimeout(context.Background(), timeout)
    defer cancelFunc() // 确保函数退出时清理上下文

    g, ctx := errgroup.WithContext(ctx)
    for i := 0; i < 10; i++ {
        g.Go(func() error {
            // 用select监听ctx取消信号和业务操作
            select {
            case <-ctx.Done():
                // 上下文取消时，立即返回错误
                return ctx.Err()
            case <-time.After(5 * time.Second):
                // 模拟实际业务逻辑
                return nil
            }
        })
    }

    // 启动goroutine执行Wait()，通过channel传递结果
    waitResult := make(chan error, 1)
    go func() {
        waitResult <- g.Wait()
    }()

    // select等待超时或Wait()完成
    select {
    case err := <-waitResult:
        return err
    case <-ctx.Done():
        // 超时触发，返回超时错误
        return ctx.Err()
    }
}

关键细节说明 #

• goroutine 响应取消：在每个 goroutine 里用 select 监听 ctx.Done()，这样上下文超时后，goroutine 会立刻停止执行，避免资源浪费。
• Wait() 异步化：把 g.Wait() 放到独立 goroutine 中，通过 channel 传递结果，才能放到 select 中与超时信号并行等待。
• 超时触发逻辑：select 会优先处理先发生的事件，当超时时间到，ctx.Done() 会被触发，函数直接返回 context.DeadlineExceeded，无需等待所有 goroutine 完成。

如果你的业务场景允许超时后 goroutine 继续执行（不推荐），可以去掉 goroutine 里的 select 监听，但这样超时后 g.Wait() 对应的 goroutine 仍会等待所有任务结束，只是主函数提前返回了。

内容的提问来源于stack exchange，提问作者IsaIkari