Hi,你们好,我是明哥。git
在本身学习 Golang 的这段时间里,我写了详细的学习笔记放在个人我的微信公众号 《Go编程时光》,对于 Go 语言,我也算是个初学者,所以写的东西应该会比较适合刚接触的同窗,若是你也是刚学习 Go 语言,不防关注一下,一块儿学习,一块儿成长。github
个人在线博客:http://golang.iswbm.com
个人 Github:github.com/iswbm/GolangCodingTimegolang
在前两篇文章里,咱们学习了 协程
和 信道
的内容,里面有不少例子,当时为了保证 main goroutine 在全部的 goroutine 都执行完毕后再退出,我使用了 time.Sleep 这种简单的方式。编程
因为写的 demo 都是比较简单的, sleep 个 1 秒,咱们主观上认为是够用的。数组
但在实际开发中,开发人员是没法预知,全部的 goroutine 须要多长的时间才能执行完毕,sleep 多了吧主程序就阻塞了, sleep 少了吧有的子协程的任务就无法完成。微信
所以,使用time.Sleep 是一种极不推荐的方式,今天主要就要来介绍 一下如何优雅的处理这种状况。函数
“不要经过共享内存来通讯,要经过通讯来共享内存”学习
学习了信道后,咱们知道,信道能够实现多个协程间的通讯,那么咱们只要定义一个信道,在任务完成后,往信道中写入true,而后在主协程中获取到true,就认为子协程已经执行完毕。3d
import "fmt" func main() { done := make(chan bool) go func() { for i := 0; i < 5; i++ { fmt.Println(i) } done <- true }() <-done }
输出以下指针
0 1 2 3 4
上面使用信道的方法,在单个协程或者协程数少的时候,并不会有什么问题,但在协程数多的时候,代码就会显得很是复杂,有兴趣能够本身尝试一下。
那么有没有一种更加优雅的方式呢?
有,这就要说到 sync包 提供的 WaitGroup 类型。
WaitGroup 你只要实例化了就能使用
var 实例名 sync.WaitGroup
实例化完成后,就可使用它的几个方法:
举一个例子:
import ( "fmt" "sync" ) func worker(x int, wg *sync.WaitGroup) { defer wg.Done() for i := 0; i < 5; i++ { fmt.Printf("worker %d: %d\n", x, i) } } func main() { var wg sync.WaitGroup wg.Add(2) go worker(1, &wg) go worker(2, &wg) wg.Wait() }
输出以下
worker 2: 0 worker 2: 1 worker 2: 2 worker 2: 3 worker 2: 4 worker 1: 0 worker 1: 1 worker 1: 2 worker 1: 3 worker 1: 4
以上就是咱们在 Go 语言中实现一主多子的协程协做方式,推荐使用 sync.WaitGroup。。
系列导读
24. 超详细解读 Go Modules 前世此生及入门使用