快捷導(dǎo)航

SpringBoot定時(shí)任務(wù)+自定義線程池實(shí)踐

更新時(shí)間：2026年05月08日 16:39:36 作者：god-jiang

文章介紹了SpringBoot中使用@Schedule注解實(shí)現(xiàn)定時(shí)任務(wù)的方法,包括四種定時(shí)任務(wù)格式和Cron表達(dá)式,同時(shí),還探討了@Schedule默認(rèn)線程池大小為1的情況及解決方案,即通過(guò)@Async注解實(shí)現(xiàn)異步處理和手動(dòng)實(shí)現(xiàn)自定義線程池進(jìn)行優(yōu)化

背景

在真實(shí)的Java開(kāi)發(fā)環(huán)境中，我們經(jīng)常會(huì)需要用到定時(shí)任務(wù)來(lái)幫助我們完成一些特殊的任務(wù)，比如我最近寫的晚上11點(diǎn)定時(shí)拉取第三方的數(shù)據(jù)入庫(kù)，晚上12點(diǎn)清理臟數(shù)據(jù)等等。

如果我們使用SpringBoot來(lái)開(kāi)發(fā)，那么定時(shí)任務(wù)將會(huì)變得非常簡(jiǎn)單。SpringBoot默認(rèn)已經(jīng)幫我們封裝好了相關(guān)定時(shí)任務(wù)的組件和配置，我們只需要在相應(yīng)的地方加上@Schedule注解就可以實(shí)現(xiàn)定時(shí)任務(wù)。

啟動(dòng)定時(shí)任務(wù)

SpringBoot項(xiàng)目只需要在啟動(dòng)類上加上@EnableScheduling即可開(kāi)啟定時(shí)任務(wù)

@SpringBootApplication
@EnableScheduling
public class ScheduleTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(ScheduleTestApplication.class, args);
    }

}

創(chuàng)建定時(shí)任務(wù)

SpringBoot的Scheduler支持四種定時(shí)任務(wù)格式

fixedRate：固定速率執(zhí)行，例如每3秒執(zhí)行一次
fixedDelay：固定延遲執(zhí)行，例如距離上一次調(diào)用成功后3秒執(zhí)行
initialDelay：初始延遲任務(wù)，例如任務(wù)開(kāi)啟過(guò)3秒后再執(zhí)行，之后以固定頻率或者間隔執(zhí)行
cron：使用 Cron 表達(dá)式執(zhí)行定時(shí)任務(wù)

以上在企業(yè)開(kāi)發(fā)中經(jīng)常用到的是cron表達(dá)式，可以說(shuō)掌握了cron表達(dá)式，基本就掌握了SpringBoot的定時(shí)任務(wù)了。

使用cron表達(dá)式

@Component
public class ScheduleTask {

    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    //每隔5秒執(zhí)行一次該方法
    @Scheduled(cron = "*/5 * * * * ?")
    public void testScheduleTask() {
        System.out.println("SpringBoot的定時(shí)任務(wù)" + Thread.currentThread().getName() + sdf.format(new Date()));
    }

}

@Schedule默認(rèn)線程池大小

其實(shí)@Schedule默認(rèn)線程池大小為1，我們可以下面的實(shí)驗(yàn)得出這個(gè)結(jié)論。

@Component
public class ScheduleTask {

    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    //固定2秒執(zhí)行一次該方法
    @Scheduled(fixedRate = 2000)
    public void testScheduleTask() {
        try{
            Thread.sleep(6000);
            System.out.println("SpringBoot的定時(shí)任務(wù)" + Thread.currentThread().getName() + sdf.format(new Date()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

結(jié)果每隔6秒執(zhí)行一次，可以看到線程的名字為scheduleing-12021-01-12，表示都是用的同一個(gè)線程，默認(rèn)@Schedule是開(kāi)啟一個(gè)線程。

一般情況下使用默認(rèn)@Schedule沒(méi)有問(wèn)題，但是如果有多個(gè)定時(shí)任務(wù)，每個(gè)定時(shí)任務(wù)執(zhí)行時(shí)間可能不短的情況下，會(huì)有可能出現(xiàn)定時(shí)任務(wù)一直沒(méi)有機(jī)會(huì)執(zhí)行的情況。

異步執(zhí)行定時(shí)任務(wù)

給該方法加上@Async進(jìn)行異步處理，看看會(huì)是什么效果～

@Component
@EnableAsync
public class ScheduleTask {

    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    @Async
    @Scheduled(fixedRate = 2000)
    public void testScheduleTask() {
        try{
            Thread.sleep(6000);
            System.out.println("SpringBoot的定時(shí)任務(wù)" + Thread.currentThread().getName() + sdf.format(new Date()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

可以看出線程的名字都是不一樣的，然后每隔2秒的執(zhí)行一次該方法，異步處理不受方法內(nèi)的時(shí)間影響，并行執(zhí)行。

手動(dòng)實(shí)現(xiàn)自定義任務(wù)線程池

雖然可以用SpringBoot提供給我們的異步注解@Async處理，但是我們開(kāi)發(fā)者也可以手動(dòng)實(shí)現(xiàn)一個(gè)線程池，更好的配置和使用我們的異步處理。

@Component
public class AsyncScheduledTaskConfig {

    @Bean
    public Executor myAsync() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //最大線程數(shù)
        executor.setMaxPoolSize(100);
        //核心線程數(shù)
        executor.setCorePoolSize(10);
        //任務(wù)隊(duì)列的大小
        executor.setQueueCapacity(10);
        //線程前綴名
        executor.setThreadNamePrefix("god-jiang-");
        //線程存活時(shí)間
        executor.setKeepAliveSeconds(30);

        /**
         * 拒絕處理策略
         * CallerRunsPolicy()：交由調(diào)用方線程運(yùn)行，比如 main 線程。
         * AbortPolicy()：直接拋出異常。
         * DiscardPolicy()：直接丟棄。
         * DiscardOldestPolicy()：丟棄隊(duì)列中最老的任務(wù)。
         */
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
        //線程初始化
        executor.initialize();
        return executor;
    }
}

使用自定義的線程池實(shí)現(xiàn)異步處理

@Component
@EnableAsync
public class ScheduleTask {

    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    @Async("myAsync")
    @Scheduled(fixedRate = 2000)
    public void testScheduleTask() {
        try{
            Thread.sleep(6000);
            System.out.println("SpringBoot的定時(shí)任務(wù)" + Thread.currentThread().getName() + sdf.format(new Date()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}