ScheduledThreadPoolExecutor可以用来很方便实现我们的调度任务，具体使用可以参考调度线程池ScheduledThreadPoolExecutor的正确使用姿势这篇文章，那大家知道它是怎么实现的吗，本文就带大家来揭晓谜底。,我们先思考下，如果让大家去实现ScheduledThreadPoolExecutor可以周期性执行任务的功能，需要考虑哪些方面呢？,答：我们是不是可以继承线程池类，按照线程池的思路，将任务先丢到阻塞队列中，等到时间到了，工作线程就从阻塞队列获取任务执行。,答：我们可以根据参数获取这个任务还要多少时间执行，那么我们是不是可以从阻塞队列中获取任务的时候，通过条件队列的的awaitNanos(delay)方法，阻塞一定时间。,答：这就更加简单了，任务执行完成后，把它再次加入到队列不就行了吗。,
,类结构图,
,ScheduledThreadPoolExecutor的类结构图如上图所示，很明显它是在我们的线程池ThreadPoolExecutor框架基础上扩展的。,重要属性,通过ScheduledThreadPoolExecutor类的成员属性，我们可以了解它的数据结构。,ScheduledFutureTask 继承 FutureTask，实现 RunnableScheduledFuture 接口，无论是 runnable 还是 callable，无论是否需要延迟和定时，所有的任务都会被封装成 ScheduledFutureTask。,该类具有延迟执行的特点, 覆盖FutureTask 的 run 方法来实现对延时执行、周期执行的支持。,对于延时任务调用FutureTask#run，而对于周期性任务则调用FutureTask#runAndReset 并且在成功之后根据 fixed-delay/fixed-rate模式来设置下次执行时间并重新将任务塞到工作队列。,成员属性如下：,DelayedWorkQueue 是支持延时获取元素的阻塞队列， 内部采用优先队列 PriorityQueue（小根堆、满二叉树）存储元素。,内部数据结构是数组，所以延迟队列出队头元素后需要让其他元素（尾）替换到头节点，防止空指针异常。,成员属性如下：,延迟执行方法，并指定延迟执行的时间，只会执行一次。,调用triggerTime(delay, unit)方法计算延迟的时间。,按照固定的频率周期性的执行任务，捕手renwu，一次任务的启动到下一次任务的启动的间隔,按照指定的延时周期性执行任务，上一个任务执行完毕后，延时一定时间，再次执行任务。,上面多种提交任务的方式，殊途同归，最终都会调用delayedExecute()方法执行延迟或者周期任务。,delayedExecute()方法是执行延迟任务的入口,addWorker()方法实际上父类ThreadPoolExecutor的方法，这个方法在该文章 Java线程池源码深度解析中详细介绍过，这边做个总结：,目前工作线程已经创建好了，工作线程开始工作了，它会从阻塞队列中获取延迟任务执行，这部分也是线程池里面的原理，不做展开，那我们看下它是如何实现延迟执行的? 主要关注如何从阻塞队列中获取任务。,该方法会在上面的addWoker()方法创建工作线程后，工作线程中循环持续调用workQueue.take()方法获取延迟任务。,该方法主要获取延迟队列中任务延迟时间小于等于0 的任务。,如果延迟时间不小于0，那么调用条件队列的awaitNanos(delay)阻塞方法等待一段时间，等时间到了，延迟时间自然小于等于0了。,获取到任务后，工作线程就可以开始执行调度任务了。,该方法主要做两个事情， 获取头节点并调整堆，重新选择延迟时间最小的节点放入头部。,从延迟队列中获取任务后，工作线程会调用延迟任务的run()方法执行任务。,调用isPeriodic()方法判断任务是否是周期性任务还是非周期性任务,如果任务是非周期任务，就调用父类的FutureTask#run()执行一次,如果任务是非周期任务，就调用父类的FutureTask#runAndReset(), 返回true会设置下一次的执行时间，重新放入线程池的阻塞队列中，等待下次获取执行,周期任务正常完成后任务的状态不会变化，依旧是 NEW，不会设置 outcome 属性。,但是如果本次任务执行出现异常，会进入 setException 方法将任务状态置为异常，把异常保存在 outcome 中。,方法返回 false，后续的该任务将不会再周期的执行,如果属性period大于0，表示fixed-rate模式，直接加上period时间即可。,如果属性period小于等于0， 表示是fixed-delay模式， 调用triggerTime重新计算下次时间。,
© 版权声明
文章版权归作者所有，未经允许请勿转载。
