登录
首页 >  Golang >  Go教程

GolangWaitGroup使用技巧与实战分享

时间:2026-03-24 10:38:34 341浏览 收藏

本文深入剖析了 Go 语言中 sync.WaitGroup 的核心使用陷阱与最佳实践,强调 Add() 必须在 goroutine 启动前一次性调用、Done() 务必通过 defer 确保执行、WaitGroup 必须以指针形式传递避免值拷贝导致的同步失效,并明确指出 WaitGroup 仅用于等待完成,不替代 channel 进行结果传递——掌握这些关键细节,能帮你彻底避开死锁、panic 和竞态等常见并发雷区,写出更健壮、可维护的 Go 并发代码。

Golang Sync.WaitGroup正确使用姿势_等待多协程同步技巧

WaitGroup.Add() 必须在启动 goroutine 前调用

很多人把 Add() 放在 goroutine 里,结果 Wait() 立刻返回——因为主协程根本没等上,计数器还没来得及加。本质是竞态:Add 和 Done 的执行顺序不可控。

  • Add() 必须在 go func() {...}() 之前调用,哪怕只是加 1
  • 如果循环启多个 goroutine,Add(n) 要在循环外一次性加完,别在循环里边启边加(容易漏或重复)
  • 加负数会 panic:panic: sync: negative WaitGroup counter,别传 -1 或变量未初始化就减

错误示例:

for i := range tasks {
    go func() {
        wg.Add(1) // ❌ 在 goroutine 里 Add,大概率失效
        defer wg.Done()
        process(i)
    }()
}
wg.Wait() // 立刻返回

Done() 必须确保执行,且只能调用一次

Done() 是递减计数器,漏调、多调、或 panic 后没执行,都会让 Wait() 永远卡住,或触发 panic: sync: WaitGroup is reused before previous Wait has returned

  • 99% 的场景下,用 defer wg.Done() 最安全,哪怕函数中途 return 或 panic
  • 别手动写 wg.Done() 在多个 return 分支里——容易漏
  • 绝不能对同一个 WaitGroup 实例重复调用 Wait(),除非中间调过 Add() 重置(但不推荐,易错)

正确姿势:

for _, task := range tasks {
    wg.Add(1)
    go func(t Task) {
        defer wg.Done() // ✅ defer 保底
        if err := t.Run(); err != nil {
            log.Println(err)
            return
        }
    }(task)
}
wg.Wait()

WaitGroup 不能复制,必须传指针

Go 中结构体赋值是值拷贝。WaitGroup 内部含 mutex 和 int64 计数器,复制后两个实例完全独立——你在副本上调 Add(),原实例的 Wait() 根本感知不到。

  • 函数参数、字段、闭包捕获时,一律传 *sync.WaitGroup,不是 sync.WaitGroup
  • 常见翻车点:闭包里直接引用外部 wg 变量,但该变量本身是局部值拷贝(比如从另一个函数返回了 wg 值)
  • 编译器不会报错,但运行时行为诡异:有时等得到,有时死锁——取决于调度时机,极难复现

反例:

func startWorkers(wg sync.WaitGroup) { // ❌ 值传递
    for i := 0; i <h3>WaitGroup 不适合替代 channel 处理结果传递</h3><p><code>WaitGroup</code> 只解决“等结束”,不解决“拿结果”。强行用全局切片 + mutex 收集输出,代码臃肿且易出竞态;用 channel 才是 Go 的惯用法。</p>
  • 需要返回值、错误、或中间状态时,优先选 chan Result,而不是靠 WaitGroup + 全局变量
  • WaitGroup 配合 channel 是常见组合:用 wg 控制 goroutine 生命周期,用 channel 流式收数据
  • 别为了“统一用 wg”而放弃 channel —— 它们职责不同,混用反而增加心智负担

简洁做法:

results := make(chan Result, len(tasks))
for _, t := range tasks {
    wg.Add(1)
    go func(task Task) {
        defer wg.Done()
        results <p>真正容易被忽略的是:WaitGroup 的零值可用,但一旦开始用,它的生命周期必须由使用者严格管理——Add/Done/Wait 的调用顺序、是否可重用、是否跨 goroutine 共享,每个环节都藏着静默故障点。写完记得问自己一句:如果某个 goroutine panic 了,wg.Done() 还会被调到吗?</p><p>理论要掌握,实操不能落!以上关于《GolangWaitGroup使用技巧与实战分享》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注golang学习网公众号吧!</p>
资料下载
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>