最近在用golang做项目的时候,使用到了goroutine。在golang中启动协程非常方便,只需要加一个go关键字:
 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))
}
  • 出处:https://github.com/scottkiss/grtm
优质内容筛选与推荐>>
1、GCC使用
2、webpack+vue学习记录
3、IOS view的圆角和阴影并存
4、第一次作业-准备点评
5、day07 数据类型的内置方法(列表的内置方法)