Golang中的sync包的WaitGroup操作
知识点掌握了,还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战,手把手教大家学习《Golang中的sync包的WaitGroup操作》,在实现功能的过程中也带大家重新温习相关知识点,温故而知新,回头看看说不定又有不一样的感悟!
sync的waitgroup功能
WaitGroup
使用多线程时,进行等待多线程执行完毕后,才可以结束函数,有两个选择
channel
waitgroup
首先使用channel
func add (n *int , isok chan bool){
for i :=0 ;i
但是,如果线程一旦增多,就会导致代码冗余,增加负担,可以使用sync.WaitGroup包
func add (n *int , wait *sync.WaitGroup) {
for i := 0 ; i
仿sync.WaitGroup功能
type Wait struct {//创建一个结构体
Num int//线程的个数
ok chan bool//线程与函数通信的管道
}
func (t *Wait) Add (n int){//初始化线程个数
t.Num = n
t.ok = make(chan bool , n)
}
func (t *Wait) Done (){//执行完一个线程之后,执行的函数,每执行完一个线程,调用函数,使用通信管道进行传输一个true
t.ok
补充:Golang的WaitGroup陷阱
sync.WaitGroup是并发环境中,一个相当常用的数据结构,用来等待所有协程的结束,在写代码的时候都是按着例子的样子写的,也没用深究过它的使用。前几日想着能不能在协程中执行Add()函数,答案是不能,这里介绍下。
陷阱在WaitGroup的3个函数的调用顺序上。先回顾下3个函数的功能:
Add(delta int):给计数器增加delta,比如启动1个协程就增加1。
Done():协程退出前执行,把计数器减1。
Wait():阻塞等待计数器为0。
考一考
下面的程序是创建了协程father,然后father协程创建了10个子协程,main函数等待所有协程结束后退出,看看下面代码有没有什么问题?
package main
import (
"fmt"
"sync"
)
func father(wg *sync.WaitGroup) {
wg.Add(1)
defer wg.Done()
fmt.Printf("father\n")
for i := 0; i
发现问题了吗?如果没有看下面的运行结果:main函数在子协程结束前就开始结束了。
father
main: father and all chindren exit
child [9]
child [0]
child [4]
child [7]
child [8]
陷阱分析
产生以上问题的原因在于,创建协程后在协程内才执行Add()函数,而此时Wait()函数可能已经在执行,甚至Wait()函数在所有Add()执行前就执行了,Wait()执行时立马就满足了WaitGroup的计数器为0,Wait结束,主程序退出,导致所有子协程还没完全退出,main函数就结束了。
正确的做法
Add函数一定要在Wait函数执行前执行,这在Add函数的文档中就提示了: Note that calls with a positive delta that occur when the counter is zero must happen before a Wait.。
如何确保Add函数一定在Wait函数前执行呢?在协程情况下,我们不能预知协程中代码执行的时间是否早于Wait函数的执行时间,但是,我们可以在分配协程前就执行Add函数,然后再执行Wait函数,以此确保。
下面是修改后的程序,以及输出结果。
package main
import (
"fmt"
"sync"
)
func father(wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("father\n")
for i := 0; i
father
child [9]
child [7]
child [8]
child [1]
child [4]
child [5]
child [2]
child [6]
child [0]
child [3]
main: father and all chindren exit
以上为个人经验,希望能给大家一个参考,也希望大家多多支持golang学习网。如有错误或未考虑完全的地方,望不吝赐教。
好了,本文到此结束,带大家了解了《Golang中的sync包的WaitGroup操作》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!
Golang模拟令牌桶进行对访问的限流方式
- 上一篇
- Golang模拟令牌桶进行对访问的限流方式
- 下一篇
- go-kit组件使用hystrix中间件的操作
-
- 温暖的小蝴蝶
- 这篇文章内容真是及时雨啊,好细啊,真优秀,mark,关注up主了!希望up主能多写Golang相关的文章。
- 2023-01-14 23:44:18
-
- 活力的小懒猪
- 这篇技术文章真是及时雨啊,up主加油!
- 2023-01-11 19:23:22
-
- 端庄的大树
- 很详细,已加入收藏夹了,感谢up主的这篇文章内容,我会继续支持!
- 2023-01-09 18:11:04
-
- 激动的硬币
- 这篇文章内容出现的刚刚好,太详细了,真优秀,码住,关注老哥了!希望老哥能多写Golang相关的文章。
- 2023-01-09 03:18:25
-
- 时尚的仙人掌
- 很有用,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,帮助很大,总算是懂了,感谢老哥分享文章内容!
- 2023-01-08 23:41:16
-
- 专注的菠萝
- 赞 ??,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,看完之后很有帮助,总算是懂了,感谢作者大大分享技术贴!
- 2023-01-08 02:39:37
-
- Golang · Go教程 | 2小时前 | go并发 · pprof · 故障排查 · Go教程 · 版本升级 · GODEBUG runtime/pprof Go 1.27 goroutine 标签 tracebacklabels
- Go 1.27 崩溃堆栈为什么多了 goroutine 标签:tracebacklabels 的取舍
- 174浏览 收藏
-
- Golang · Go教程 | 3小时前 | 网络编程 · HTTP · go · 性能 · 连接复用 Go 1.27 http.Response.Body Response.Body.Close
- Go 1.27 http.Response.Body 关闭会自动排空什么:连接复用与异常边界
- 311浏览 收藏
-
- Golang · Go教程 | 4小时前 | 标准库 · go · Go 1.27 · 并发测试 · HTTP 测试 · testing/synctest Go 1.27 httptest.NewTestServer Go 并发测试 内存网络
- Go 1.27 httptest.NewTestServer 怎么接 synctest:内存测试网络的适用范围
- 184浏览 收藏
-
- Golang · Go教程 | 6小时前 | go · TLS · Go 1.27 · QUIC · crypto/tls Go 1.27 QUICConfig ClientHelloInfoConn QUIC握手
- Go 1.27 QUIC 握手如何传入连接信息:ClientHelloInfoConn 解决什么问题
- 320浏览 收藏
-
- Golang · Go教程 | 7小时前 | 性能优化 · Go教程 · 数据库驱动 · Go1.27 · 数据库驱动 database/sql Go 1.27 Rows.Scan RowsColumnScanner
- Go 1.27 数据库驱动如何少做一次中转:RowsColumnScanner 直接写入目标值
- 187浏览 收藏
-
- Golang · Go教程 | 9小时前 | Go教程 · Go工具链 · Go测试 · JSON解析 · 测试报告 Go 1.27 go test -json OutputType test2json
- Go 1.27 go test -json OutputType 怎么解析:区分错误、续行与帧
- 266浏览 收藏
-
- Golang · Go教程 | 10小时前 | 标准库 · JSON · Go教程 · Go 1.27 encoding/json/v2 JSON迁移 DefaultOptionsV1
- Go 1.27 JSON v1 与 v2 渐进切换:Options 如何控制兼容语义
- 172浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- SuperCLUE
- SuperCLUE是权威的中文大语言模型综合评测基准,涵盖语言理解、知识应用、AI Agent智能体及安全性等12项核心能力。通过多轮对话与客观测试,定期发布榜单与技术报告,为模型研发、优化及行业选型提供科学依据。
- 17次使用
-
- 腾讯扣叮
- 腾讯扣叮是腾讯推出的6-18岁青少年编程学习平台,依托游戏与AI技术,提供图形化编程、3D创作、虚拟实验室及丰富赛事课程,助力培养计算思维与创新能力。
- 16次使用
-
- 堆友AI学习
- 堆友AI学习是堆友推出的专业AI设计教育平台,提供从基础到进阶的线上课程及线下实训营。结合阿里国际AITIC认证,通过视频教程、笔记分享和实战案例,帮助设计师掌握AIGC技能,提升职业竞争力。
- 9次使用
-
- WellSaid
- WellSaid是一款基于AI的高质量语音生成平台,提供120+种自然逼真的配音声音。支持团队协作、API集成及SOC2/GDPR合规,适用于企业培训、营销视频及多语言内容创作,助力高效工作流程。
- 8次使用
-
- Framer AI
- Framer AI是一款强大的无代码建站工具,支持通过中文文本描述自动生成、排版并发布响应式网站。目前提供免费无限次生成服务,被评测为效果最佳的AI网站生成器之一,具备智能文案优化及自定义主题功能。
- 12次使用
-
- GosyncWaitGroup使用深入理解
- 2022-12-22 122浏览
-
- Go语言同步等待组sync.WaitGroup结构体对象方法详解
- 2022-12-30 201浏览
-
- Go WaitGroup及Cond底层实现原理
- 2022-12-29 241浏览
-
- Go基础教程系列之WaitGroup用法实例详解
- 2023-01-07 452浏览
-
- Go并发编程中sync/errGroup的使用
- 2023-02-24 158浏览

