@Schedule注解实现定时任务,多线程执行定时任务,Cron表达式解读
使用@Schedule注解实现定时任务
1、首先linux定时执行php,在项目启动类上添加@EnableScheduling注解,开启对定时任务的支持。@EnableScheduling注解的作用是发觉注解@Scheduled的任务并在后台执行该任务。
@SpringBootApplication
@EnableScheduling
public class ScheduledApplication {
public static void main(String[] args) {
SpringApplication.run(ScheduledApplication.class, args);
}
}
2、编写定时任务类和技巧,定时任务类通过SpringIOC加载,使用@Component注解。
3、定时方式使用@Scheduled注解。下列代码中,fixedRate是long类型,表示任务执行的间隔微秒数,下边代码中的定时任务每3秒执行一次。
@Component
public class ScheduledTask {
@Scheduled(fixedRate = 3000)
public void scheduledTask() {
System.out.println("任务执行时间:" + LocalDateTime.now());
}
}
4、运行工程,项目启动和运行日志如下,可见每3秒复印一次日志执行记录。
Server is running ...
任务执行时间-ScheduledTask:2020-06-23T18:02:14.747
任务执行时间-ScheduledTask:2020-06-23T18:02:17.748
任务执行时间-ScheduledTask:2020-06-23T18:02:20.746
任务执行时间-ScheduledTask:2020-06-23T18:02:23.747
@Scheduled注解
在里面Demo中,使用了@Scheduled(fixedRate=3000)注解来定义每过3秒执行的任务。对于@Scheduled的使用可以总结如下几种方法。
@Scheduled(fixedRate=3000)上一次开始执行时间点以后3秒再执行(fixedRate
属性:定时任务开始后再度执行定时任务的延时(需等待下次定时任务完成),单位纳秒)。
@Scheduled(fixedDelay=3000)上一次执行完毕时间点过后3秒再执行(fixedDelay
属性:定时任务执行完成后再度执行定时任务的延时(需等待下次定时任务完成),单位纳秒)。
@Scheduled(initialDelay=1000,fixedRate=3000)第一次延后一秒后执行,然后按
fixedRate的规则每3秒执行一次(initialDelay属性:第一次执行定时任务的延后时间,需配合fixedDelay
或则fixedRate来使用)。
@Scheduled(cron="0021*?*")通过cron表达式定义规则。
关于「Corn表达式」,将在文末介绍。
多线程执行定时任务
import org.slf4j.LoggerFactory;
@Component
public class ScheduledTask {
private static final org.slf4j.Logger logger = LoggerFactory.getLogger(ScheduledTask.class);
@Scheduled(cron = "0/5 * * * * *")
public void scheduled(){
logger.info("使用cron---任务执行时间:{} 线程名称:{}",LocalDateTime.now(),Thread.currentThread().getName());
}
@Scheduled(fixedRate = 5000)
public void scheduled1() {
logger.info("fixedRate---任务执行时间:{} 线程名称:{}",LocalDateTime.now(),Thread.currentThread().getName());
}
@Scheduled(fixedDelay = 5000)
public void scheduled2() {
logger.info("fixedDelay---任务执行时间:{} 线程名称:{}",LocalDateTime.now(),Thread.currentThread().getName());
}
}
程序输出如下。
2020-06-23 23:31:04.447 INFO 34069 : fixedRate---任务执行时间:2020-06-23T23:31:04.447 线程名称:scheduling-1
2020-06-23 23:31:04.494 INFO 34069 : fixedDelay---任务执行时间:2020-06-23T23:31:04.494 线程名称:scheduling-1
2020-06-23 23:31:05.004 INFO 34069 : 使用cron---任务执行时间:2020-06-23T23:31:05.004 线程名称:scheduling-1
2020-06-23 23:31:09.445 INFO 34069 : fixedRate---任务执行时间:2020-06-23T23:31:09.445 线程名称:scheduling-1
2020-06-23 23:31:09.498 INFO 34069 : fixedDelay---任务执行时间:2020-06-23T23:31:09.498 线程名称:scheduling-1
2020-06-23 23:31:10.003 INFO 34069 : 使用cron---任务执行时间:2020-06-23T23:31:10.003 线程名称:scheduling-1
2020-06-23 23:31:14.444 INFO 34069 : fixedRate---任务执行时间:2020-06-23T23:31:14.444 线程名称:scheduling-1
2020-06-23 23:31:14.503 INFO 34069 : fixedDelay---任务执行时间:2020-06-23T23:31:14.503 线程名称:scheduling-1
2020-06-23 23:31:15.002 INFO 34069 : 使用cron---任务执行时间:2020-06-23T23:31:15.002 线程名称:scheduling-1
可以看见,3个定时任务都早已执行,而且使同一个线程中串行执行。当定时任务增多,假若一个任务卡死,会引起其他任务也难以执行。
因而,须要考虑多线程执行定时任务的情况。
1、创建配置类:在传统的Spring项目中linux系统镜像下载,我们可以在xml配置文件添加task的配置,而在SpringBoot项目中通常使用config配置类的形式添加配置,所以新建一个AsyncConfig类。在配置类中,使用@EnableAsync注解开启异步风波的支持。
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
@Configuration
@EnableAsync
public class AsyncConfig {
private int corePoolSize = 10;
private int maxPoolSize = 200;
private int queueCapacity = 10;
@Bean
public Executor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(maxPoolSize);
executor.setQueueCapacity(queueCapacity);
executor.initialize();
return executor;
}
}
@Configuration:表明该类是一个配置类
@EnableAsync:开启异步风波的支持
2、在定时任务的类或则方式上添加@Async注解,表示是异步风波的定时任务。
@Component
@Async
public class ScheduledTask {
private static final org.slf4j.Logger logger = LoggerFactory.getLogger(ScheduledTask.class);
@Scheduled(cron = "0/5 * * * * *")
public void scheduled(){
logger.info("使用cron 线程名称:{}",Thread.currentThread().getName());
}
@Scheduled(fixedRate = 5000)
public void scheduled1() {
logger.info("fixedRate--- 线程名称:{}",Thread.currentThread().getName());
}
@Scheduled(fixedDelay = 5000)
public void scheduled2() {
logger.info("fixedDelay 线程名称:{}",Thread.currentThread().getName());
}
}
3、运行程序,控制台输出如下,可以看见,定时任务是在多个线程中执行的。
2020-06-23 23:45:08.514 INFO 34824 : fixedRate--- 线程名称:taskExecutor-1
2020-06-23 23:45:08.514 INFO 34824 : fixedDelay 线程名称:taskExecutor-2
2020-06-23 23:45:10.005 INFO 34824 : 使用cron 线程名称:taskExecutor-3
2020-06-23 23:45:13.506 INFO 34824 : fixedRate--- 线程名称:taskExecutor-4
2020-06-23 23:45:13.510 INFO 34824 : fixedDelay 线程名称:taskExecutor-5
2020-06-23 23:45:15.005 INFO 34824 : 使用cron 线程名称:taskExecutor-6
2020-06-23 23:45:18.509 INFO 34824 : fixedRate--- 线程名称:taskExecutor-7
2020-06-23 23:45:18.511 INFO 34824 : fixedDelay 线程名称:taskExecutor-8
2020-06-23 23:45:20.005 INFO 34824 : 使用cron 线程名称:taskExecutor-9
2020-06-23 23:45:23.509 INFO 34824 : fixedRate--- 线程名称:taskExecutor-10
2020-06-23 23:45:23.511 INFO 34824 : fixedDelay 线程名称:taskExecutor-1
2020-06-23 23:45:25.005 INFO 34824 : 使用cron 线程名称:taskExecutor-2
2020-06-23 23:45:28.509 INFO 34824 : fixedRate--- 线程名称:taskExecutor-3
2020-06-23 23:45:28.512 INFO 34824 : fixedDelay 线程名称:taskExecutor-4
2020-06-23 23:45:30.005 INFO 34824 : 使用cron 线程名称:taskExecutor-5
2020-06-23 23:45:33.509 INFO 34824 : fixedRate--- 线程名称:taskExecutor-6
2020-06-23 23:45:33.513 INFO 34824 : fixedDelay 线程名称:taskExecutor-7
2020-06-23 23:45:35.005 INFO 34824 : 使用cron 线程名称:taskExecutor-8
...
Cron表达式
cron表达式是一个字符串,该字符串由6个空格分为7个域,每一个域代表一个时间含意。一般定义“年”的部份可以省略,实际常用的Cron表达式由前6部份组成。格式如下:
[秒][分][时][日][月][周][年]
须要说明的是,Cron表达式中,“周”是从周六开始估算的。“周”域上的1表示的是周末,7表示周日。
Cron中的键值
,:指的是在两个以上的时间点中都执行。假如在“分”这个域中定义为8,12,35,则表示分别在第8分,第12分,第35分执行该定时任务。
-:指定在某个域的连续范围。假如在“时”这个域中定义1-6,则表示在1到6点之每小时都触发一次雨林木风linux,等价于1,2,3,4,5,6。
*:表示所有值,可剖析为“每”。假如在“日”这个域中设置*linux定时执行php,表示每三天就会触发。
?:表示不指定值。使用的场景为不须要关心当前设置这个数组的值。诸如,要在每月的8号触发一个操作,但不关心是周几,我们可以如此设置0008*?。
/:表示触发步进(step),“/”前面的值代表初始值(“*”等同“0”),前面的值代表偏斜量,在某个域上周期性触发。例如在“秒”上定义5/10表示从第5秒开始,每10秒执行一次;而在“分”上则表示从第5分钟开始,每10分钟执行一次。
L:表示英语中的LAST的意思,只能在“日”和“周”中使用。在“日”中设置,表示当月的最后三天(根据当前月份,倘若是五月都会根据是否是润年),在“周”上表示周日,相当于“7”或
“SAT”。假如在“L”前加上数字,则表示该数据的最后一个。诸如在“周”上设置“7L”这样的格式,则表示“本月最后一个周日”。
W:表示离指定日期的近来那种工作日(周三至周日)触发,只能在“日”中使用且只能用在具体的数字以后。若在“日”上置“15W”,表示离每月15号近来的那种工作日触发。如果15号刚好是周末,则找近来的周日(14号)触发;假如15号是周未,则找近来的明天一(16号)触发;假如15号刚好在工作日(周三至周日),则就在该天触发。假如是"1W"就只能往本月的下一个近来的工作日推不能跨月往上一个月推。
#:比如,A#B表示每月的第B个周的周A(周的计数从周六开始),只能作用于“周”上。诸如2#3表示在每月的第3个周六,5#3表示本月第3周的礼拜四。
注意,L用在“周”这个域上,每周最后三天是周末。“周”域上的1表示的是周末,7表示周日,即每周计数是从周六开始的。
记录文章地址:
本文原创地址://q13zd.cn/dxczxdsrwcbd.html编辑:刘遄,审核员:暂无