在go语言中优雅退出goroutines

htyu_0203_39 · · 3829 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

在go语言中优雅退出goroutines,通常需要做以下3点:

1. 向各个goroutines发通知,令其退出,如shutdown.

2. 等待各个goroutines都退出,如: sync.WaitGroup.

3. 在退出goroutine之前,确保数据不丢失(1.停止生产数据。2.关闭数据channel messages. 3. 消费者goroutine检查判断数据channel messages是否有效,若无效,则退出。)


package main


import (

       "fmt"
       "sync"
       "os"
       "os/signal"
       "syscall"
)

func consumer(messages <- chan int, shutdown <- chan int, wg *sync.WaitGroup) {

       defer wg.Done()
       for {

              select {

              case message, ok := <- messages:
              //do something.
              if ok {

                     fmt.Println(message)

              } else {

                     //no data , exit.
                     fmt.Println("no data, exit.")
                     return
              }

              case _ = <- shutdown:
              //we `re done!
              //shutdown now , messages buffered channel data may be lost.
                     fmt.Println("all done!")
                     return

              }
       }
}

func main() {

       //signals handle.
       shutdown := make(chan int)
       sigs := make(chan os.Signal, 1)
       signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
       go func() {

              sig := <- sigs
              fmt.Println(sig)
              //shutdown now , messages buffered channel data may be lost.
              //close(shutdown)
              /*or*/shutdown <- 0
       } ()
       messages := make(chan int, 16)

       wg := &sync.WaitGroup{}
       wg.Add(1)
       go consumer(messages, shutdown, wg)
       for i := 0; i < 10; i++ {

              messages <- i
       }
       close(messages) //flush messages channel , no data loss.
       fmt.Println("wait!")
       wg.Wait()


}

注意: 此文章只是我个人笔记, 如有错漏,请一定指正, 共同学习, 我的邮箱: htyu_0203_39@sina.com


有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:htyu_0203_39

查看原文:在go语言中优雅退出goroutines

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

3829 次点击  
加入收藏 微博
1 回复  |  直到 2000-01-01 00:00:00
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传