定时任务方案大百科(下)

简介: 节前有更新一篇定时任务的相关文章《延时消息之时间轮》,有朋友提出希望可以完整的介绍下常见的定时任务方案,于是便有了这篇文章。

ScheduledExecutor


既然 Timer 存在一些问题,于是在 JDK1.5 中的并发包中推出了 ScheduledThreadPoolExecutor 来替代 Timer,从它所在包路径也能看出它本身是支持任务并发执行的。


先来看看它的类继承图:



可以看到他本身也是一个线程池,继承了 ThreadPoolExecutor



从他的构造函数中也能看出,本质上也是创建了一个线程池,只是这个线程池中的阻塞队列是一个自定义的延迟队列 DelayedWorkQueue(与 Timer 中的 TaskQueue 作用一致)


新建任务



当我们写入一个定时任务时,首先会将任务写入到 DelayedWorkQueue 中,其实这个队列本质上也是使用数组实现的最小堆。



新建任务时最终会调用到 offer() 方法,在这里也会使用 siftUp() 将写入的任务移动到堆顶。



原理就和之前的 Timer 类似,只不过这里是通过自定义比较器来排序的,很明显它是通过任务的执行时间进行比较的。


运行任务


所以这样就能将任务按照执行时间的顺序排好放入到线程池中的阻塞队列中。


这时就得需要回顾一下之前线程池的知识点了:


在线程池中会利用初始化时候的后台线程从阻塞队列中获取任务,只不过在这里这个阻塞队列变为了 DelayedWorkQueue,所以每次取出来的一定是按照执行时间排序在前的任务。



Timer 类似,要在任务取出后调用 finishPoll() 进行删除,也是将最后一个任务提到堆顶,然后挨个对比移动到合适的位置。


而触发消费这个 DelayedWorkQueue 队列的地方则是在写入任务的时候。



本质上是调用 ThreadPoolExecutoraddWorker() 来写入任务的,所以消费 DelayedWorkQueue 也是在其中触发的。


这里更多的是关于线程池的知识点,不太清楚的可以先看看之前总结的线程池篇,这里就不再赘述。




原理看完了想必也知道和 Timer 的优势在哪儿了。


Timer ScheduledThreadPoolExecutor
单线程阻塞 多线程任务互不影响
异常时任务停止 依赖于线程池,单个任务出现异常不影响其他任务


所以有定时任务的需求时很明显应当淘汰 Timer 了。


时间轮


最后一个是基于时间轮的定时任务,这个我在上一篇《延时消息之时间轮》有过详细介绍。


通过源码分析我们也可以来做一个对比:


ScheduledThreadPoolExecutor 基于时间轮
写入效率 基于最小堆,任务越多效率越低 HashMap 的写入类似,效率很高。
执行效率 每次取出第一个,效率很高 每秒拨动一个指针取出任务


所以当写入的任务较多时,推荐使用时间轮,它的写入效率更高。


但任务很少时其实 ScheduledThreadPoolExecutor 也不错,毕竟它不会每秒都去拨动指针消耗 CPU ,而是一旦没有任务线程会阻塞直到有新的任务写入进来。


RingBufferWheel 更新


在之前的《延时消息之时间轮》中自定义了一个基于时间轮的定时任务工具 RingBufferWheel ,在网友的建议下这次顺便也做了一些调整,优化了 API 也新增了取消任务的 API。



在之前的 API 中,每当新增一个任务都要调用一下 start(),感觉很怪异;这次直接将启动函数合并到 addTask 中,使用起来更加合理。


同时任务的写入也支持并发了。



不过这里需要注意的是 start() 在并发执行的时候只能执行一次,于是就利用了 CAS 来保证同时只有一个线程可以执行成功。


同时在新增任务的时候会返回一个 taskId ,利用此 ID 便可实现取消任务的需求(虽然是比较少见),使用方法如下:



感兴趣的朋友可以看下源码也很容易理解。


分布式定时任务


最后再扩展一下,上文我们所提到的所有方案都是单机版的,只能在单个进程中使用。


一旦我们需要在分布式场景下实现定时任务的高可用、可维护之类的需求就得需要一个完善的分布式调度平台的支持。


目前市面上流行的开源解决方案也不少:





我个人在工作中只使用过前面两者,都能很好的解决分布式调度的需求;比如高可用、统一管理、日志报警等。


当然这些开源工具其实在定时调度这个功能上和上文中所提到的一些方案是分不开的,只是需要结合一些分布式相关的知识;比远程调用、统一协调、分布式锁、负载均衡之类的。


