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

如何在Golang中管理多个goroutine_Golang channel与WaitGroup协作技巧

夏敏大大_2525

夏敏大大_2525

发布时间:2026-01-22 11:53:08

|

393人浏览过

|

来源于php中文网

原创

goroutine泄漏典型表现为内存持续上涨、CPU不降及pprof显示大量goroutine阻塞在chan receive/select;定位需用runtime.NumGoroutine()打点日志并访问/debug/pprof/goroutine?debug=2查堆栈。

如何在golang中管理多个goroutine_golang channel与waitgroup协作技巧

goroutine 泄漏的典型表现和快速定位方法

启动大量 goroutine 后程序内存持续上涨、CPU 占用不降,或 pprof 显示大量 goroutine 处于 chan receive 或 select 等待状态,基本可以判定存在泄漏。根本原因常是 channel 未关闭 + 接收端未退出,或 WaitGroup 的 Add/Done 不配对。

  • 用 runtime.NumGoroutine() 在关键点打日志,观察数量是否回落
  • HTTP 服务下访问 /debug/pprof/goroutine?debug=2 查看完整堆栈
  • 所有带循环的 goroutine 必须有明确退出条件,避免无休止 for {}

channel 关闭时机必须由发送方决定

channel 是并发安全的,但关闭行为本身不是原子操作;多个 goroutine 同时 close(ch) 会 panic:panic: close of closed channel。因此,**只有唯一发送方(或经协调的发送方)才能调用 close()**,接收方只负责读取直到 ok == false。

  • 若使用 for range ch,channel 关闭后自动退出循环 —— 这是安全的惯用法
  • 若用 select 配合 case v, ok := ,需显式检查 <code>ok 并 break
  • 绝不要在多个 goroutine 中都写 if ch != nil { close(ch) }
go func() {
    defer wg.Done()
    for i := 0; i < 5; i++ {
        ch <- i
    }
    close(ch) // ✅ 唯一关闭点
}()

WaitGroup 与 channel 组合使用的正确模式

常见错误是把 wg.Add(1) 放在 goroutine 内部,导致主 goroutine 提前等待;或忘记 wg.Done(),造成死锁。标准协作结构是:启动前 Add,退出前 Done,channel 负责数据传递,WaitGroup 负责生命周期同步。

Golang Uber Dig
Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器,提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象,支持命名依赖等

下载
  • wg.Add(n) 必须在 goroutine 启动前执行,且不能被并发调用
  • 每个 goroutine 结束前必须调用 wg.Done(),推荐用 defer wg.Done()
  • 若 goroutine 可能因 channel 关闭提前退出,defer 仍能保证 Done 执行
ch := make(chan int, 3)
var wg sync.WaitGroup
<p>// 启动 3 个 worker
for i := 0; i < 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
for v := range ch {
fmt.Printf("worker %d got %d\n", id, v)
}
}(i)
}</p><p>// 发送数据
for i := 0; i < 5; i++ {
ch <- i
}
close(ch)</p><p>wg.Wait() // 等待所有 worker 退出

立即学习“go语言免费学习笔记(深入)”;

何时该用 channel,何时该用 WaitGroup

channel 不是万能同步原语。它适合传递数据、控制流(如退出信号)、或实现生产者-消费者模型;WaitGroup 只解决“等一组 goroutine 结束”这一个事。混用时容易过度设计 —— 比如仅为了等结束而创建无缓冲 channel 做通知,不如直接用 WaitGroup 简洁。

  • 需要传值、背压、或解耦生产/消费节奏 → 用 channel
  • 只关心“它们干完了没”,且无数据交互 → 用 WaitGroup
  • 既要等结束,又要收集返回结果 → channel 更自然(如 chan result)
  • 超时控制、取消传播 → 应优先考虑 context.Context,而非靠 channel + timer 拼接

真正难的不是语法,是判断哪个 goroutine 该关 channel、哪个该关自己、哪个该被 WaitGroup 等 —— 这取决于你定义的职责边界。一旦发送方结束,就该关 channel;一旦 worker 完成全部任务(包括处理完 channel 关闭),就该 Done;没有明确的“最后一个”概念,只有清晰的状态契约。

热门AI工具

更多
码上飞
码上飞 Hot

一款基于自然语言的AI应用开发平台,可根据用户描述自动生成应用程序,帮助个人和团队快速完成应用原型与开发。

豆包大模型

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

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

DeepSeek

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

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

WorkBuddy

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

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

Loomy
Loomy Hot

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

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

相关专题

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

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

539

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、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1236

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开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1826

2024.05.21

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

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

5194

2025.06.09

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

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

2414

2025.06.10

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

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

4266

2025.06.17

DBeaver怎么导入数据
DBeaver怎么导入数据

DBeaver数据导入专题,整理Excel、CSV、SQL、TXT等常见文件的数据导入方法,涵盖目标数据库选择、数据表创建、字段映射、数据类型设置及导入参数配置等操作,帮助用户将本地文件中的数据写入数据库,并了解批量导入、重复数据处理和导入失败等常见问题的解决方法。

0

2026.11.05

热门下载

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

精品课程

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

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