golang延时任务如何实现


这篇文章主要介绍“golang延时任务如何实现”,在日常操作中,相信很多人在golang延时任务如何实现问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”golang延时任务如何实现”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!我们都知道,任何一种队列,实际上都是存在生产者和消费者两部分的。只不过,延时任务相对于普通队列,多了一个延时的特性罢了。1、生产者从生产者的角度上讲,当用户推送一个任务过来的时候,会携带着延迟执行的时间数值。为了让这个任务到预定时刻能执行,我们需要将这个任务放在内存里储存一段时间,并且时间是一维的,在不断增长。那么,我们用什么数据结构存储呢?(1)选择一:map。由于map具有无序性,无法按照执行时间排序,我们无法保证取出的任务是否是当前时间点需要执行的,所以排除这个选项。(2)选择二:channel。的确,channel有时候可以看作队列,然而,它的输出和输入严格遵循着“先进先出”的原则,遗憾的是,先进的任务未必就是先执行的,因此,channel也并不合适。(3)选择三:slice。切片貌似可行,因为切片元素是具有有序性的,所以,如果我们能够按照执行时间的顺序排列好所有的切片元素,那么,每次只要读取切片的头元素(也可能是尾元素),就可以得到我们要的任务。2、消费者从消费者的角度来说,它最大的难点在于,如何让每个任务,在特定的时间点被消费。那么,针对每一个任务,我们如何实现,让它等待一段时间后再执行呢?没错,就是timer。总结下来,“切片+timer”的组合,应该是可以达到目的的。(1)用户调用InitDelayQueue() ,初始化延时任务对象。(2)开启协程,监听任务操作管道(add/delete信号),以及执行时间管道(timer.C信号)。(3)用户发出add/delete信号。(4)(2)中的协程捕捉到(3)中的信号,对任务列表进行变更。(5)当任务执行的时间点到达的时候(timer.C管道有元素输出的时候),执行任务。(1)延时任务对象这里需要注意,有一个waitRemoveTaskMapping字段。由于要删除的任务,可能还在add管道中,没有及时更新到tasks字段中,所以,需要临时记录下客户要删除的任务id。(2)任务对象在这个过程中,我们需要对用户对任务的操作信号,以及任务的执行时间信号进行监听。完善我们的初始化方法:生产者推送任务的时候,只需要将任务加到add管道中即可,在这里,我们生成一个任务id,并返回给用户。在这里,我们要将用户推送的任务放到延时任务的tasks字段中。由于,我们需要将任务按照执行时间顺序排序,所以,我们需要找到新增任务在切片中的插入位置。又因为,插入之前的任务列表已经是有序的,所以,我们可以采用二分法处理。找到正确的插入位置后,我们才能将任务准确插入:那么,在监听add管道的时候,我们直接调用上述addTask() 即可。在这里,我们可以遍历任务列表,根据删除任务的id找到其在切片中的对应index。然后,我们可以完善start()方法了。start()执行的时候,分成两种情况:任务列表为空,只需要监听add管道即可;任务列表不为空的时候,需要监听所有管道。任务执行信号,主要是依靠timer来实现,属于第二种情况。执行任务:结束任务,刷新任务列表:delay_queue.go测试代码:dela免费云主机域名y_queue_test.go上面的方案,的确实现了延时任务的效果,但是其中仍然有一些问题,仍然值得我们思考和优化。1、按照上面的方案,如果大量延时任务的执行时间,集中在同一个时间点,会造成短时间内timer频繁地创建和销毁。2、上述方案相比于time.AfterFunc()方法,我们需要在哪些场景下作出取舍。3、如果服务崩溃或重启,如何去持久化队列中的任务。到此,关于“golang延时任务如何实现”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注百云主机网站,小编会继续努力为大家带来更多实用的文章!

相关推荐: node能高并发的原因是什么

本篇内容主要讲解“node能高并发的原因是什么”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“node能高并发的原因是什么”吧! 因为node具有“事务驱动”和异步“I/O”特性,是非阻塞异步操作;针对每个并发请求,…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 05/26 22:13
下一篇 05/26 22:14

相关推荐