golang协程如何关闭


本文摘自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

func run(done chan int) {

        for {

                select {

                case <-done:

                        fmt.Println("exiting...")

                        done <- 1

                        break

                default:

                }

  

                time.Sleep(time.Second * 1)

                fmt.Println("do something")

        }

}

  

func main() {

        c := make(chan int)

  

        go run(c)

  

        fmt.Println("wait")

        time.Sleep(time.Second * 5)

  

        c <- 1

        <-c

  

        fmt.Println("main exited")

}

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()之后它会返回。

示例:

阅读剩余部分

相关阅读 >>

golang能封装成dll吗

聊聊dapr的consistent hash

一篇文章带你入门go语言基础之并发

golang如何退出进程?

【发布了go-carbon1.1.1版本】完善对主流orm的支持,新增公共方法

go语言学习(五):通道的用法

golang如何判断字符串是否为空

golang判断错误类型的方法

精心整理!9个 python 实用案例分享

[系列] go - 结构(struct) 实现 接口(interface)

更多相关阅读请进入《golang》频道 >>




打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...

    正在狠努力加载,请稍候...