Golang控制goroutine的启动与关闭
2015-10-10 13:11
519 查看
最近在用golang做项目的时候,使用到了goroutine。在golang中启动协程非常方便,只需要加一个go关键字:
但是对于一些长时间执行的任务,例如:
在某些情况下,需要退出时候却有些不方便。举个例子,你启动了一个协程,长时间轮询处理一些任务。当某种情况下,需要外部通知,主动结束这个循环。发现,golang并没有像java那样中断或者关闭线程的interrupt,stop方法。于是就想到了channel,通过类似信号的方式来控制goroutine的关闭退出(实际上并不是真的直接关闭goroutine,只是把一些长时间循环的阻塞函数退出,然后让goroutine自己退出),具体思路就是就是对于每个启动的goroutine注册一个channel。为了方便后续使用,我封装了一个简单的库:https://github.com/scottkiss/grtm
原理比较简单,这里不详细说了,直接看源码就可以了。具体使用示例:
go myfunc(){ //do something }()
但是对于一些长时间执行的任务,例如:
go loopfunc(){ for{ //do something repeat } }()
在某些情况下,需要退出时候却有些不方便。举个例子,你启动了一个协程,长时间轮询处理一些任务。当某种情况下,需要外部通知,主动结束这个循环。发现,golang并没有像java那样中断或者关闭线程的interrupt,stop方法。于是就想到了channel,通过类似信号的方式来控制goroutine的关闭退出(实际上并不是真的直接关闭goroutine,只是把一些长时间循环的阻塞函数退出,然后让goroutine自己退出),具体思路就是就是对于每个启动的goroutine注册一个channel。为了方便后续使用,我封装了一个简单的库:https://github.com/scottkiss/grtm
原理比较简单,这里不详细说了,直接看源码就可以了。具体使用示例:
package main import ( "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)) }
相关文章推荐
- LSGO软件技术团队2015~2016学年第五周(0928~1004)总结
- Go之简单并发
- 一、Go语言的变量和常量
- Algorithm 4th environment setup
- 全栈开发系列学习2——django项目搭建
- 安装django
- Golang vim开发环境设置
- 9月全球搜索引擎市场份额:7个版本Google上榜
- ubuntu下golang的安装、编译、运行
- Go之函数直接实现接口
- Go之类型判断
- Go之对象拷贝
- AMP:Google 的新开源项目能让网页秒开
- GoF 种设计模式
- HOTPOWER.【专注游戏界面外包】/接游戏界面外包/logo外包/icon
- [Django入门知识浅介]再写一个Django动态程序
- Code Forces 581 D. Three Logos(计算几何)
- LeetCode Majority Element II(Moore Voting Algorithm即Majority Voting Algorithm)
- [Django入门知识浅介]第一个Django程序:Hello World
- 解决chrome下用google搜索图片第二页以后不显示的问题(转)