博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Golang控制goroutine的启动与关闭
阅读量:4343 次
发布时间:2019-06-07

本文共 1077 字,大约阅读时间需要 3 分钟。

  最近在用golang做项目的时候,使用到了goroutine。在golang中启动协程非常方便,只需要加一个go关键字:

   

 go myfunc(){      //do something }()

   但是对于一些长时间执行的任务,例如:

 go loopfunc(){          for{      //do something repeat           }  }()

在某些情况下,需要退出时候却有些不方便。举个例子,你启动了一个协程,长时间轮询处理一些任务。当某种情况下,需要外部通知,主动结束这个循环。发现,golang并没有像java那样中断或者关闭线程的interrupt,stop方法。于是就想到了channel,通过类似信号的方式来控制goroutine的关闭退出(实际上并不是真的直接关闭goroutine,只是把一些长时间循环的阻塞函数退出,然后让goroutine自己退出),具体思路就是就是对于每个启动的goroutine注册一个channel。为了方便后续使用,我封装了一个简单的库:

原理比较简单,这里不详细说了,直接看源码就可以了。具体使用示例:

 

package mainimport (        "fmt"        "github.com/scottkiss/grtm"        "time"       )func myfunc() {    fmt.Println("do something repeat by interval 4 seconds")    time.Sleep(time.Second * time.Duration(4))}func main() {        gm := grtm.NewGrManager()        gm.NewLoopGoroutine("myfunc", myfunc)        fmt.Println("main function")        time.Sleep(time.Second * time.Duration(40))        fmt.Println("stop myfunc goroutine")        gm.StopLoopGoroutine("myfunc")        time.Sleep(time.Second * time.Duration(80))}

  

 

转载于:https://www.cnblogs.com/vimsk/p/4866586.html

你可能感兴趣的文章
关于WordCount的作业
查看>>
UIView的layoutSubviews,initWithFrame,initWithCoder方法
查看>>
STM32+IAP方案 实现网络升级应用固件
查看>>
用74HC165读8个按键状态
查看>>
jpg转bmp(使用libjpeg)
查看>>
linear-gradient常用实现效果
查看>>
sql语言的一大类 DML 数据的操纵语言
查看>>
VMware黑屏解决方法
查看>>
JS中各种跳转解析
查看>>
JAVA 基础 / 第八课:面向对象 / JAVA类的方法与实例方法
查看>>
Ecust OJ
查看>>
P3384 【模板】树链剖分
查看>>
Thrift源码分析(二)-- 协议和编解码
查看>>
考勤系统之计算工作小时数
查看>>
4.1 分解条件式
查看>>
Equivalent Strings
查看>>
flume handler
查看>>
收藏其他博客园主写的代码,学习加自用。先表示感谢!!!
查看>>
H5 表单标签
查看>>
C语言编程-9_4 字符统计
查看>>