SpringBoot-定时任务
内容摘要
SpringBoot在2.0版本之后,提供了非常方便的注解方式来编写定时任务程序,无需添加任何配置文件和依赖关系,快速构建一个SpringBoot项目,添加注解如下:@SpringBootApplication
@En
@En
文章正文
SpringBoot在2.0版本之后,提供了非常方便的注解方式来编写定时任务程序,无需添加任何配置文件和依赖关系,快速构建一个SpringBoot项目,添加注解如下:
@SpringBootApplication @EnableScheduling public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } }
@EnableScheduling:开启对定时任务的支持
注解方式-单线程
创建SchedulerTask1类存放与task包下:
@Component public class SchedulerTask1 { @Scheduled(cron = "*/6 * * * * ?") private void process(){ System.out.println("SchedulerTask1 : " + LocalDateTime.now().toLocalTime() + " 线程 : " + Thread.currentThread().getName()); } }
创建SchedulerTask2类存放与task包下:
@Component public class SchedulerTask2 { @Scheduled(fixedRate = 3000) private void process(){ System.out.println("SchedulerTask2 : " + LocalDateTime.now().toLocalTime() + " 线程 : " + Thread.currentThread().getName()); } }
@Scheduled 参数可以接受两种定时的设置,一种是我们常用的cron="*/6 * * * * ?",一种是 fixedRate = 3000,两种都表示每隔X秒打印一下内容。
fixedRate 说明
@Scheduled(fixedRate = 3000) :上一次开始执行时间点之后3秒再执行
@Scheduled(fixedDelay = 3000) :上一次执行完毕时间点之后3秒再执行
@Scheduled(initialDelay=1000, fixedRate=6000) :第一次延迟1秒后执行,之后按
fixedRate 的规则每6秒执行一次
Cron表达式参数分别表示:
秒(0~59) 例如0/5表示每5秒
分(0~59)
时(0~23)
日(0~31)的某天,需计算
月(0~11)
周几( 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT)
启动项目,执行结果如下:
SchedulerTask2 : 21:36:47.795008800 线程 : scheduling-1 SchedulerTask1 : 21:36:48.014888600 线程 : scheduling-1 SchedulerTask2 : 21:36:50.792887400 线程 : scheduling-1 SchedulerTask2 : 21:36:53.792697900 线程 : scheduling-1 SchedulerTask1 : 21:36:54.002684700 线程 : scheduling-1 SchedulerTask2 : 21:36:56.792517700 线程 : scheduling-1 SchedulerTask2 : 21:36:59.792606400 线程 : scheduling-1 SchedulerTask1 : 21:37:00.002598400 线程 : scheduling-1 SchedulerTask2 : 21:37:02.792423300 线程 : scheduling-1 SchedulerTask2 : 21:37:05.802238 线程 : scheduling-1 SchedulerTask1 : 21:37:06.002225200 线程 : scheduling-1
可以看到,当上面两个定时任务同时执行时,用的是同一个线程:scheduling-1,任务的执行时机会受上一个任务执行时间的影响。
注解方式-多线程
新建MultithreadScheduleTask类存放与task包下:
@Component @EnableAsync public class MultithreadScheduleTask { @Async @Scheduled(fixedDelay = 1000) public void first() throws InterruptedException { System.out.println("第一个定时任务开始 : " + LocalDateTime.now().toLocalTime() + " 线程 : " + Thread.currentThread().getName()); Thread.sleep(1000 * 10); } @Async @Scheduled(fixedDelay = 2000) public void second() { System.out.println("第二个定时任务开始 : " + LocalDateTime.now().toLocalTime() + " 线程 : " + Thread.currentThread().getName()); System.out.println(); } }
@EnableAsync:开启多线程
启动项目,运行结果如下:
第一个定时任务开始 : 21:48:47.121991300 线程 : task-1 第二个定时任务开始 : 21:48:47.121991300 线程 : task-2 第一个定时任务开始 : 21:48:48.121930600 线程 : task-3 第二个定时任务开始 : 21:48:49.114640 线程 : task-4 第一个定时任务开始 : 21:48:49.114640 线程 : task-5 第一个定时任务开始 : 21:48:50.119792400 线程 : task-6 第二个定时任务开始 : 21:48:51.119726900 线程 : task-7 第一个定时任务开始 : 21:48:51.129727800 线程 : task-8 第一个定时任务开始 : 21:48:52.130157200 线程 : task-2 第二个定时任务开始 : 21:48:53.120096500 线程 : task-4 第一个定时任务开始 : 21:48:53.140095 线程 : task-7 第一个定时任务开始 : 21:48:54.140429600 线程 : task-4 第二个定时任务开始 : 21:48:57.130710 线程 : task-1
代码注释
[!--zhushi--]