多线程执行定时任务，Cron表达式详解使用

@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

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表示周日，即每周计数是从周六开始的。

记录文章地址：

本文原创地址：https://www.linuxprobe.com/dxczxdsrwcbd.html编辑：刘遄，审核员：暂无

多线程执行定时任务，Cron表达式详解使用

多线程执行定时任务，Cron表达式详解使用

为您推荐一些与本文相关的文章：