解决多个@Scheduled定时任务执行时个别不执行问题
作者：在代码的路上奔跑
这篇文章主要介绍了解决多个@Scheduled定时任务执行时个别不执行问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
多个@Scheduled定时任务执行时个别不执行
原因
项目在启动时，如果没有指定线程池的大小，默认会创建核心线程数为1的默认线程池，故而当项目中出现多个@Scheduled线程时，只能一个个的执行，从而导致个别线程执行时间过长(或长期执行)时，其他定时器不能按照指定的规则进行执行。
解决办法
1、配置执行线程池的大小
spring.task.scheduling.pool.size=10
2.将定时器设置为异步线程
/**
异步线程
定时器延迟1秒启动，每距上一次执行完成后间隔3秒执行一次
*/
@Async(“taskExecutor”)
@Scheduled(initialDelay = 1000L, fixedDelay = 3000L)
public void test(){System.out.println(“—”+System.currentTimeMillis());//业务内容
}@Scheduled多定时任务，重叠执行
@Scheduled如果有两个定时任务，定时任务重复时，只有一个可以执行。如下
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
@Component
public class MyScheduled {
@Scheduled(cron = "0/5 * * * * ?")
public void execute1(){
String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute1对应的线程名: "+curName);
try {
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
}
}
@Scheduled(cron = "0/5 * * * * ?")
public void execute2(){
String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute2对应的线程名: "+curName);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}通过执行可以看到，打印线程名称为同一个。即如果不手动指定线程池，则默认启动单线程，进行执行定时任务。
如果想要多个定时任务重叠执行，需要手动指定线程池，如下
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
@Component
@EnableScheduling
public class MyScheduled {
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(50);
return taskScheduler;
}
@Scheduled(cron = "0/5 * * * * ?")
public void execute1(){
String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute1对应的线程名: "+curName);
try {
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
}
}
@Scheduled(cron = "0/5 * * * * ?")
public void execute2(){
String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute2对应的线程名: "+curName);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}此时，多个定时任务，是不通的线程执行，同时，定时任务可以重叠执行。
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。