快捷導(dǎo)航

springBoot?@Scheduled實(shí)現(xiàn)多個(gè)任務(wù)同時(shí)開(kāi)始執(zhí)行

更新時(shí)間：2021年12月28日 16:45:17 作者：李振偉

這篇文章主要介紹了springBoot?@Scheduled實(shí)現(xiàn)多個(gè)任務(wù)同時(shí)開(kāi)始執(zhí)行，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

@Scheduled多個(gè)任務(wù)同時(shí)開(kāi)始執(zhí)行

只需在springBoot啟動(dòng)類上添加

如下代碼即可：

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

在這里插入圖片描述

@Scheduled多定時(shí)任務(wù)，重疊執(zhí)行

@Scheduled如果有兩個(gè)定時(shí)任務(wù)

定時(shí)任務(wù)重復(fù)時(shí)，只有一個(gè)可以執(zhí)行。

如下

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("當(dāng)前時(shí)間:"+LocalDateTime.now()+"  任務(wù)execute1對(duì)應(yīng)的線程名: "+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("當(dāng)前時(shí)間:"+LocalDateTime.now()+"  任務(wù)execute2對(duì)應(yīng)的線程名: "+curName);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

通過(guò)執(zhí)行可以看到，打印線程名稱為同一個(gè)。即如果不手動(dòng)指定線程池，則默認(rèn)啟動(dòng)單線程，進(jìn)行執(zhí)行定時(shí)任務(wù)。

如果想要多個(gè)定時(shí)任務(wù)重疊執(zhí)行

需要手動(dòng)指定線程池，如下

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("當(dāng)前時(shí)間:"+LocalDateTime.now()+"  任務(wù)execute1對(duì)應(yīng)的線程名: "+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("當(dāng)前時(shí)間:"+LocalDateTime.now()+"  任務(wù)execute2對(duì)應(yīng)的線程名: "+curName);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

此時(shí)，多個(gè)定時(shí)任務(wù)，是不通的線程執(zhí)行，同時(shí)，定時(shí)任務(wù)可以重疊執(zhí)行。

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: