博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
go的简单并发之goroutine与WaitGroup
阅读量:4101 次
发布时间:2019-05-25

本文共 825 字,大约阅读时间需要 2 分钟。

 WaitGroup跟java的CountdownLatch以及python里的join方法差不多,也是阻塞等待所有任务完成之后再继续执行。

WaitGroup的用途:它能够一直等到所有的goroutine执行完成,并且阻塞主线程的执行,直到所有的goroutine执行完成。

WaitGroup总共有三个方法:Add(delta int),Done(),Wait()。简单的说一下这三个方法的作用。

Add:添加或者减少等待goroutine的数量

Done:相当于Add(-1)   //wg.Done()最好用defer注册一下,避免函数内部出错执行不到

Wait:执行阻塞,直到所有的WaitGroup数量变成0

package mainimport (	"fmt"	"sync")/*WaitGroup的用途:它能够一直等到所有的goroutine执行完成,并且阻塞主线程的执行,直到所有的goroutine执行完成。*/var wg sync.WaitGroup//用于并发的目的函数func say(v int) {	fmt.Println("talk to me...", v)	wg.Done() //并发的一个任务完成,计数器减一,相当于Add(-1)              //wg.Done()最好用defer注册一下,避免函数内部出错执行不到}func main() {	wg.Add(10) //说明要开10个并发,内部计数器,	//也可以再循环内部,每次Add(1)	for i := 0; i < 10; i++ {		go say(i)	}	fmt.Println("I'm main func...")	wg.Wait() //执行阻塞,直到所有的WaitGroup数量变成0	fmt.Println("All concurrent applications are completed...")}

输出结果与分析:

 

转载地址:http://izwsi.baihongyu.com/

你可能感兴趣的文章
用idea创建一个maven web项目
查看>>
Kafka
查看>>
9.1 为我们的角色划分权限
查看>>
维吉尼亚之加解密及破解
查看>>
DES加解密
查看>>
TCP/IP协议三次握手与四次握手流程解析
查看>>
PHP 扩展开发 : 编写一个hello world !
查看>>
inet_ntoa、 inet_aton、inet_addr
查看>>
用模板写单链表
查看>>
用模板写单链表
查看>>
链表各类操作详解
查看>>
C++实现 简单 单链表
查看>>
数据结构之单链表——C++模板类实现
查看>>
Linux的SOCKET编程 简单演示
查看>>
正则匹配函数
查看>>
Linux并发服务器编程之多线程并发服务器
查看>>
聊聊gcc参数中的-I, -L和-l
查看>>
[C++基础]034_C++模板编程里的主版本模板类、全特化、偏特化(C++ Type Traits)
查看>>
C语言内存检测
查看>>
Linux epoll模型
查看>>