在 go 中，sync.waitgroup.wait() 是阻塞调用，不支持原生超时；可通过协程封装为通道操作，结合 select 与 time.after 实现优雅的超时等待机制。
在 go 中，sync.waitgroup.wait() 是阻塞调用，不支持原生超时；可通过协程封装为通道操作，结合 select 与 time.after 实现优雅的超时等待机制。
sync.WaitGroup 是 Go 中实现“屏障（barrier）”语义的核心工具，常用于等待一组 goroutine 并发任务全部完成。但其 Wait() 方法是同步阻塞的，无法直接设置超时——这在实际工程中尤为关键：网络请求、I/O 操作可能因异常延迟或失败而长期挂起，导致主流程无法及时响应。
幸运的是，Go 的并发模型天然支持将阻塞调用“通道化”。只需启动一个轻量 goroutine 执行 wg.Wait()，并在完成后关闭或发送信号到通道，即可将其无缝接入 select 语句，从而获得超时能力。
以下是一个完整、安全、可复用的示例：
package main
import (
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
done := make(chan struct{})
// 启动若干模拟异步任务（如 HTTP 请求）
for i := 0; i < 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
// 模拟可能耗时或失败的操作
delay := time.Duration(100+id*200) * time.Millisecond
time.Sleep(delay)
fmt.Printf("Task %d completed\n", id)
}(i)
}
// 将 Wait() 转为非阻塞通道操作
go func() {
wg.Wait()
close(done) // 通知所有任务已完成
}()
// 使用 select 实现带超时的等待
select {
case <-done:
fmt.Println("✅ All tasks finished successfully.")
case <-time.After(500 * time.Millisecond):
fmt.Println("⚠️ Timeout reached — some tasks may still be running.")
// 注意：此处 wg 未完成，但主逻辑可继续处理（如取消、日志、降级）
}
}? 关键注意事项：
- ✅ close(done) 是推荐做法（而非 done <- struct{}{}），因其零内存分配、语义清晰（表示“完成事件已发生”，且可被多次接收而不 panic）；
- ⚠️ 超时后 wg.Wait() 仍在后台执行，不会自动终止正在运行的 goroutine；若需真正取消，请配合 context.Context + 可取消的 I/O 操作（如 http.Client 设置 Timeout 或 context.WithTimeout）；
- ? 若需复用该模式，可封装为辅助函数：
func WaitWithTimeout(wg *sync.WaitGroup, timeout time.Duration) bool { done := make(chan struct{}) go func() { wg.Wait(); close(done) }() select { case <-done: return true case <-time.After(timeout): return false } }
综上，虽然 sync.WaitGroup 本身无超时接口，但借助 Go 的 goroutine 和 channel 组合能力，仅需几行代码即可构建出健壮、可读、符合 Go 并发哲学的超时等待逻辑——这正是 Go “用通信共享内存”理念的典型实践。
