java定时任务_定时任务3种实现方式

java定时任务_定时任务3种实现方式

• 定时任务在实际的开发中特别常见&＃xff0c;比如电商平台 30 分钟后自动取消未支付的订单&＃xff0c;以及凌晨的数据汇总和备份等&＃xff0c;都需要借助定时任务来实现&＃xff0c;那么我们本文就来看一下定时任务最简单的几种实现方式。

Timer

• Timer 是 JDK 自带的定时任务执行类&＃xff0c;无论任何项目都可以直接使用 Timer 来实现定时任务&＃xff0c;所以 Timer 的优点就是使用方便&＃xff0c;它的实现代码如下&＃xff1a;

  public class MyTimerTask {public static void main(String[] args) {// 定义一个任务TimerTask timerTask &＃61; new TimerTask() {&＃64;Overridepublic void run() {System.out.println("Run timerTask&＃xff1a;" &＃43; new Date());}};// 计时器Timer timer &＃61; new Timer();// 添加执行任务&＃xff08;延迟 1s 执行&＃xff0c;每 3s 执行一次&＃xff09;timer.schedule(timerTask, 1000, 3000);}
}


• 程序执行结果如下&＃xff1a;

• Run timerTask&＃xff1a;Mon Aug 17 21:29:25 CST 2020
Run timerTask&＃xff1a;Mon Aug 17 21:29:28 CST 2020
Run timerTask&＃xff1a;Mon Aug 17 21:29:31 CST 2020


Timer 缺点分析

• 任务执行时间长影响其他任务

• 当一个任务的执行时间过长时&＃xff0c;会影响其他任务的调度&＃xff0c;如下代码所示&＃xff1a;

  public class MyTimerTask {public static void main(String[] args) {// 定义任务 1TimerTask timerTask &＃61; new TimerTask() {&＃64;Overridepublic void run() {System.out.println("进入 timerTask 1&＃xff1a;" &＃43; new Date());try {// 休眠 5 秒TimeUnit.SECONDS.sleep(5);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Run timerTask 1&＃xff1a;" &＃43; new Date());}};// 定义任务 2TimerTask timerTask2 &＃61; new TimerTask() {&＃64;Overridepublic void run() {System.out.println("Run timerTask 2&＃xff1a;" &＃43; new Date());}};// 计时器Timer timer &＃61; new Timer();// 添加执行任务&＃xff08;延迟 1s 执行&＃xff0c;每 3s 执行一次&＃xff09;timer.schedule(timerTask, 1000, 3000);timer.schedule(timerTask2, 1000, 3000);}
}


• 程序执行结果如下&＃xff1a;

• 进入 timerTask 1&＃xff1a;Mon Aug 17 21:44:08 CST 2020
Run timerTask 1&＃xff1a;Mon Aug 17 21:44:13 CST 2020 Run timerTask 2&＃xff1a;Mon Aug 17 21:44:13 CST 2020
进入 timerTask 1&＃xff1a;Mon Aug 17 21:44:13 CST 2020
Run timerTask 1&＃xff1a;Mon Aug 17 21:44:18 CST 2020
进入 timerTask 1&＃xff1a;Mon Aug 17 21:44:18 CST 2020
Run timerTask 1&＃xff1a;Mon Aug 17 21:44:23 CST 2020 Run timerTask 2&＃xff1a;Mon Aug 17 21:44:23 CST 2020
进入 timerTask 1&＃xff1a;Mon Aug 17 21:44:23 CST 2020


• 从上述结果中可以看出&＃xff0c;当任务 1 运行时间超过设定的间隔时间时&＃xff0c;任务 2 也会延迟执行。 原本任务 1 和任务 2 的执行时间间隔都是 3s&＃xff0c;但因为任务 1 执行了 5s&＃xff0c;因此任务 2 的执行时间间隔也变成了 10s&＃xff08;和原定时间不符&＃xff09;

• 任务异常影响其他任务

• 使用 Timer 类实现定时任务时&＃xff0c;当一个任务抛出异常&＃xff0c;其他任务也会终止运行&＃xff0c;如下代码所示&＃xff1a;

• public class MyTimerTask {public static void main(String[] args) {// 定义任务 1TimerTask timerTask &＃61; new TimerTask() {&＃64;Overridepublic void run() {System.out.println("进入 timerTask 1&＃xff1a;" &＃43; new Date());// 模拟异常int num &＃61; 8 / 0;System.out.println("Run timerTask 1&＃xff1a;" &＃43; new Date());}};// 定义任务 2TimerTask timerTask2 &＃61; new TimerTask() {&＃64;Overridepublic void run() {System.out.println("Run timerTask 2&＃xff1a;" &＃43; new Date());}};// 计时器Timer timer &＃61; new Timer();// 添加执行任务&＃xff08;延迟 1s 执行&＃xff0c;每 3s 执行一次&＃xff09;timer.schedule(timerTask, 1000, 3000);timer.schedule(timerTask2, 1000, 3000);}
}


• 程序执行结果如下&＃xff1a;

• 进入 timerTask 1&＃xff1a;Mon Aug 17 22:02:37 CST 2020
Exception in thread "Timer-0" java.lang.ArithmeticException: / by zero
at com.example.MyTimerTask$1.run(MyTimerTask.java:21)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
Process finished with exit code 0


Timer 小结

• Timer 类实现定时任务的优点是方便&＃xff0c;因为它是 JDK 自定的定时任务&＃xff0c;但缺点是任务如果执行时间太长或者是任务执行异常&＃xff0c;会影响其他任务调度&＃xff0c;所以在生产环境下建议谨慎使用。

ScheduledExecutorService

• ScheduledExecutorService 也是 JDK 1.5 自带的 API&＃xff0c;我们可以使用它来实现定时任务的功能&＃xff0c;也就是说ScheduledExecutorService 可以实现 Timer 类具备的所有功能&＃xff0c;并且它可以解决了 Timer 类存在的所有问题。

• ScheduledExecutorService 实现定时任务的代码示例如下&＃xff1a;

• public class MyScheduledExecutorService {public static void main(String[] args) {// 创建任务队列ScheduledExecutorService scheduledExecutorService &＃61;Executors.newScheduledThreadPool(10); // 10 为线程数量// 执行任务scheduledExecutorService.scheduleAtFixedRate(() -> {System.out.println("Run Schedule&＃xff1a;" &＃43; new Date());}, 1, 3, TimeUnit.SECONDS); // 1s 后开始执行&＃xff0c;每 3s 执行一次}
}


• 程序执行结果如下&＃xff1a;

• Run Schedule&＃xff1a;Mon Aug 17 21:44:23 CST 2020
Run Schedule&＃xff1a;Mon Aug 17 21:44:26 CST 2020
Run Schedule&＃xff1a;Mon Aug 17 21:44:29 CST 2020


• 使用 ScheduledExecutorService 可以避免任务执行时间过长对其他任务造成的影响。

• 当任务 1 出现异常时&＃xff0c;并不会影响任务 2 的执行

ScheduledExecutorService 小结

• 在单机生产环境下建议使用 ScheduledExecutorService 来执行定时任务&＃xff0c;它是 JDK 1.5 之后自带的 API&＃xff0c;因此使用起来也比较方便&＃xff0c;并且使用 ScheduledExecutorService 来执行任务&＃xff0c;不会造成任务间的相互影响。

Spring Task

• 如果使用的是 Spring 或 Spring Boot 框架&＃xff0c;可以直接使用 Spring Framework 自带的定时任务&＃xff0c;使用上面两种定时任务的实现方式&＃xff0c;很难实现设定了具体时间的定时任务&＃xff0c;比如当我们需要每周五来执行某项任务时&＃xff0c;但如果使用 Spring Task 就可轻松的实现此需求
• 以 Spring Boot 为例&＃xff0c;实现定时任务只需两步&＃xff1a;
• 开启定时任务
• 添加定时任务

开启定时任务

• 开启定时任务只需要在 Spring Boot 的启动类上声明 &＃64;EnableScheduling 即可&＃xff0c;实现代码如下&＃xff1a;

• &＃64;SpringBootApplication
&＃64;EnableScheduling // 开启定时任务
public class DemoApplication {// do someing
}


添加定时任务

• 定时任务的添加只需要使用 &＃64;Scheduled 注解标注即可&＃xff0c;如果有多个定时任务可以创建多个 &＃64;Scheduled 注解标注的方法&＃xff0c;示例代码如下&＃xff1a;

• import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;&＃64;Component // 把此类托管给 Spring&＃xff0c;不能省略
public class TaskUtils {// 添加定时任务&＃64;Scheduled(cron &＃61; "59 59 23 0 0 5") // cron 表达式&＃xff0c;每周五 23:59:59 执行public void doTask(){System.out.println("我是定时任务~");}
}


• 定时任务是自动触发的无需手动干预&＃xff0c;也就是说 Spring Boot 启动后会自动加载并执行定时任务。