@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 ...
任务执行时间-ScheduledTask2020-06-23T18:02:14.747
任务执行时间-ScheduledTask2020-06-23T18:02:17.748
任务执行时间-ScheduledTask2020-06-23T18:02:20.746
任务执行时间-ScheduledTask2020-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

linux 定时执行脚本_linux定时执行python脚本_linux定时执行php脚本

或则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个定时任务都早已执行,而且使同一个线程中串行执行。当定时任务增多,假若一个任务卡死,会引起其他任务也难以执行。

linux 定时执行脚本_linux定时执行php脚本_linux定时执行python脚本

因而,须要考虑多线程执行定时任务的情况。

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编辑:刘遄,审核员:暂无