很有幸得到公司信任,采用新的语言进行一些底层服务的开发,在实现功能的同时,也获得了一些感悟,因此在这记录一下,方便自己查看也可以共享给大家。
golang中定时器
golang中提供了2种定时器timer和ticker(如果JS很熟悉的话应该会很了解),分别是一次性定时器和重复任务定时器。
一般用法:
func main() { input := make(chan interface{}) //producer - produce the messages go func() { for i := 0; i < 5; i++ { input <- i } input <- "hello, world" }() t1 := time.NewTimer(time.Second * 5) t2 := time.NewTimer(time.Second * 10) for { select { //consumer - consume the messages case msg := <-input: fmt.Println(msg) case <-t1.C: println("5s timer") t1.Reset(time.Second * 5) case <-t2.C: println("10s timer") t2.Reset(time.Second * 10) } } }
源码观察
这个C是啥,我们去源码看看,以timer为例:
type Timer struct { C <-chan Time r runtimeTimer }
原来是一个channel,其实有GO基础的都知道,GO的运算符当出现的->或者<-的时候,必然是有一端是指channel。按照上面的例子来看,就是阻塞在一个for循环内,等待到了定时器的C从channel出来,当获取到值的时候,进行想要的操作。
设计我们的定时任务队列
我的需求
当时我的需求是这样,我需要接收到客户端的请求并产生一个定时任务,会在固定时间执行,可能是一次,也可能是多次,也可能到指定时间自动停止,可能当任务终止的时候,我还要能停止掉。
具体我画了个流程图,差不多如下,画图水平有限,请见谅。
定义结构
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() //协成执行 防止主进程被阻塞 }
执行部分应该是重点的,我的理解是,分成三部:
- 首先获得一个最先执行的任务
- 然后产生一个定时器,用于执行任务
- 进行阻塞判断,获取我们要进行的操作
func (one *OnceCron) run() { for { //第一步 获取任务 now := time.Now() //获取到当前时间 task, key := one.GetTask() //获取最近的一个任务的执行时间 i64 := task.RunTime - now.Unix() //任务执行和当前时间的差 var d time.Duration if i64 < 0 { //如果任务时间已过期,将执行时间改成现在并且利马执行 one.tasks[key].RunTime = now.Unix() one.doAndReset(key) continue } else { //否则,获取距离执行开始的间隔时间 d = time.Unix(task.RunTime, 0).Sub(now) } //第二步 产生定时器 timer := time.NewTimer(d) //第三步 捕获定时器或者其他事件 for { select { //当定时器到了执行时间时,执行当前任务并关闭定时器 case <-timer.C: one.doAndReset(key) if task != nil { go task.Job.Run() timer.Stop() } //当外部添加了任务时,关闭当前定时器 case <-one.add: timer.Stop() //当外部要删除一个任务时,删除ID为uuidstr的任务 case uuidstr := <-one.remove: one.removeTask(uuidstr) timer.Stop() //当遇到要关闭整个定时器任务时 case <-one.stop: timer.Stop() return } break } } }
后记
这个文章纯粹为笔记分析类的文章,旨在分析我碰到一个需求是如何通过分析过程来产生我们需要的代码的。
源码地址:timing 一个任务队列
应用地址:一个应用于谷歌消息推送的转发中间件
参考源码:GOLANG实现crontab功能
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
P70系列延期,华为新旗舰将在下月发布
3月20日消息,近期博主@数码闲聊站 透露,原定三月份发布的华为新旗舰P70系列延期发布,预计4月份上市。
而博主@定焦数码 爆料,华为的P70系列在定位上已经超过了Mate60,成为了重要的旗舰系列之一。它肩负着重返影像领域顶尖的使命。那么这次P70会带来哪些令人惊艳的创新呢?
根据目前爆料的消息来看,华为P70系列将推出三个版本,其中P70和P70 Pro采用了三角形的摄像头模组设计,而P70 Art则采用了与上一代P60 Art相似的不规则形状设计。这样的外观是否好看见仁见智,但辨识度绝对拉满。
更新日志
- 黄乙玲1988-无稳定的爱心肝乱糟糟[日本东芝1M版][WAV+CUE]
- 群星《我们的歌第六季 第3期》[320K/MP3][70.68MB]
- 群星《我们的歌第六季 第3期》[FLAC/分轨][369.48MB]
- 群星《燃!沙排少女 影视原声带》[320K/MP3][175.61MB]
- 乱斗海盗瞎6胜卡组推荐一览 深暗领域乱斗海盗瞎卡组分享
- 炉石传说乱斗6胜卡组分享一览 深暗领域乱斗6胜卡组代码推荐
- 炉石传说乱斗本周卡组合集 乱斗模式卡组最新推荐
- 佟妍.2015-七窍玲珑心【万马旦】【WAV+CUE】
- 叶振棠陈晓慧.1986-龙的心·俘虏你(2006复黑限量版)【永恒】【WAV+CUE】
- 陈慧琳.1998-爱我不爱(国)【福茂】【WAV+CUE】
- 咪咕快游豪礼放送,百元京东卡、海量欢乐豆就在咪咕咪粉节!
- 双11百吋大屏焕新“热”,海信AI画质电视成最大赢家
- 海信电视E8N Ultra:真正的百吋,不止是大!
- 曾庆瑜1990-曾庆瑜历年精选[派森][WAV+CUE]
- 叶玉卿1999-深情之选[飞图][WAV+CUE]