Spring的任務調度@Scheduled注解——task:scheduler和task:executor的解析

applicationContext 的配置如下:

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd"xmlns:task="http://www.springframework.org/schema/task"><context:annotation-config /><task:annotation-driven scheduler="myScheduler" executor="myExecutor"/><!-- 調度線程池配置 --><task:scheduler id="myScheduler" pool-size="5"/><!-- 執行線程池配置 --><task:executor id="myExecutor" pool-size="5"/><context:component-scan base-package="com.zaimeibian" /></beans> package com.zaimeibian.task;import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date;import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component;@Component public class PrintTask {DateFormat df = new SimpleDateFormat("HH:mm:ss");// 這個Async注解，代表當前任務是要異步執行的@Async@Scheduled(fixedRate = 5000)public void printA(){System.out.println("A執行 " + df.format(new Date()));try {Thread.sleep(10000);} catch (InterruptedException e) {}System.out.println("A打印輸出 " + df.format(new Date())+ Thread.currentThread());}@Scheduled(fixedRate = 5000)public void printB(){System.out.println("B執行 " + df.format(new Date()));try {Thread.sleep(10000);} catch (InterruptedException e) {}System.out.println("B打印輸出 " + df.format(new Date())+ Thread.currentThread());}@Scheduled(fixedRate = 5000)public void printC(){System.out.println("C執行 " + df.format(new Date()));try {Thread.sleep(10000);} catch (InterruptedException e) {}System.out.println("C打印輸出 " + df.format(new Date())+ Thread.currentThread());}// 配置initialDelay的任務是在容器啟動后延遲一定時間才開始調度@Scheduled(fixedRate = 5000, initialDelay=1000)public void printD(){System.out.println("D執行 " + df.format(new Date()));try {Thread.sleep(30000);} catch (InterruptedException e) {}System.out.println("D打印輸出 " + df.format(new Date())+ Thread.currentThread());}// 配置initialDelay的任務是在容器啟動后延遲一定時間才開始調度@Scheduled(fixedRate = 5000, initialDelay=1000)public void printE(){System.out.println("E執行 " + df.format(new Date()));try {Thread.sleep(30000);} catch (InterruptedException e) {}System.out.println("E打印輸出 " + df.format(new Date())+ Thread.currentThread());}}

這里，fixDelay 和 fixRate 參數代表每個任務，前者在上一個任務調度完成后，延遲一定的時間執行。而后者可以在每間隔一定時間就執行新任務（但這里與 executor 的參數有關）。下面的試驗會詳細說明這兩個參數。
Spring 的任務調度線程池，即

<task:scheduler id="myScheduler" pool-size="5"/>

如果不配置，那么默認值是 1 ，即結果是所有聲明的任務，都是串行執行的，比如代碼中的 A/B/C/D/E 五個任務，在默認值是 1 的情況下，只能一個個串行來執行。不能出現并行的情況。
可以將參數改為 1 ，運行，輸出如下：

B執行 12:16:36 B打印輸出 12:16:46Thread[myScheduler-1,5,main] A執行 12:16:46 A打印輸出 12:16:56Thread[myScheduler-1,5,main] C執行 12:16:56 C打印輸出 12:17:06Thread[myScheduler-1,5,main] D執行 12:17:06 D打印輸出 12:17:36Thread[myScheduler-1,5,main] E執行 12:17:36 E打印輸出 12:18:06Thread[myScheduler-1,5,main] B執行 12:18:06 B打印輸出 12:18:16Thread[myScheduler-1,5,main] A執行 12:18:16 A打印輸出 12:18:26Thread[myScheduler-1,5,main] C執行 12:18:26 C打印輸出 12:18:36Thread[myScheduler-1,5,main] D執行 12:18:36 D打印輸出 12:19:06Thread[myScheduler-1,5,main] E執行 12:19:06 E打印輸出 12:19:36Thread[myScheduler-1,5,main] B執行 12:19:36 B打印輸出 12:19:46Thread[myScheduler-1,5,main] A執行 12:19:46 A打印輸出 12:19:56Thread[myScheduler-1,5,main]

可以看到只有 myScheduler-1 這一個調度線程來調度這五個任務，任務之間只能串行，即等待上個任務完成后釋放調度線程，然后調度線程才能調度執行下一個任務。

然后我們還改回調度線程池 5 個線程池大小，運行：

C執行 12:23:04 A執行 12:23:04 B執行 12:23:04 E執行 12:23:05 D執行 12:23:05 C打印輸出 12:23:14Thread[myScheduler-2,5,main] C執行 12:23:14 A打印輸出 12:23:14Thread[myScheduler-3,5,main] A執行 12:23:14 B打印輸出 12:23:14Thread[myScheduler-1,5,main] B執行 12:23:14 C打印輸出 12:23:24Thread[myScheduler-2,5,main] C執行 12:23:24 A打印輸出 12:23:24Thread[myScheduler-3,5,main] A執行 12:23:24 B打印輸出 12:23:24Thread[myScheduler-1,5,main] B執行 12:23:24 C打印輸出 12:23:34Thread[myScheduler-2,5,main] A打印輸出 12:23:34Thread[myScheduler-3,5,main] C執行 12:23:34 A執行 12:23:34 B打印輸出 12:23:34Thread[myScheduler-1,5,main] B執行 12:23:34 E打印輸出 12:23:35Thread[myScheduler-4,5,main] E執行 12:23:35 D打印輸出 12:23:35Thread[myScheduler-5,5,main] D執行 12:23:35

可以看到，如果每個任務都有一個調度線程來處理，那么就是很理想的情況，各個任務之間是并行的，互不干擾各自獨立，按照各自的時間來觸發。（可以看到 1-5 這 5 個線程都在各自調度自己的任務）
這里還要注意一點，fixDelay 和 fixRate 看上去似乎是一樣的，在每個任務的調度線程中，都是必須上一個執行完畢后，等待配置的時間后，再開始下一次的執行。是不是 fixRate 參數不起作用呢？因為不是說 fixRate 是間隔一定時間執行，而不需要等待上一個任務執行完畢么？

這里引入另一個參數，可以看任務 A 上方注釋掉的 @Async 注解：這個注解，代表可以異步執行。異步執行的話，調度線程池就會不用當前調度線程來執行，而是交給 task:executor 這個執行線程池來執行。
我們來運行，這里為了更好的說明，我們可以把 A 的 fixRate 改為 2秒 ，看運行結果：

B執行 12:34:44 C執行 12:34:44 A執行 12:34:44 D執行 12:34:45 E執行 12:34:45 A執行 12:34:46 A執行 12:34:48 A執行 12:34:50 A執行 12:34:52 B打印輸出 12:34:54Thread[myScheduler-2,5,main] B執行 12:34:54 C打印輸出 12:34:54Thread[myScheduler-3,5,main] A打印輸出 12:34:54Thread[myExecutor-1,5,main] C執行 12:34:54 A執行 12:34:54 A打印輸出 12:34:56Thread[myExecutor-2,5,main] A執行 12:34:56 A打印輸出 12:34:58Thread[myExecutor-3,5,main] A執行 12:34:58 A打印輸出 12:35:00Thread[myExecutor-4,5,main] A執行 12:35:00 A打印輸出 12:35:02Thread[myExecutor-5,5,main] A執行 12:35:02 B打印輸出 12:35:04Thread[myScheduler-2,5,main] B執行 12:35:04 C打印輸出 12:35:04Thread[myScheduler-3,5,main] A打印輸出 12:35:04Thread[myExecutor-1,5,main] C執行 12:35:04 A執行 12:35:04 A打印輸出 12:35:06Thread[myExecutor-2,5,main]

里 A 任務的線程是 myExecutor-1 到 myExecutor-5，說明 myScheduler-1 這個調度線程調度了 A 任務，但是交給了線程池中的 myExecutor 中的執行線程來具體執行的。
所以，配置 task:scheduler 參數的線程池，是為了根據任務總數來分配調度線程池的大小；而配置 task:executor ，是為了某個任務如果要異步的執行時，實現當前任務內的多線程并發。

總結

以上是生活随笔為你收集整理的Spring的任务调度@Scheduled注解——task:scheduler和task:executor的解析的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。