在spring boot中教沾，簡(jiǎn)單的任務(wù)調(diào)度工作可以由@Scheduled注解來完成沾瓦。

如果需要深入了解spring的調(diào)度心铃，最好的方式是先看下官方文檔准谚。

一、Spring的任務(wù)抽象接口

TaskExecutor接口

TaskExecutor是任務(wù)執(zhí)行接口去扣，類似于java.util.concurrent.Executor柱衔，該接口只有一個(gè)方法execute(Runnable task)，用于執(zhí)行任務(wù)厅篓。

Spring提供了一組TaskExecutor的實(shí)現(xiàn)秀存，基本上能滿足所有的需求。它們的使用方式跟普通的Spring Bean一樣羽氮。

TaskScheduler接口

TaskScheduler接口是定時(shí)器的抽象或链，它的源代碼如下〉笛海可以看到澳盐，該接口包含了一組方法用于指定任務(wù)執(zhí)行的時(shí)間。

public interface TaskScheduler {

    ScheduledFuture schedule(Runnable task, Trigger trigger);

    ScheduledFuture schedule(Runnable task, Date startTime);

    ScheduledFuture scheduleAtFixedRate(Runnable task, Date startTime, long period);

    ScheduledFuture scheduleAtFixedRate(Runnable task, long period);

    ScheduledFuture scheduleWithFixedDelay(Runnable task, Date startTime, long delay);

    ScheduledFuture scheduleWithFixedDelay(Runnable task, long delay);

}

二令宿、實(shí)操

2.1叼耙、定時(shí)任務(wù)

具體步驟如下：

1. 在應(yīng)用入口增加@EnableScheduling

@SpringBootApplication
@EnableScheduling
public class Application {

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

如果應(yīng)用依賴了spring-boot-starter-actuator，即使沒有聲明@EnableScheduling粒没，調(diào)度任務(wù)也會(huì)被執(zhí)行筛婉。因?yàn)?code>spring-boot-starter-actuator本身也聲明了@EnableScheduling，見MetricExportAutoConfiguration癞松。

2. 增加任務(wù)調(diào)度服務(wù)

@Component // 或@Service
public class TaskService {

    @Scheduled(fixedRate = 1000) // 每隔1秒執(zhí)行一次
    public void timerRate() {
        // 在此處執(zhí)行調(diào)度任務(wù)爽撒。
    }
}

@Scheduled 注解主要使用在執(zhí)行調(diào)度任務(wù)的方法上入蛆。

注意！Springboot 默認(rèn)的執(zhí)行方式是串行執(zhí)行硕勿，無論有多少task（@Scheduled）哨毁，都是一個(gè)線程串行執(zhí)行。同一個(gè)task源武，如果前一個(gè)還沒跑完后面一個(gè)就不會(huì)觸發(fā)扼褪，不同的task也不能同時(shí)運(yùn)行，這是因?yàn)閟cheduler的默認(rèn)線程數(shù)為1的緣故粱栖。

在高可用的情況下话浇，如果微服務(wù)有多個(gè)實(shí)例，scheduler會(huì)在多個(gè)實(shí)例上同時(shí)運(yùn)行查排。

2.2凳枝、并行任務(wù)

在上面的基礎(chǔ)上，增加一個(gè)實(shí)現(xiàn)SchedulingConfigurer接口的類：

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {

    private final int POOL_SIZE = 10;
 
    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();

        threadPoolTaskScheduler.setPoolSize(POOL_SIZE);
        // 線程前綴
        threadPoolTaskScheduler.setThreadNamePrefix("my-scheduled-task-pool-");
        threadPoolTaskScheduler.initialize();

        scheduledTaskRegistrar.setTaskScheduler(threadPoolTaskScheduler);
    }

  /*  @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskExecutor());
    }
 
    @Bean(destroyMethod="shutdown")
    public Executor taskExecutor() {
        return Executors.newScheduledThreadPool(POOL_SIZE); // 線程池初始化10個(gè)線程
    }*/
}

如果在調(diào)度方法里打印當(dāng)前線程名稱：

Current Thread : my-scheduled-task-pool-1
Current Thread : my-scheduled-task-pool-2
...

配置多個(gè)線程會(huì)導(dǎo)致同一個(gè)task前一個(gè)還沒跑完后面又被觸發(fā)的問題跋核。

附錄1岖瑰、@Scheduled中的參數(shù)

(1) cron：cron表達(dá)式，指定任務(wù)在特定時(shí)間執(zhí)行;
(2) fixedDelay：表示上一次任務(wù)執(zhí)行完成后多久再次執(zhí)行砂代，參數(shù)類型為long蹋订，單位ms;
(3) fixedDelayString：與fixedDelay含義一樣，只是參數(shù)類型變?yōu)镾tring;
(4) fixedRate：表示按一定的頻率執(zhí)行任務(wù)刻伊，參數(shù)類型為long露戒，單位ms;
(5) fixedRateString: 與fixedRate的含義一樣，只是將參數(shù)類型變?yōu)镾tring;
(6) initialDelay：表示延遲多久再第一次執(zhí)行任務(wù)捶箱，參數(shù)類型為long智什，單位ms;
(7) initialDelayString：與initialDelay的含義一樣，只是將參數(shù)類型變?yōu)镾tring;
(8) zone：時(shí)區(qū)丁屎，默認(rèn)為當(dāng)前時(shí)區(qū)荠锭，一般沒有用到。

例子：

• @Scheduled(fixedRate=1000)： 上一次開始執(zhí)行后1秒再次執(zhí)行晨川；
• @Scheduled(fixedDelay=1000)：上一次執(zhí)行完成后1秒再次執(zhí)行证九；
• @Scheduled(initialDelay=1000, fixedDelay=3000)：第一次延遲1秒執(zhí)行，然后在上一次執(zhí)行完成后3秒再次執(zhí)行共虑；
• @Scheduled(cron="* * * * * ?")：按cron表達(dá)式執(zhí)行愧怜。

附錄2、CRON表達(dá)式

Cron格式

Quartz的官方文檔

一個(gè) Cron表達(dá)式是由6或7個(gè)字段(年字段是可選字段)的字符串組成妈拌，字段與字段之間用空格來隔開拥坛。
Cron表達(dá)式使用格式：

各個(gè)域的定義：

特殊符號(hào)代表的含義：

CRON表達(dá)式官方例子