javatimer序列化_Java主要三种方式来实现定时任务

现代的应用程序早已不是以前的那些由简单的增删改查拼凑而成的程序了&＃xff0c;高复杂性早已是标配&＃xff0c;而任务的定时调度与执行也是对程序的基本要求了。

很多业务需求的实现都离不开定时任务&＃xff0c;例如&＃xff0c;每月一号&＃xff0c;移动将清空你上月未用完流量&＃xff0c;重置套餐流量&＃xff0c;以及备忘录提醒、闹钟等功能。

Java 系统中主要有三种方式来实现定时任务&＃xff1a;

Timer和TimerTask

ScheduledExecutorService

三方框架 Quartz

下面我们一个个来看。

(图1)

Timer和TimerTask

先看一个小 demo&＃xff0c;接着我们再来分析其中原理&＃xff1a;

这种方式的定时任务主要用到两个类&＃xff0c;Timer 和 TimerTask。其中&＃xff0c;TimerTask 继承接口 Runnable&＃xff0c;抽象的描述一种任务类型&＃xff0c;我们只要重写实现它的 run 方法就可以实现自定义任务。

而 Timer 就是用于定时任务调度的核心类&＃xff0c;demo 中我们调用其 schedule 并指定延时 1000 毫秒&＃xff0c;所以上述代码会在一秒钟后完成打印操作&＃xff0c;接着程序结束。

那么&＃xff0c;使用上很简单&＃xff0c;两个步骤即可&＃xff0c;但是其中的实现逻辑是怎样的呢&＃xff1f;

Timer 接口

首先&＃xff0c;Timer 接口中&＃xff0c;这两个字段是非常核心重要的&＃xff1a;

(图2)

TaskQueue 是一个队列&＃xff0c;内部由动态数组实现的最小堆结构&＃xff0c;换句话说&＃xff0c;它是一个优先级队列。而优先级参考下一次执行时间&＃xff0c;越快执行的越排在前面&＃xff0c;这一点我们回头再研究。

接着&＃xff0c;这个 TimerThread 类其实是 Timer 的一个内部类&＃xff0c;它继承了 Thread 并重写了其 run 方法&＃xff0c;该线程实例将在构建 Timer 实例的时候被启动。

run 方法内部会循环的从队列中取任务&＃xff0c;如果没有就阻塞自己&＃xff0c;而当我们成功的向队列中添加了定时任务&＃xff0c;也会尝试唤醒该线程。

我们也来看一下 Timer 的构造方法&＃xff1a;public Timer(String name) {

thread.setName(name);

thread.start();

}

再简单不过的构造函数了&＃xff0c;为内部线程设置线程名&＃xff0c;并启动该线程。

最后&＃xff0c;我们着重看一下 Timer 中用于配置一个定时任务进任务队列的方法。//在时刻 time 处执行任务

schedule(TimerTask task, Date time)

//延时 delay 毫秒后执行任务

schedule(TimerTask task, long delay)

//固定延时重复执行&＃xff0c;firstTime为首次执行时间&＃xff0c;

//往后没间隔 period 毫秒执行一次

schedule(TimerTask task, Date firstTime, long period)

//固定延时重复执行

//首次执行时间为当前时间延时 delay 毫秒

schedule(TimerTask task, long delay, long period)

//固定频率重复执行&＃xff0c;每过 period 毫秒执行一次

scheduleAtFixedRate(TimerTask task, Date firstTime, long period)

//固定频率重复执行

scheduleAtFixedRate(TimerTask task, long delay, long period)

相信有了注释&＃xff0c;这几个方法的区别与作用应该不难理解&＃xff0c;但是其中有两个概念需要作一点区分。

&＃61;&＃61;固定延时&＃61;&＃61; VS &＃61;&＃61;固定频率&＃61;&＃61;

固定延时&＃xff1a;以任务的上一次 实际 执行时间做参考&＃xff0c;往后延时 period 毫秒。

固定频率&＃xff1a;任务的往后每一次执行时间都在任务提交的那一刻得到了确定&＃xff0c;不论你上次任务是否意外延时了&＃xff0c;定时定点执行下一次任务。

这两者的区别还是很大的&＃xff0c;希望你能够理解清楚&＃xff0c;接着我们以其中一个方法为例&＃xff0c;看看底层实现。

以这个方法为例&＃xff0c;其他重载方法的底层调用都是同样的&＃xff0c;我们不去赘述。

(图3)

这个方法的作用&＃xff0c;我们再说一遍。

以当前时间为准&＃xff0c;延时 delay 毫秒后第一次执行该任务&＃xff0c;并且采取固定延时的方式&＃xff0c;每隔 period 毫秒再次执行该任务。

开头的两个异常判断我们不再赘述&＃xff0c;看看 sched 方法&＃xff1a;

(图4)

方法需要传入三个参数&＃xff0c;参数 task 代表的需要执行的任务体&＃xff0c;TimerTask 我们回头会详细介绍&＃xff0c;这里你知道它代表了一个任务体即可。

参数 time 描述了该任务下一次执行的时刻&＃xff0c;计算机底层是以毫秒描述时刻的&＃xff0c;所以这里转换为 long 类型来描述时刻。

参数 period 是固定延时的毫秒数。

整个方法的逻辑我们可以总结概括一下&＃xff0c;具体的代码就不一行行分析了&＃xff0c;因为也不难。

首先使用任务队列的内置对象锁&＃xff0c;锁住个队列。

接着再去锁住我们的 task&＃xff0c;并修改其内部的一些属性字段值&＃xff0c;nextExecutionTime 指明下一次任务执行时间&＃xff0c;period 设置固定延时的毫秒数&＃xff0c;修改 state 状态为计划中。

然后将 task 添加到任务队列&＃xff0c;其中 add 方法内部会进行最小堆重构&＃xff0c;参考的就是 nextExecutionTime 字段的值&＃xff0c;越小优先级越高。

判断如果自己就是队列第一个任务&＃xff0c;那么将唤醒 Timer 中阻塞了的任务线程。

可能会有人疑问&＃xff0c;Timer 如何判断一个任务是否是重复执行的&＃xff0c;还是单次执行就结束的&＃xff1f;

答案在 TimerThread 的 run 方法里&＃xff0c;有兴趣你可以去研究下&＃xff0c;方法体比较多比较长&＃xff0c;这里不做分析。

当我们构造 Timer 实例的时候&＃xff0c;就会启动该线程&＃xff0c;该线程会在一个死循环中尝试从任务队列上获取任务&＃xff0c;如果成功获取就执行该任务并在执行结束之后做一个判断。

如果 period 值为零&＃xff0c;则说明这是一次普通任务&＃xff0c;执行结束后将从队列首部移除该任务。

如果 period 为负值&＃xff0c;则说明这是一次固定延时的任务&＃xff0c;修改它下次执行时间 nextExecutionTime 为当前时间减去 period&＃xff0c;重构任务队列。

如果 period 为正数&＃xff0c;则说明这是一次固定频率的任务&＃xff0c;修改它下次执行时间为 上次执行时间加上 period&＃xff0c;并重构任务队列。

其实&＃xff0c;我也已经把 TimerThread 的 run 方法里最核心的逻辑也已经介绍了&＃xff0c;建议大家亲自去研究研究具体代码的实现&＃xff0c;你会对这一块的逻辑更清晰。

最后&＃xff0c;我们看一看这个 Timer 它有哪些劣势的地方&＃xff1a;

Timer 的背后只有一个线程&＃xff0c;不管你有多少个任务&＃xff0c;都只有一个工作线程&＃xff0c;效率上必然是要打折扣的。

限于单线程&＃xff0c;如果第一个任务逻辑上死循环了&＃xff0c;后续的任务一个都得不到执行。

依然是由于单线程&＃xff0c;任一任务抛出异常后&＃xff0c;整个 Timer 就会结束&＃xff0c;后续任务全部都无法执行。

所以你看&＃xff0c;单线程的 Timer 带来了太多局限性&＃xff0c;于是我们看它的替代者。

PS&＃xff1a;本来计划再介绍下 TimerTask 这个抽象任务类的&＃xff0c;但是发现实在没啥好介绍的&＃xff0c;就是增加了两个字段&＃xff0c;一个用于记录下一次该任务的执行时间&＃xff0c;一个用于延时毫秒数。你也只需要重写其 run 方法即可。

ScheduledExecutorService

这个接口相信你一定眼熟&＃xff0c;我告诉你在哪见过。

(图5)

你看&＃xff0c;它是我们异步框架中的接口&＃xff0c;正好我们今天来介绍他&＃xff0c;这样整个异步框架中所有的接口我们都分析过了。

(图6)

(图7)

ScheduledExecutorService中定义的这四个接口方法和 Timer 中对应的方法几乎一样&＃xff0c;只不过 Timer 的 scheduled 方法需要在外部传入一个 TimerTask 的抽象任务。

而我们的 ScheduledExecutorService 封装的更加细致了&＃xff0c;随便你传 Runnable 或是 Callable&＃xff0c;我会在内部给你做一层封装&＃xff0c;封装一个类似 TimerTask 的抽象任务类(ScheduledFutureTask)。

然后传入线程池&＃xff0c;启动线程去执行该任务&＃xff0c;而我们的 ScheduledFutureTask 重写的 run 方法是这样的&＃xff1a;

(图8)

如果 periodic 为 true 则说明这是一个需要重复执行的任务&＃xff0c;否则说明是一个一次性任务。

所以实际执行该任务的时候&＃xff0c;需要分类&＃xff0c;如果是普通的任务就直接调用 run 方法执行即可&＃xff0c;否则在执行结束之后还需要重置下下一次执行时间。

整体来说&＃xff0c;ScheduledExecutorService 区别于 Timer 的地方就在于前者依赖了线程池来执行任务&＃xff0c;而任务本身会判断是什么类型的任务&＃xff0c;需要重复执行的在任务执行结束后会被重新添加到任务队列。

而对于后者来说&＃xff0c;它只依赖一个线程不停的去获取队列首部的任务并尝试执行它&＃xff0c;无论是效率上、还是安全性上都比不上前者。

所以&＃xff0c;建议使用 ScheduledExecutorService 取代 Timer&＃xff0c;当然&＃xff0c;通过学习 Timer 会更有助于对 ScheduledExecutorService 的研究。

三方框架 Quartz

除了上述两种定时任务框架外&＃xff0c;Java 生态圈还存在一种开源的三方框架&＃xff0c;他就是 Quartz。

Quartz 是一个功能完善的任务调度框架&＃xff0c;支持集群环境下的任务调度&＃xff0c;需要将任务调度状态序列化到数据库。

Quartz 已经是随着分布式概念的流行&＃xff0c;成为企业级定时任务调度框架中的不二选择。

Quartz 这个框架的使用及与原理在本篇就不做介绍了&＃xff0c;我们会在后续介绍分布式概念的时候再来介绍它与 SpringCloud 平台下的整合使用情况。