登录
首页 >  Golang >  Go教程

Golang协程同步技巧:WaitGroup使用详解

时间:2026-01-12 15:09:30 278浏览 收藏

小伙伴们对Golang编程感兴趣吗?是否正在学习相关知识点?如果是,那么本文《Golang如何用WaitGroup同步协程执行》,就很适合你,本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点,希望对大家的知识积累有所帮助!

sync.WaitGroup是Go中用于等待goroutine完成的轻量同步机制,核心为计数器:启动前Add(1),结束时Done(),Wait()阻塞至归零;须遵守三规则:Add在goroutine外调用、Done与Add配对、仅传指针不可复制。

如何使用Golang实现WaitGroup等待协程完成_同步多任务执行

Go语言中,sync.WaitGroup 是最常用、最轻量的协程同步机制之一,用于等待一组 goroutine 全部执行完毕。它的核心是计数器:每启动一个 goroutine 就 Add(1),每个 goroutine 结束时调用 Done()(等价于 Add(-1)),主线程通过 Wait() 阻塞直到计数器归零。

WaitGroup 基本用法与关键规则

使用 WaitGroup 有三个必须遵守的要点:

  • 计数器必须在 goroutine 启动前设置好 —— wg.Add(n) 不能放在 goroutine 内部,否则可能漏加或竞态;
  • 每个 Done() 必须有对应 Add(1) —— 多调或少调都会导致死锁或提前返回;
  • WaitGroup 不能被复制 —— 只能传指针(&wg)给 goroutine,否则副本操作无效。

正确示例:并发请求并等待全部完成

以下是一个典型场景:发起 3 个 HTTP 请求,全部完成后统一处理结果:

(注意:省略错误处理以突出同步逻辑)

func main() {
    var wg sync.WaitGroup
    urls := []string{"https://httpbin.org/delay/1", "https://httpbin.org/delay/2", "https://httpbin.org/delay/1"}
<pre class="brush:php;toolbar:false"><code>results := make([]string, len(urls))
for i, url := range urls {
    wg.Add(1) // ✅ 在 goroutine 外提前加 1
    go func(idx int, u string) {
        defer wg.Done() // ✅ 确保无论是否出错都调用
        resp, _ := http.Get(u)
        defer resp.Body.Close()
        body, _ := io.ReadAll(resp.Body)
        results[idx] = string(body[:min(len(body), 50)])
    }(i, url)
}

wg.Wait() // ✅ 主线程阻塞等待全部完成
fmt.Println("All done:", len(results))</code>

}

常见陷阱与规避方式

这些错误极易引发死锁或 panic,需特别留意:

  • 在循环中直接传循环变量 —— 如 go func() { ... }(i) 写成 go func() { ... }(),会导致所有 goroutine 共享同一个 i 值;解决方法:显式传参(如上例)或用局部变量绑定;
  • 忘记调用 Done() 或 recover 后未调用 —— 推荐用 defer wg.Done(),确保退出路径全覆盖;
  • WaitGroup 被 move 或复制 —— 例如写成 go worker(wg, job)(值传递),应改为 go worker(&wg, job)
  • WaitGroup 复用前未重置 —— 若需多次使用,不能直接再调 Add(),而应新建或确保计数器已为 0(通常建议每次用新实例)。

进阶技巧:带超时的 WaitGroup 等待

有时不能无限等待,可用 select + time.After 实现超时控制:

done := make(chan struct{})
go func() {
    wg.Wait()
    close(done)
}()
<p>select {
case <-done:
fmt.Println("All goroutines finished")
case <-time.After(5 * time.Second):
fmt.Println("Timeout: some tasks still running")
}</p>

注意:超时不会终止正在运行的 goroutine,仅放弃等待 —— 若需取消任务,请配合 context.Context 使用。

到这里,我们也就讲完了《Golang协程同步技巧:WaitGroup使用详解》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于的知识点!

前往漫画官网入口并下载 ➜
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>