任务调度SpringTask

一、任务调度的概念

  在企业级应用中,会经常指定一些计划任务,即在某个时间点做某件事情,核心是以时间为关注点,即在一个特定的时间点,系统执行特定的一个操作,常见的任务调度框架有Quartz和SpringTask等。其中SpringTask是spring在spring3后自带支持的定时任务。下面的demo讲述的就是SpringTask。

二、入门demo

  2.1 创建SpringBoot工程 -- pom.xml上加上SpringBoot的基本依赖

  • 在启动类上加上注解:@EnableScheduling
  • 在需要执行定时任务的方法上加上@Scheduled(cron = "* * * * * ?")表示执行定时任务的周期
1 @EnableScheduling
2 @SpringBootApplication
3 public class SpringTaskApplication {
4 
5     public static void main(String[] args) {
6         SpringApplication.run(SpringTaskApplication.class, args);
7     }
8 }
 1 @Component
 2 public class SpringTaskDemo {
 3     /**
 4      * 定时刷新
 5      */
 6     /**
 7      * @Scheduled(fixedRate = 5000) //上次执行开始时间后5秒执行
 8      * @Scheduled(fixedDelay = 5000)  //上次执行完毕后5秒执行
 9      * @Scheduled(initialDelay=3000, fixedRate=5000) //第一次延迟3秒,以后每隔5秒执行一次
10      */
11     @Scheduled(cron = "* * * * * ?")
12     public void task01() throws InterruptedException {
13         System.out.println("开始执行了任务调度task01" + new Date());
14         Thread.sleep(5000);
15         System.out.println("结束执行了任务调度task01" + new Date());
16     }
17 }

  注:上面的任务执行打印开始结束,以及中间的线程休眠时间,主要是为了展示串行并行过程的效果。

  • 执行引导类的main方法,控制台打印消息

  2.2 Cron表达式

  格式:Cron表达式是一个字符串,字符串以5或6个空格隔开,分为6或7个域,每一个域代表一个含义,Cron有如下两种语法格式:

  (1)Seconds Minutes Hours DayofMonth Month DayofWeek Year

  (2)Seconds Minutes Hours DayofMonth Month DayofWeek

  每一个域可出现的字符如下:

  Seconds:可出现", - * /"四个字符,有效范围为0-59的整数

  Minutes:可出现", - * /"四个字符,有小范围为0-59的整数

  Hours:可出现", - * /"四个字符,有效范围为0-23的整数

  DayofMonth:可出现", - * / ? L W C"八个字符,有效范围为1-31的整数

  Month:可出现", - * /"四个字符,有效范围为1-12的整数或JAN-DEC(月份的简称)

  DayofWeek:可出现", - * / ? L C #"八个字符,有效范围为1-7的整数或SUN-SAT(星期的简称)两个范围,1表示星期天,2表示星期一,依次类推

  YEAR:可出现", - * /"四个字符,有效范围是1970-2099年

  (1),:表示列出枚举值,例如,在Minutes域使用"5,20"。则意味着在5和20分每分钟触发一次;

  (2)-:表示范围,例如在Minutes域使用"5-20",表示从5分到20分每分钟触发一次;

  (3)*:表示匹配该域的任意值,假如在Minutes域中使用"*“,表示每分钟都会触发事件;

  (4)/:表示起始时间开始触发,然后每隔固定时间触发一下,例如在Minutes域中使用5/20,则意味着第5分钟触发一次,然后第25分,45分触发一次;

-----------------------------以下符号只能出现在DayofMonth和DayofWeek两个域-----------------------------

  (5)?:它也匹配任意值,但其实不会。因为DayofMonth和DayofWeek会相互影响。例如想在每月的20日触发调度,不管是20日到底是星期几,两个位置当一个位置取一个特定含义的值后另外一个位置只能用?占位,例如:12 12 15 20 * ?;

  (6)L:表示最后,例如在DayofWeek域使用5L,意味着在最后的一个星期四触发;

---------------------------------------------------------分割线---------------------------------------------------------

  (7)W:表示有效工作日(周一到周五),只能出现在DayofMonth域中,系统将在离指定日期的最近的有效工作日触发事件。例如:在DayofMonth使用5W,如果5日是星期六,则在最近的工作日:星期五,即4日触发。如果5日是星期天,则在6日(周一)触发;如果5日在星期一到周五中的一天,,则就在5日触发。另外一点,W的最近寻找不会跨过月份;

  (8)#:用于确定第几个月的第几个星期几,只能出现在DayofWeek域,例如:4#2,表示某月的第二个星期三。

   2.3 串行化任务

  参看task01定义task02方法,此时任务公用两个任务方法

 1     /**
 2      * 上次执行开始时间后5秒执行
 3      * @throws InterruptedException
 4      */
 5     @Scheduled(fixedRate = 5000)
 6     public void task02() throws InterruptedException {
 7         System.out.println("开始执行了任务调度task02" + new Date());
 8         Thread.sleep(5000);
 9         System.out.println("结束执行了任务调度task02" + new  Date());
10     }

  测试发现,两个方法由一个线程串行执行,task01方法执行完成task02再执行

  2.4 并行任务

  我们发现有时候在项目中我们需要多个不同的任务并行的执行,下面执行配置线程池实现多线程调度任务。取消SpringBoot启动类上的@EnableScheduling注解

 1 @Configuration
 2 @EnableScheduling
 3 public class SpringTaskParallelDemo implements SchedulingConfigurer,AsyncConfigurer{
 4     @Bean
 5     public ThreadPoolTaskScheduler taskScheduler(){
 6         ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
 7         // 初始化线程池
 8         scheduler.initialize();
 9         // 线程池容量
10         int corePoolSize = 5;
11         scheduler.setPoolSize(corePoolSize);
12         return scheduler;
13     }
14 
15     @Override
16     public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
17         scheduledTaskRegistrar.setTaskScheduler(taskScheduler());
18     }
19 
20     @Override
21     public Executor getAsyncExecutor() {
22         return taskScheduler();
23     }
24 
25     @Override
26     public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
27         return null;
28     }
29 }

  测试,发现两个任务由不同的线程并行执行,互不影响。

如发现有错误欢迎指正,欢迎交流,接受反驳。 -- by不为 :)
原文地址:https://www.cnblogs.com/buwei/p/10125242.html