第@Scheduled注解不能同時執(zhí)行多個定時任務(wù)的解決方案目錄@Scheduled注解不能同時執(zhí)行多個定時任務(wù)@Scheduled同時執(zhí)行多個定時任務(wù)所導(dǎo)致的并發(fā)問題@Scheduled的執(zhí)行順序@Scheduled同步控制定時任務(wù)的執(zhí)行順序

@Scheduled注解不能同時執(zhí)行多個定時任務(wù)

最近在使用定時任務(wù)的時候發(fā)現(xiàn)，自己寫的定時任務(wù)沒有執(zhí)行，后來查了上網(wǎng)查了一下，才知道@Scheduled注解的定時任務(wù)是單線程的，同一時間段內(nèi)只能執(zhí)行一個定時任務(wù)，其它定時任務(wù)不執(zhí)行。

需要配置@Scheduled多線程支持，才能實現(xiàn)同一時間段內(nèi)，執(zhí)行多個定時任務(wù)。

一般情況下面兩個定時任務(wù)只會執(zhí)行第一個定時任務(wù)，第二個定時任務(wù)不會執(zhí)行。

/**

*測試定時任務(wù)1每天22:00:00執(zhí)行

*/

@Scheduled(cron="0022**")

publicvoidtest(){

for(inti=0;ii++){

try{

Thread.sleep(1000*10);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("=======================測試定時任務(wù)執(zhí)行1=======================");

}

}

/**

*測試定時任務(wù)2每天22:10:00執(zhí)行

*/

@Scheduled(cron="01022**")

publicvoidtest2(){

for(inti=0;ii++){

try{

Thread.sleep(1000*10);

}catch(InterruptedExceptione){

e.printStackTrace();

}

System.out.println("=======================測試定時任務(wù)執(zhí)行2=======================");

}

}

要解決上訴問題，就需要配置@Scheduled多線程支持，添加一個配置類，代碼如下：

/**

*@description:使@schedule支持多線程的配置類

*@author:DavidAllen

*@create:2025-12-08

@Configuration

publicclassScheduleConfigimplementsSchedulingConfigurer{

@Override

publicvoidconfigureTasks(ScheduledTaskRegistrartaskRegistrar){

Method[]methods=Job.class.getMethods();

intdefaultPoolSize=3;

intcorePoolSize=0;

if(!CollectionUtils.isEmpty(Arrays.asList(methods))){

for(Methodmethod:methods){

Scheduledannotation=method.getAnnotation(Scheduled.class);

if(annotation!=null){

corePoolSize++;

}

}

if(defaultPoolSizecorePoolSize){

corePoolSize=defaultPoolSize;

}

taskRegistrar.setScheduler(Executors.newScheduledThreadPool(corePoolSize));

}

}

}

@Scheduled同時執(zhí)行多個定時任務(wù)所導(dǎo)致的并發(fā)問題

@Scheduled的執(zhí)行順序

@Scheduled注解會在默認(rèn)情況下以單線程的方式執(zhí)行定時任務(wù)。

這個單線程指兩個方面：

如果一個定時任務(wù)執(zhí)行時間大于其任務(wù)間隔時間，那么下一次將會等待上一次執(zhí)行結(jié)束后再繼續(xù)執(zhí)行。如果多個定時任務(wù)在同一時刻執(zhí)行，任務(wù)會依次執(zhí)行。

那么這種效果肯定不是我們想要的，為了使@Scheduled效率更高，我們可以通過兩種方法將定時任務(wù)變成多線程執(zhí)行：

1、在啟動類中配置TaskScheduler線程池大小

@Bean

publicTaskSchedulertaskScheduler(){

ThreadPoolTaskSchedulertaskScheduler=newThreadPoolTaskScheduler();

taskScheduler.setPoolSize(50);

returntaskScheduler;

}

2、利用Spring提供的@Async注解和@EnableAsync注解

@Component

@EnableAsync

publicclassTimedTask{

@Async

@Scheduled(cron="00/1***")//每一分鐘執(zhí)行一次

publicvoidtaskA(){

//執(zhí)行你的業(yè)務(wù)邏輯

}

@Async

@Scheduled(cron="00/1***")//每一分鐘執(zhí)行一次

publicvoidtaskB(){

//執(zhí)行你的業(yè)務(wù)邏輯

}

通過以上方式，定時任務(wù)將會以多線程的方式開始執(zhí)行，減小了程序耦合度，提升運行效率。

@Scheduled同步

定時任務(wù)在同一時刻開始執(zhí)行有兩種情況：

多個任務(wù)的間隔時間相同，如都是1分鐘執(zhí)行一次，那么每一分鐘，這些任務(wù)都會一起執(zhí)行。多個任務(wù)的間隔時間不同，但有重合的時刻。如一個任務(wù)每天零點執(zhí)行，另一個任務(wù)每一分鐘執(zhí)行，那么這兩個任務(wù)在零點的時刻會一起執(zhí)行。

由于任務(wù)都是異步的，如果多個任務(wù)同時操作同一資源，那么必然會導(dǎo)致錯誤。

這個時候可以給任務(wù)加鎖，保證任務(wù)互不干擾，擁有在同一時刻執(zhí)行的線程安全：

@Component

@EnableAsync

publicclassTimedTask{

privateObjectlock=newObject();

@Async

@Scheduled(cron="000**")//每天零點執(zhí)行

publicvoidtaskA(){

synchronized(lock){

//執(zhí)行你的業(yè)務(wù)邏輯

}

}

@Async

@Scheduled(cron="00/1***")//每一分鐘執(zhí)行一次

publicvoidtaskB(){

synchronized(lock){

//執(zhí)行你的業(yè)務(wù)邏輯

}

}

控制定時任務(wù)的執(zhí)行順序

如果對執(zhí)行順序有要求的定時任務(wù)，有如下兩種情況：

1、在某一時刻同時執(zhí)行

如任務(wù)A在零點初始化數(shù)據(jù)，任務(wù)B每分