感兴趣的朋友可以自行查看下他们的源码或官方文档。


总结


一个小小的定时器其实涉及到的知识点还不少,包括数据结构、多线程等,希望大家看完多少有些帮助


本文所涉及到的所有源码:


github.com/crossoverJi…


相关文章
|
4天前
|
SQL 弹性计算 安全
阿里云上云优选与飞天加速计划活动区别及购买云服务器后续必做功课参考
对于很多用户来说,购买云服务器通常都是通过阿里云当下的各种活动来购买,这就有必要了解这些活动的区别,同时由于活动内的云服务器购买之后还需要单独购买并挂载数据盘,还需要设置远程密码以及安全组等操作之后才能正常使用云服务器。本文就为大家介绍一下目前比较热门的上云优选与飞天加速计划两个活动的区别,以及通过活动来购买云服务器之后的一些必做功课,确保云服务器可以正常使用,以供参考。
|
弹性计算 监控 安全
阿里云服务器配置选择流程(2023新版教程)
阿里云服务器配置选择流程(2023新版教程)
314 0
|
域名解析 弹性计算 Linux
阿里云服务器简介、优势、购买流程及网站搭建教程
阿里云服务器简介、优势、购买流程及网站搭建教程
202 0
|
域名解析 弹性计算 Linux
阿里云服务器配置教程(从购买配置到网站上线全流程)
阿里云服务器使用教程包括云服务器购买、云服务器配置选择、云服务器开通端口号、搭建网站所需Web环境、安装网站程序、域名解析到云服务器公网IP地址,最后网站上线全流程,阿小云分享阿里云服务器详细使用教程:
580 0
|
存储 弹性计算 大数据
阿里云服务器简介和优势以及购买流程
阿里云服务器简介和优势以及购买流程,阿里云服务器全方位介绍包括云服务器ECS优势、云服务器租用价格、云服务器使用场景及限制说明,阿里云百科分享云服务器ECS介绍、个人和企业免费试用、云服务器活动、云服务器ECS规格、优势、功能及应用场景详细说明
|
存储 弹性计算 小程序
阿里云服务器的四种购买方式及其适合对象和购买流程简介
对于第一次购买云服务器的新手用户来说,阿里云服务器购买页面有点复杂,从云服务器购买、配置选择到网站上线全过程都是很多新手用户关心的问题,2023年了,小编决定写一篇阿里云服务器购买流程的图文教程。
453 1
阿里云服务器的四种购买方式及其适合对象和购买流程简介
|
域名解析 弹性计算 网络协议
阿里云服务器建站教程来了(十分钟网站上线)
阿里云服务器建站教程来了(十分钟网站上线)阿里云轻量应用服务器怎么使用?阿里云轻量应用服务器使用教程:轻量应用服务器购买、重置密码、远程连接、宝塔面板的Web环境搭建、WordPress网站程序安装到网站上线,阿里云服务器网分享轻量应用服务器从购买、配置建站环境、轻量服务器应用服务器远程连接、开端口到网站上线全流程
308 0
阿里云服务器建站教程来了(十分钟网站上线)
|
云安全 弹性计算 安全
在阿里云各活动中购买的云服务器,后续还需要哪些操作才能正常使用
当下阿里云在各种活动中推出了众多价格非常实惠的云服务器,但是我们在通过这些活动购买好云服务器之后,并不是马上就可以用了,购买之后还需要给云服务器设置远程登录密码、设置安全组规则、设置基础安全、购买并挂载云盘等操作之后,我们才能使用并部署自己的应用到云服务器上,以下内容是在阿里云各个活动中购买云服务器之后必做的一些功课介绍。
在阿里云各活动中购买的云服务器,后续还需要哪些操作才能正常使用
|
存储 机器学习/深度学习 弹性计算
阿里云服务器优势和购买流程
阿里云服务器优势和购买流程,阿里云服务器全方位介绍包括云服务器ECS优势、云服务器租用价格、云服务器使用场景及限制说明,阿里云服务器网分享云服务器ECS介绍、个人和企业免费试用、云服务器活动、云服务器ECS规格
76 0
|
弹性计算 人工智能 安全
阿里云服务器优势和购买流程和使用流程
阿里云是阿里巴巴集团的旗舰云计算品牌,它为全球各种规模的企业提供了云计算服务。阿里云服务器是阿里云的一项核心业务,它是一种可靠的云服务解决方案,具有许多优势。
阿里云服务器优势和购买流程和使用流程