讲师中心 微信公众号
AI工具推荐 视频效率加速

如何等待多个goroutine完成_Go并发等待机制解析

小萱酱_8313

小萱酱_8313

发布时间:2026-02-03 11:48:51

|

1009人浏览过

|

来源于php中文网

原创

sync.WaitGroup 是等待多个 goroutine 完成的最常用且可靠方式,需在启动前调用 Add()、goroutine 内用 defer Done()、主协程调用 Wait() 阻塞等待。

如何等待多个goroutine完成_go并发等待机制解析

用 sync.WaitGroup 等待多个 goroutine 完成是最常用且可靠的方式

Go 没有内置的“等待所有 goroutine 结束”语法,sync.WaitGroup 是标准库提供的轻量级同步原语,专为这类场景设计。它通过计数器 + 阻塞等待实现协作式同步,不依赖 channel 或 sleep 轮询。

关键点在于:必须在启动 goroutine 之前调用 Add(),且每个 goroutine 内部必须调用 Done();Wait() 会阻塞直到计数归零。

  • Add(1) 必须在 goroutine 启动前调用,否则可能因竞态导致计数未生效
  • 不要在 goroutine 外部调用 Done(),也不要用 defer Done() 在非 goroutine 函数中——Done() 只应在对应 goroutine 内执行
  • 计数器不可为负,多次调用 Done() 会 panic,务必确保每个 Add() 都有且仅有一个匹配的 Done()
package main
<p>import (
"fmt"
"sync"
"time"
)</p><p>func main() {
var wg sync.WaitGroup
urls := []string{"<a href="https://www.php.cn/link/e75a2d435455f0626ccf0af67216e76f">https://www.php.cn/link/e75a2d435455f0626ccf0af67216e76f</a>", "<a href="https://www.php.cn/link/88b3febc5798a734026c82c1012408f5">https://www.php.cn/link/88b3febc5798a734026c82c1012408f5</a>", "<a href="https://www.php.cn/link/6fe0fa22eca4dea0f85b883b75c76a34">https://www.php.cn/link/6fe0fa22eca4dea0f85b883b75c76a34</a>"}</p><pre class='brush:php;toolbar:false;'>for _, url := range urls {
    wg.Add(1) // 注意:这里在 goroutine 外、启动前调用
    go func(u string) {
        defer wg.Done() // 在 goroutine 内调用
        fmt.Printf("Fetching %s...\n", u)
        time.Sleep(500 * time.Millisecond)
        fmt.Printf("Done: %s\n", u)
    }(url)
}

wg.Wait() // 主 goroutine 阻塞等待全部完成
fmt.Println("All done.")

}

为什么不用 channel 配合 for range 等待?

用 channel 收集完成信号(如 done := make(chan struct{}, N))也能工作,但属于“手动模拟 WaitGroup”,增加了复杂度和出错风险。

常见问题包括:

  • 缓冲区大小设错(比如 make(chan struct{}, 2) 却发 3 个信号 → 第三个写操作阻塞)
  • 忘记关闭 channel,导致 for range 永远不退出
  • goroutine panic 后未发送信号,主 goroutine 永久等待(WaitGroup 同样会卡住,但至少不会因 channel 操作 panic)
  • 无法复用:每次都要新建 channel 和循环逻辑,而 sync.WaitGroup 可重置(WaitGroup{} 重新赋值)或直接新建

除非你同时需要返回结果或错误(这时用带类型的 channel 更自然),否则纯等待完成,sync.WaitGroup 更简洁、安全、符合 Go 的惯用法。

AI舌诊面诊问诊医疗系统+诊疗商城系统源码
AI舌诊面诊问诊医疗系统+诊疗商城系统源码

AI 舌诊面诊问诊医疗系统 + 诊疗商城系统源码是一套结合 AI 辅助诊断与商品转化的健康类程序,基于浩创云、ThinkPHP(PHP)开发,支持微信服务号与 H5 端,适合做中医舌诊面诊问答、健康建议推送以及配套诊疗商品的运营。

下载

WaitGroup 的底层行为与注意事项

sync.WaitGroup 内部使用原子操作维护计数器,并在 Wait() 时进入休眠状态,由 runtime 唤醒。它不是基于 mutex 的忙等,性能开销极低。

  • 不能拷贝:WaitGroup 包含互斥锁字段,复制会导致 panic —— 总是传指针或作为包级/局部变量直接使用
  • 不能重用后未重置:如果重复使用同一变量,需确保上次 Wait() 已返回,且不再有 goroutine 调用 Done();否则可能读到旧计数或引发 panic
  • 没有超时机制:Wait() 会一直等,生产代码中建议结合 context.WithTimeout 控制整体等待时限(例如启动 goroutine 时传入 context)

若需超时等待,典型做法是启动一个 timer goroutine 或用 select + time.After:

done := make(chan struct{})
go func() {
    wg.Wait()
    close(done)
}()
<p>select {
case <-done:
fmt.Println("All finished")
case <-time.After(3 * time.Second):
fmt.Println("Timeout!")
}

当 goroutine 可能 panic 时,如何避免 WaitGroup 卡死?

WaitGroup 本身不处理 panic,如果某个 goroutine panic 且没调用 Done(),Wait() 就永远阻塞。这不是 bug,而是设计使然:它假设你控制着 goroutine 的生命周期。

真正可靠的解法是保证 Done() 总被执行:

  • 用 defer wg.Done() —— 这是最简单有效的方案,defer 在 panic 后仍会执行
  • 避免在 defer 前做可能 panic 的操作(比如 defer 前解引用 nil 指针)
  • 若逻辑复杂,可包裹 recover:
go func() {
    defer wg.Done()
    defer func() {
        if r := recover(); r != nil {
            fmt.Printf("Recovered in goroutine: %v\n", r)
        }
    }()
    // 可能 panic 的代码
}()

注意:recover 只对当前 goroutine 有效,不影响其他 goroutine,也不会让主流程继续执行失败逻辑 —— 它只是防止 Done() 被跳过。

最常被忽略的一点:很多人把 wg.Add() 放在 goroutine 内部,以为“自己加自己减”,结果因调度延迟导致 Wait() 先执行、计数为 0 直接返回,后续 goroutine 还没开始就结束了。务必记住——Add() 是“预告”,必须提前告知要等几个任务。

热门AI工具

更多
Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

519

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

616

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1196

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

791

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1746

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

4954

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

2294

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

4166

2025.06.17

Vite 项目如何打包和部署
Vite 项目如何打包和部署

Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章,帮助读者完成上线流程。

20

2026.10.28

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn