定时任务ScheduledExecutorService实现是怎样的

这篇文章将为大家详细讲解有关定时任务ScheduledExecutorService实现是怎样的,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。

成都创新互联公司-专业网站定制、快速模板网站建设、高性价比城厢网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式城厢网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖城厢地区。费用合理售后完善,10年实体公司更值得信赖。

现在项目中基本不会自己定义一个ScheduledExecutorService来执行定时任务。都是用第三方框架比如xxl-job之类的,不过了解最基本的定时任务原理还是很有必要的。

ScheduledExecutorService简单示例

我们先来看最简单的使用,代码如下图:

 定时任务ScheduledExecutorService实现是怎样的

ScheduledThreadPoolExecutor是ScheduledExecutorService的实现,能做一些基本的定时任务功能。

比如上图的例子,可以延迟3秒后每隔5秒执行任务。实现起来比较简单。

基础源码分析

首先ScheduledThreadPoolExecutor继承了ThreadPoolExecutor并实现了ScheduledExecutorService,所以它拥有线程池的功能

然后我们看它的构造方法,它有几个构造方法,我们以上面示例的为例,方法中只有一行代码如下:

super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,new DelayedWorkQueue());

调用了父类的构造方法,也就是线程池的构造方法,它自身并没有实现任务事情,除了new了一个DelayedWorkQueue()给父类,这个是给线程池存放任务队列的。

提交任务方法源码

ScheduledThreadPoolExecutor提供了几个执行定时任务的方法,不过我们还是分析上面用到的scheduleAtFixedRate方法,查看源码如下图:

 定时任务ScheduledExecutorService实现是怎样的

这个方法一共就三步:

首先初始化ScheduledFutureTask,它继承了FutureTask,扩展了一些定时任务需要的属性,比如下次执行时间、每次任务执行间隔。

然后调用decorateTask方法装饰任务,目前没有做任务事情,我们可以自定义实现一些功能。

最后调用delayedExecute方法,从上图可以看到这个方法主要流程也简单,首先是把任务放到线程池的队列中,然后调用ensurePrestart方法,ensurePrestart方法是线程池的方法,作用是根据线程池线程数调用addWorker方法创建线程,addWorker方法就不多说了,不清楚的同学可以看我前面几篇的《三分钟弄懂线程池执行过程》。 

提交定时任务的方法还是很简单的,包装一个任务(用于保存定时任务需要的信息),然后提交到线程池的队列中。 

但是有一个问题是,任务提交到线程池了,我们知道线程池能够执行任务,但是都是执行一次啊,不会像定时任务那样执行任务的!那它到底是怎么实现定时任务功能的呢? 

实现定时任务关键第一步

从之前文章分析线程池中最终执行的是提交的任务那个对象的run方法,所以ScheduledFutureTask对run方法有特殊的实现,跟进源码发现run方法正常的流程就两步:

调用ScheduledFutureTask.super.runAndReset()也就是调用了父类的FutureTask的runAndReset()方法,这个方法没有什么在上上篇文章有讲,就是调用内部的Callable的run,保存结果;

在上一个执行完成也就是任务完成后,调用了setNextRunTime();reExecutePeriodic(outerTask);两步代码,第一步是计算下次任务执行时间,第二个是把任务放到队列中; 

run方法执行了具体的方法,在任务执行成功后重新计算了任务下次执行的时间,并再次把任务加载到了队列中,重复执行。 

但是到目前为止也只是实现了规定了在什么时候执行与重复执行,那么到底是如何实现在具体的时间执行呢?

延迟队列实现定时执行

通过还是没有发现如何实现定时执行的,没办法只能继续跟进代码,最后跟到线程池的runWorker方法,在获取Worker的firstTask方法来执行,想起刚刚在调用ensurePrestart方法中调用addWorker方法传递的firstTask都是null,也就是说Worker执行的任务都是从队列中拉取的任务,他们都没有自己的firstTask

也就想起了在初始化方法给线程池传递的队列是new DelayedWorkQueue();所以应该基本找到问题了,我们来看队列的take方法:

 定时任务ScheduledExecutorService实现是怎样的

从源码可以看到是根据队列中第一个元素,然后利用ScheduledFutureTask的getDelay方法来判断是否返回任务或者阻塞,getDelay是根据属性time(前面提到的下次任务执行时间)减去当前时间。

那么如果第一个任务进来判断是10秒后执行,第二个任务进来判断是5秒后执行,那么第二个任务是不是等第一个任务执行完才能执行呢?

很明显不能这么实现,这里就要看DelayedWorkQueue的add方法了,它并没有实现add方法,不过add方法调用的offer,DelayedWorkQueue实现了offer方法。

offer方法也简单,就是把任务加到queue数组中,如果数组为null则直接加进去,并唤醒take哪里的线程,如果不为null则比较数组中任务的time,越近的越在前面,如果新加进来的任务被设置到了数组的第一个,则唤醒take那里阻塞的线程。

ScheduledExecutorService继承线程池,也是把任务提交给线程池执行,只不过它的任务类进行扩展。

任务类ScheduledFutureTask继承FutureTask并扩展了一些属性来记录任务下次执行时间和每次执行间隔。同时重写了run方法重新计算任务下次执行时间,并把任务放到线程池队列中。

ScheduledExecutorService自定义了阻塞队列DelayedWorkQueue给线程池使用,它可以根据ScheduledFutureTask的下次执行时间来阻塞take方法,并且新进来的ScheduledFutureTask会根据这个时间来进行排序,最小的最前面。

总结起来就是通过线程池来执行任务,ScheduledFutureTask记录任务定时信息,DelayedWorkQueue来排序任务定时执行。 

关于定时任务ScheduledExecutorService实现是怎样的就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。


网站题目:定时任务ScheduledExecutorService实现是怎样的
网站地址:http://myzitong.com/article/jpeipj.html