栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Go语言

第007节:sync包——WaitGroup

Go语言 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

官网文档对sync包的介绍:

Package sync provides basic synchronization primitives such as mutual exclusion locks. Other than the once and WaitGroup types, most are intended for use by low-level library routines. Higher-level synchronization is better done via channels and communication.

第007节:sync包——WaitGroup

sync是synchronization同步这个词的缩写,所以也会叫做同步包。这里提供了基本同步的操作,比如互斥锁等等。这里除了Once和WaitGroup类型之外,大多数类型都是供低级库例程使用的。更高级别的同步最好通过channel通道和communication通信来完成

一、WaitGroup

WaitGroup,同步等待组。

在类型上,它是一个结构体。一个WaitGroup的用途是等待一个goroutine的集合执行完成。主goroutine调用了Add()方法来设置要等待的goroutine的数量。然后,每个goroutine都会执行并且执行完成后调用Done()这个方法。与此同时,可以使用Wait()方法来阻塞,直到所有的goroutine都执行完成。


第007节:sync包——WaitGroup

二、Add()方法:

Add这个方法,用来设置到WaitGroup的计数器的值。我们可以理解为每个waitgroup中都有一个计数器
用来表示这个同步等待组中要执行的goroutin的数量。

如果计数器的数值变为0,那么就表示等待时被阻塞的goroutine都被释放,如果计数器的数值为负数,那么就会引发恐慌,程序就报错了。


第007节:sync包——WaitGroup

三、Done()方法

Done()方法,就是当WaitGroup同步等待组中的某个goroutine执行完毕后,设置这个WaitGroup的counter数值减1。


第007节:sync包——WaitGroup

其实Done()的底层代码就是调用了Add()方法:

// Done decrements the WaitGroup counter by one.func (wg *WaitGroup) Done() {    wg.Add(-1)}

四、Wait()方法

Wait()方法,表示让当前的goroutine等待,进入阻塞状态。一直到WaitGroup的计数器为零。才能解除阻塞,
这个goroutine才能继续执行。


第007节:sync包——WaitGroup

五、示例代码:

我们创建并启动两个goroutine,来打印数字和字母,并在main goroutine中,将这两个子goroutine加入到一个WaitGroup中,同时让main goroutine进入Wait(),让两个子goroutine先执行。当每个子goroutine执行完毕后,调用Done()方法,设置WaitGroup的counter减1。当两条子goroutine都执行完毕后,WaitGroup中的counter的数值为零,解除main goroutine的阻塞。

示例代码:

package mainimport (    "fmt"    "sync")var wg sync.WaitGroup // 创建同步等待组对象func main()  {        //设置等待组中,要执行的goroutine的数量    wg.Add(2)    go fun1()    go fun2()    fmt.Println("main进入阻塞状态。。。等待wg中的子goroutine结束。。")    wg.Wait() //表示main goroutine进入等待,意味着阻塞    fmt.Println("main,解除阻塞。。")}func fun1()  {    for i:=1;i<=10;i++{        fmt.Println("fun1.。。i:",i)    }    wg.Done() //给wg等待中的执行的goroutine数量减1.同Add(-1)}func fun2()  {    defer wg.Done()    for j:=1;j<=10;j++{        fmt.Println("tfun2..j,",j)    }}

运行结果:


第007节:sync包——WaitGroup
GOROOT=/usr/local/go #gosetupGOPATH=/Users/ruby/go #gosetup/usr/local/go/bin/go build -i -o /private/var/folders/kt/nlhsnpgn6lgd_q16f8j83sbh0000gn/T/___go_build_demo05_waitgroup_go /Users/ruby/go/src/l_goroutine/demo05_waitgroup.go #gosetup/private/var/folders/kt/nlhsnpgn6lgd_q16f8j83sbh0000gn/T/___go_build_demo05_waitgroup_go #gosetupfun1.。。i: 1fun1.。。i: 2fun1.。。i: 3fun1.。。i: 4fun1.。。i: 5fun1.。。i: 6fun1.。。i: 7fun1.。。i: 8fun1.。。i: 9fun1.。。i: 10main进入阻塞状态。。。等待wg中的子goroutine结束。。    fun2..j, 1    fun2..j, 2    fun2..j, 3    fun2..j, 4    fun2..j, 5    fun2..j, 6    fun2..j, 7    fun2..j, 8    fun2..j, 9    fun2..j, 10main,解除阻塞。。Process finished with exit code 0
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/793659.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号