用golang实现一个定时器任务队列实例

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《用golang实现一个定时器任务队列实例》，聊聊定时器，希望可以帮助到正在努力赚钱的你。

 很有幸得到公司信任，采用新的语言进行一些底层服务的开发，在实现功能的同时，也获得了一些感悟，因此在这记录一下，方便自己查看也可以共享给大家。

golang中定时器

golang中提供了2种定时器timer和ticker（如果JS很熟悉的话应该会很了解），分别是一次性定时器和重复任务定时器。

一般用法:

func main() { 
 input := make(chan interface{}) 
 //producer - produce the messages
 go func() {
  for i := 0; i 

<p>源码观察</p>
<p>这个C是啥，我们去源码看看，以timer为例：</p>

<pre class="brush:plain;">
type Timer struct {
 C 

<p>原来是一个channel，其实有GO基础的都知道，GO的运算符当出现的->或者
</p><p><span style="color: #ff0000"><strong>设计我们的定时任务队列</strong></span></p>
<p><strong>我的需求</strong></p>
<p>当时我的需求是这样，我需要接收到客户端的请求并产生一个定时任务，会在固定时间执行，可能是一次，也可能是多次，也可能到指定时间自动停止，可能当任务终止的时候，我还要能停止掉。</p>
<p>具体我画了个流程图，差不多如下，画图水平有限，请见谅。</p>
<p style="text-align: center"><img alt=""    style="max-width:100%"  style="max-width:100%" src="/uploads/20230101/167256274763b1483b688c8.jpg?201842395256"></p>
<p><strong>定义结构</strong></p>

<pre class="brush:plain;">
type OnceCron struct {
 tasks []*Task   //任务的列队
 add chan *Task  //当遭遇到新任务的时候
 remove chan string  //当遭遇到删除任务的时候
 stop chan struct{}  //当遇到停止信号的时候
 Logger *log.Logger  //日志 
}
type Job interface {
 Run()     //执行接口
}
type Task struct {
  Job  Job   //要执行的任务 
 Uuid string   //任务标识,删除时用
 RunTime int64   //执行时间
 Spacing int64   //间隔时间
 EndTime int64   //结束时间
 Number int    //总共要次数
}

队列实现

首先，我们要获得一个队列任务

func NewCron() *OnceCron 常规操作，为了节省篇幅，我就不写出来，具体可以看源码，贴在了底部。

然后，开始定时器队列的运行，一般，都会命名为Start。那么就有一个问题，我们刚开始启动程序的时候，这个时候是没有任务队列，那岂不是for{ select{}}在等待个毛毛球？所以，我们需要在Start的时候添加一个默认的任务， 我是这么做的，添加了一个一小时执行一次的重复队列，防止队列退出。

func (one *OnceCron) Start() {
 //初始化的時候加入一個一年的長定時器,間隔1小時執行一次
 task := getTaskWithFuncSpacing(3600, time.Now().Add(time.Hour*24*365).Unix（） , func() {
 log.Println("It's a Hour timer!")
 }) //为了代码格式markdown 里面有个括号我改成全角了
 one.tasks = append(one.tasks, task)
 go one.run() //协成执行 防止主进程被阻塞
}

执行部分应该是重点的，我的理解是，分成三部:

1. 首先获得一个最先执行的任务
2. 然后产生一个定时器，用于执行任务
3. 进行阻塞判断，获取我们要进行的操作

func (one *OnceCron) run() {

 for {
    //第一步 获取任务
 now := time.Now() //获取到当前时间
 task, key := one.GetTask() //获取最近的一个任务的执行时间
 i64 := task.RunTime - now.Unix() //任务执行和当前时间的差

 var d time.Duration
 if i64 

<p><span style="color: #ff0000"><strong>后记</strong></span></p>
<p>这个文章纯粹为笔记分析类的文章，旨在分析我碰到一个需求是如何通过分析过程来产生我们需要的代码的。</p>
<p>源码地址:<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5ko5XFfIfNhNCyr5q5aaPGZKestI2fZXxsi6jHutKtjquEz62tfs6Sqrlph6pxYLyGm2S_fYGofmuDorLN0WyDhp_Rsa6VzoXdsqWGvX1iu6ybcQ' rel='nofollow'>timing 一个任务队列 </a></p>
<p>应用地址:<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5ko5XFfIfNhNCyr5q5aaPGZKestI2fZXxsh6_GuptsfauEz62tf8-St7VthaqCnLGGgp-yo31jiaaGsbS3zW2DeYzfsmZ-3oWVuWqR4IqasYNtcQ' rel='nofollow'>一个应用于谷歌消息推送的转发中间件</a></p>
<p>参考源码:<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5ko5XFfIfNhNCyr5q5aanEZHqhxpCbpolsg67HzLOifauEz757hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Jtt' rel='nofollow'>GOLANG实现crontab功能 </a><br></p>
<p>到这里，我们也就讲完了《用golang实现一个定时器任务队列实例》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于golang的知识点！</p>