如何在Golang中使用WaitGroup等待任务完成
作者:RiverSoul
时间:2025-11-18
来源:互联网
浏览:0
WaitGroup用于等待多个goroutine完成,通过Add增加计数、Done减少计数、Wait阻塞直至计数为零,需确保Add与Done配对使用,避免并发错误。
WaitGroup用于等待多个goroutine完成,通过Add增加计数、Done减少计数、Wait阻塞直至计数为零,需确保Add与Done配对使用,避免并发错误。

在Go语言中,WaitGroup 是 sync 包提供的一个同步原语,用于等待一组并发的goroutine执行完成。它特别适用于主协程需要等待多个子任务结束后再继续的场景。
WaitGroup 基本用法
WaitGroup 有三个核心方法:
Add(delta int):增加计数器,通常传入要启动的goroutine数量。Done():在每个goroutine结束时调用,表示该任务已完成(相当于 Add(-1))。Wait():阻塞当前协程,直到计数器归零。
典型使用模式如下:
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
// 模拟任务执行
fmt.Printf("任务 %d 完成\n", id)
}(i)
}
wg.Wait() // 等待所有任务完成
fmt.Println("所有任务已结束")
避免常见错误
使用 WaitGroup 时有几个关键点需要注意:
- 确保每次
Add都有对应的Done,否则程序可能永久阻塞或 panic。 - 不要在 goroutine 外部调用
Done,应放在 goroutine 内部并配合defer使用。 Add调用可以在启动 goroutine 前完成,但不能晚于Wait。
例如,下面这种写法是安全的:
wg.Add(3) go task(&wg) go task(&wg) go task(&wg) wg.Wait()
实际应用场景
WaitGroup 常用于批量请求、数据抓取、并行处理等场景。比如同时发起多个HTTP请求:
var wg sync.WaitGroup
urls := []string{"http://example.com", "http://httpbin.org", "http://httpstat.us"}
for _, url := range urls {
wg.Add(1)
go func(u string) {
defer wg.Done()
resp, err := http.Get(u)
if err != nil {
fmt.Printf("请求失败 %s: %v\n", u, err)
return
}
defer resp.Body.Close()
fmt.Printf("成功获取 %s, 状态码: %s\n", u, resp.Status)
}(url)
}
wg.Wait()
fmt.Println("所有请求完成")
基本上就这些。只要记得配对使用 Add 和 Done,并在主线程调用 Wait,就能正确等待所有任务结束。不复杂但容易忽略细节。
作者最新文章
微软推出Project Zenith:面向Windows 11开发者的AI硬件加速方案
2026-09-08 18:15
打破流量垄断,让平台经济释放普惠红利
2026-09-08 18:07
Arm AGI CPU详解:136核Neoverse V3,3nm双芯粒架构与AI数据中心部署
2026-09-08 17:18
Windows安装Docker教程:启用WSL2并运行第一个容器验证
2026-09-04 09:26
PDF转Word操作指南:在线与本地转换方法及格式检查
2026-09-03 16:03
热门文章
更多
精品专题
更多
Mac软件
更多
WINDOWS
更多
Windows 10
Windows
Windows 10 是一款微软推出的经典操作系统,拥有硬件兼容性与多任务处理能力。它更偏向把系统状态查看和常用调节动作放在一起,适合需要持续观察和微调设备状态的场景。
极度公式
Windows/macOS/Linux
极度公式是一款跨平台专业LaTeX公式识别编辑软件,支持OCR公式识别和多平台编辑。和使用说明,避免使用,享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。
















