为 Go 语言中的 sync.WaitGroup 添加超时等待机制

go 标准库的 waitgroup.wait() 不支持原生超时，本文介绍一种简洁、安全、符合 go 惯用法的超时封装方案：通过 goroutine + channel + time.after 实现带超时的等待，并提供可复用的工具函数及关键注意事项。 go 标准库的 waitgroup.wait() 不支持原生超时，本文介绍一种简洁、安全、符合 go 惯用法的超时封装方案：通过 goroutine + channel + time.after 实现带超时的等待，并提供可复用的工具函数及关键注意事项。在构建高可靠性调度系统（如任务分发器、工作池或后台协程管理器）时，常需等待一组 goroutine 全部完成。sync.WaitGroup 是标准做法，但其 Wait() 方法是阻塞且无超时的——一旦某个 worker 协程因 panic、死锁或逻辑错误未调用 Done()，主流程将永久挂起，导致整个服务不可用。这与“故障隔离”和“优雅降级”的工程目标相悖。因此，为 WaitGroup.Wait() 增加可配置的超时机制，是生产环境中的刚需。最推荐的实现方式是非侵入式封装：不修改原有 WaitGroup 使用逻辑，而是通过 goroutine 将 wg.Wait() 异步化，并利用 channel 与 time.After() 配合 select 实现超时控制。以下是一个经过实战验证的工具函数：import ( "sync" "time")// waitTimeout 等待 WaitGroup 完成，最多等待指定超时时间。// 返回 true 表示超时（WaitGroup 未在时限内完成），false 表示正常完成。func waitTimeout(wg *sync.WaitGroup, timeout time.Duration) bool { done := make(chan struct{}) go func() { defer close(done) wg.Wait() }() select { case <-done: return false // 正常完成 case <-time.After(timeout): return true // 超时 }}? 使用示例： Tellers AI Tellers是一款自动视频编辑工具，可以将文本、文章或故事转换为视频。