一, 定时任务实现的几种方式:
Timer
这是 java 自带的 java.util.Timer 类, 这个类允许你调度一个 java.util.TimerTask 任务. 使用这种方式可以让你的程序按照某一个频度执行, 但不能在指定时间运行. 一般用的较少.
ScheduledExecutorService
也 jdk 自带的一个类; 是基于线程池设计的定时任务类, 每个调度任务都会分配到线程池中的一个线程去执行, 也就是说, 任务是并发执行, 互不影响.
Spring Task
Spring3.0 以后自带的 task, 可以将它看成一个轻量级的 Quartz, 而且使用起来比 Quartz 简单许多.
Quartz
这是一个功能比较强大的的调度器, 可以让你的程序在指定时间执行, 也可以按照某一个频度执行, 配置起来稍显复杂.
二, 基于 SpringBoot 的定时任务
使用 SpringBoot 自带的定时任务, 只需要添加相应的注解就可以实现
2.1 导入 SpringBoot 启动包
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-parent</artifactId>
- <version>2.1.1.RELEASE</version>
- </dependency>
2.2 启动类启用定时
在启动类上面加上 @EnableScheduling 即可开启定时
- @SpringBootApplication
- @EnableScheduling // 开启定时
- public class SpringBootDemoTimeTaskApplication {
- private static final Logger logger = LoggerFactory.getLogger(SpringBootDemoTimeTaskApplication.class);
- public static void main(String[] args) {
- SpringApplication.run(SpringBootDemoTimeTaskApplication.class);
- logger.info("SpringBootDemoTimeTaskApplication start!");
- }
- }
2.3 创建定时任务实现类 SchedulerTask
- @Component
- public class SchedulerTask {
- private static final Logger logger = LoggerFactory.getLogger(SchedulerTask.class);
- /**
- * @Scheduled(fixedRate = 6000) : 上一次开始执行时间点之后 6 秒再执行
- * @Scheduled(fixedDelay = 6000) : 上一次执行完毕时间点之后 6 秒再执行
- * @Scheduled(initialDelay=1000, fixedRate=6000) : 第一次延迟 1 秒后执行, 之后按 fixedRate 的规则每 6 秒执行一次
- * @Scheduled(cron=""): 详见 cron 表达式 http://www.pppet.net/
- */
- @Scheduled(fixedRate = 5000)
- public void scheduled1() {
- logger.info("=====>>>>>使用 fixedRate 执行定时任务");
- }
- @Scheduled(fixedDelay = 10000)
- public void scheduled2() {
- logger.info("=====>>>>>使用 fixedDelay 执行定时任务");
- }
- @Scheduled(cron="*/6 * * * * ?")
- private void scheduled3(){
- logger.info("使用 cron 执行定时任务");
- }
- }
运行结果:
2019-03-09 17:33:05.681 INFO 7752 --- [ main] c.v.t.SpringBootDemoTimeTaskApplication : SpringBootDemoTimeTaskApplication start!
2019-03-09 17:33:06.002 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : 使用 cron 执行定时任务
2019-03-09 17:33:10.680 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedRate 执行定时任务
2019-03-09 17:33:12.003 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : 使用 cron 执行定时任务
2019-03-09 17:33:15.676 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedRate 执行定时任务
2019-03-09 17:33:15.676 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedDelay 执行定时任务
2019-03-09 17:33:18.002 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : 使用 cron 执行定时任务
2019-03-09 17:33:20.677 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedRate 执行定时任务
2019-03-09 17:33:24.002 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : 使用 cron 执行定时任务
2019-03-09 17:33:25.680 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedRate 执行定时任务
2019-03-09 17:33:25.681 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedDelay 执行定时任务
2019-03-09 17:33:30.005 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : 使用 cron 执行定时任务
2019-03-09 17:33:30.680 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedRate 执行定时任务
2019-03-09 17:33:35.680 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedRate 执行定时任务
2019-03-09 17:33:35.682 INFO 7752 --- [ scheduling-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 fixedDelay 执行定时任务
2.4 执行时间的配置
在上面的定时任务中, 我们在方法上使用 @Scheduled 注解来设置任务的执行时间, 并且使用三种属性配置方式:
fixedRate: 定义一个按一定频率执行的定时任务
fixedDelay: 定义一个按一定频率执行的定时任务, 与上面不同的是, 改属性可以配合 initialDelay, 定义该任务延迟执行时间.
cron: 通过表达式来配置任务执行时间 -- 在线 cron 表达式生成器 http://cron.qqe2.com/
三, 多线程执行定时任务
SpringBoot 定时任务默认单线程, 可以看到三个定时任务都已经执行, 并且使同一个线程中 (scheduling-1) 串行执行, 如果只有一个定时任务, 这样做肯定没问题, 当定时任务增多, 如果一个任务卡死, 会导致其他任务也无法执行.
3.1 多线程配置类 AsyncConfig.class
- @Configuration // 表明该类是一个配置类
- @EnableAsync // 开启异步事件的支持
- public class AsyncConfig {
- @Value("${myProps.corePoolSize}")
- private int corePoolSize;
- @Value("${myProps.maxPoolSize}")
- private int maxPoolSize;
- @Value("${myProps.queueCapacity}")
- private int queueCapacity;
- @Bean
- public Executor taskExecutor() {
- ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
- executor.setCorePoolSize(corePoolSize);
- executor.setMaxPoolSize(maxPoolSize);
- executor.setQueueCapacity(queueCapacity);
- executor.initialize();
- return executor;
- }
- }
3.2 配置文件 application.YAML 中添加多线程配置
- myProps:
- corePoolSize: 10
- maxPoolSize: 100
- queueCapacity: 10
3.3 在定时任务的类或者方法上添加 @Async
此时, 可让每一个任务都是在不同的线程中, 启动项目, 日志打印如下:
2019-03-11 15:16:54.855 INFO 10782 --- [ main] c.v.t.SpringBootDemoTimeTaskApplication : SpringBootDemoTimeTaskApplication start!
2019-03-11 15:16:55.015 INFO 10782 --- [ taskExecutor-1] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 1
2019-03-11 15:17:00.002 INFO 10782 --- [ taskExecutor-2] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 2
2019-03-11 15:17:00.002 INFO 10782 --- [ taskExecutor-3] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 1
2019-03-11 15:17:05.003 INFO 10782 --- [ taskExecutor-4] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 1
2019-03-11 15:17:06.005 INFO 10782 --- [ taskExecutor-5] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 2
2019-03-11 15:17:10.004 INFO 10782 --- [ taskExecutor-6] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 1
2019-03-11 15:17:12.005 INFO 10782 --- [ taskExecutor-7] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 2
2019-03-11 15:17:15.006 INFO 10782 --- [ taskExecutor-8] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 1
2019-03-11 15:17:18.004 INFO 10782 --- [ taskExecutor-9] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 2
2019-03-11 15:17:20.004 INFO 10782 --- [taskExecutor-10] cn.van.task.service.SchedulerTask : =====>>>>>使用 cron 执行定时任务 - 1
日志打印证明了我的预测, 至此, 多线程中执行定时任务完毕!
四, 源码及其延伸
来源: https://www.cnblogs.com/vandusty/p/11390196.html