hi,你好!欢迎访问本站!登录
本站由简数采集腾讯云宝塔系统阿里云强势驱动
当前位置:首页 - 文章 - 后端开发 - 正文 看Cosplay古风插画小姐姐,合集图集打包下载:炫龙网 · 炫龙图库

golang协程怎样封闭_后端开发

2019-12-29后端开发ki4网21°c
A+ A-

1、经由过程Channel通报退出信号

channel作为go的一种基础数据类型,它有3种基础状况:nil、open、closed。

经由过程Channel同享数据,而不是经由过程同享内存同享数据。主流程能够经由过程channel向任何goroutine发送住手信号,就像下面如许:

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

示例:

type Service struct {
        // Other things
 
        ch        chan bool
        waitGroup *sync.WaitGroup
}
 
func NewService() *Service {
	s := &Service{
                // Init Other things
                ch:        make(chan bool),
                waitGroup: &sync.WaitGroup{},
	}
 
	return s
}
 
func (s *Service) Stop() {
        close(s.ch)
        s.waitGroup.Wait()
}
 
func (s *Service) Serve() {
        s.waitGroup.Add(1)
        defer s.waitGroup.Done()
 
        for {
                select {
                case <-s.ch:
                        fmt.Println("stopping...")
                        return
                default:
                }
                s.waitGroup.Add(1)
                go s.anotherServer()
	}
}
func (s *Service) anotherServer() {
        defer s.waitGroup.Done()
        for {
                select {
                case <-s.ch:
                        fmt.Println("stopping...")
                        return
                default:
                }
 
                // Do something
        }
}
 
func main() {
 
        service := NewService()
        go service.Serve()
 
        // Handle SIGINT and SIGTERM.
        ch := make(chan os.Signal)
        signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
        fmt.Println(<-ch)
 
        // Stop the service gracefully.
        service.Stop()
}

更多golang学问请关注golang教程栏目。

以上就是golang协程怎样封闭的细致内容,更多请关注ki4网别的相干文章!

  选择打赏方式
微信赞助

打赏

QQ钱包

打赏

支付宝赞助

打赏

  选择分享方式
  移步手机端
golang协程怎样封闭_后端开发

1、打开你手机的二维码扫描APP
2、扫描左则的二维码
3、点击扫描获得的网址
4、可以在手机端阅读此文章
标签:

发表评论

选填

必填

必填

选填

请拖动滑块解锁
>>