springBoot @Scheduled實現多個任務同時開始執行

Posted on by

@Scheduled多個任務同時開始執行

隻需在springBoot啟動類上添加

如下代碼即可：

	@Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskExecutor = new ThreadPoolTaskScheduler();
        taskExecutor.setPoolSize(50);
        return taskExecutor;
    }

在這裡插入圖片描述

@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();
        }
    }
}

此時，多個定時任務，是不通的線程執行，同時，定時任務可以重疊執行。

以上為個人經驗，希望能給大傢一個參考，也希望大傢多多支持WalkonNet。

推薦閱讀：