本文摘自php中文网,作者尚,侵删。
1、通过Channel传递退出信号
channel作为go的一种基本数据类型,它有3种基本状态:nil、open、closed。
通过Channel共享数据,而不是通过共享内存共享数据。主流程可以通过channel向任何goroutine发送停止信号,就像下面这样:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 |
|
2、使用waitgroup
通常情况下,我们像下面这样使用waitgroup:
1、创建一个Waitgroup的实例,假设此处我们叫它wg
2、在每个goroutine启动的时候,调用wg.Add(1),这个操作可以在goroutine启动之前调用,也可以在goroutine里面调用。当然,也可以在创建n个goroutine前调用wg.Add(n)
3、当每个goroutine完成任务后,调用wg.Done()
4、在等待所有goroutine的地方调用wg.Wait(),它在所有执行了wg.Add(1)的goroutine都调用完wg.Done()前阻塞,当所有goroutine都调用完wg.Done()之后它会返回。
示例:
相关阅读 >>
linux怎么安装golang和dep(附错两个误解决方法)
介绍基于go语言框架gin开发的mvc轮子框架:ginlaravel
在 docker 下 golang 的 gomaxprocs 初始化混乱问题
更多相关阅读请进入《golang》频道 >>
Go语言101
一个与时俱进的Go编程知识库。