javascript
Spring的任务调度@Scheduled注解——task:scheduler和task:executor的解析
Spring的任務調(diào)度@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"/><!-- 調(diào)度線程池配置 --><task:scheduler id="myScheduler" pool-size="5"/><!-- 執(zhí)行線程池配置 --><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注解，代表當前任務是要異步執(zhí)行的@Async@Scheduled(fixedRate = 5000)public void printA(){System.out.println("A執(zhí)行 " + 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執(zhí)行 " + 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執(zhí)行 " + df.format(new Date()));try {Thread.sleep(10000);} catch (InterruptedException e) {}System.out.println("C打印輸出 " + df.format(new Date())+ Thread.currentThread());}// 配置initialDelay的任務是在容器啟動后延遲一定時間才開始調(diào)度@Scheduled(fixedRate = 5000, initialDelay=1000)public void printD(){System.out.println("D執(zhí)行 " + df.format(new Date()));try {Thread.sleep(30000);} catch (InterruptedException e) {}System.out.println("D打印輸出 " + df.format(new Date())+ Thread.currentThread());}// 配置initialDelay的任務是在容器啟動后延遲一定時間才開始調(diào)度@Scheduled(fixedRate = 5000, initialDelay=1000)public void printE(){System.out.println("E執(zhí)行 " + df.format(new Date()));try {Thread.sleep(30000);} catch (InterruptedException e) {}System.out.println("E打印輸出 " + df.format(new Date())+ Thread.currentThread());}}這里，fixDelay 和 fixRate 參數(shù)代表每個任務，前者在上一個任務調(diào)度完成后，延遲一定的時間執(zhí)行。而后者可以在每間隔一定時間就執(zhí)行新任務（但這里與 executor 的參數(shù)有關(guān)）。下面的試驗會詳細說明這兩個參數(shù)。
Spring 的任務調(diào)度線程池，即
如果不配置，那么默認值是 1 ，即結(jié)果是所有聲明的任務，都是串行執(zhí)行的，比如代碼中的 A/B/C/D/E 五個任務，在默認值是 1 的情況下，只能一個個串行來執(zhí)行。不能出現(xiàn)并行的情況。
可以將參數(shù)改為 1 ，運行，輸出如下：
可以看到只有 myScheduler-1 這一個調(diào)度線程來調(diào)度這五個任務，任務之間只能串行，即等待上個任務完成后釋放調(diào)度線程，然后調(diào)度線程才能調(diào)度執(zhí)行下一個任務。
然后我們還改回調(diào)度線程池 5 個線程池大小，運行：
C執(zhí)行 12:23:04 A執(zhí)行 12:23:04 B執(zhí)行 12:23:04 E執(zhí)行 12:23:05 D執(zhí)行 12:23:05 C打印輸出 12:23:14Thread[myScheduler-2,5,main] C執(zhí)行 12:23:14 A打印輸出 12:23:14Thread[myScheduler-3,5,main] A執(zhí)行 12:23:14 B打印輸出 12:23:14Thread[myScheduler-1,5,main] B執(zhí)行 12:23:14 C打印輸出 12:23:24Thread[myScheduler-2,5,main] C執(zhí)行 12:23:24 A打印輸出 12:23:24Thread[myScheduler-3,5,main] A執(zhí)行 12:23:24 B打印輸出 12:23:24Thread[myScheduler-1,5,main] B執(zhí)行 12:23:24 C打印輸出 12:23:34Thread[myScheduler-2,5,main] A打印輸出 12:23:34Thread[myScheduler-3,5,main] C執(zhí)行 12:23:34 A執(zhí)行 12:23:34 B打印輸出 12:23:34Thread[myScheduler-1,5,main] B執(zhí)行 12:23:34 E打印輸出 12:23:35Thread[myScheduler-4,5,main] E執(zhí)行 12:23:35 D打印輸出 12:23:35Thread[myScheduler-5,5,main] D執(zhí)行 12:23:35可以看到，如果每個任務都有一個調(diào)度線程來處理，那么就是很理想的情況，各個任務之間是并行的，互不干擾各自獨立，按照各自的時間來觸發(fā)。（可以看到 1-5 這 5 個線程都在各自調(diào)度自己的任務）
這里還要注意一點，fixDelay 和 fixRate 看上去似乎是一樣的，在每個任務的調(diào)度線程中，都是必須上一個執(zhí)行完畢后，等待配置的時間后，再開始下一次的執(zhí)行。是不是 fixRate 參數(shù)不起作用呢？因為不是說 fixRate 是間隔一定時間執(zhí)行，而不需要等待上一個任務執(zhí)行完畢么？
這里引入另一個參數(shù)，可以看任務 A 上方注釋掉的 @Async 注解：這個注解，代表可以異步執(zhí)行。異步執(zhí)行的話，調(diào)度線程池就會不用當前調(diào)度線程來執(zhí)行，而是交給 task:executor 這個執(zhí)行線程池來執(zhí)行。
我們來運行，這里為了更好的說明，我們可以把 A 的 fixRate 改為 2秒 ，看運行結(jié)果：
里 A 任務的線程是 myExecutor-1 到 myExecutor-5，說明 myScheduler-1 這個調(diào)度線程調(diào)度了 A 任務，但是交給了線程池中的 myExecutor 中的執(zhí)行線程來具體執(zhí)行的。
所以，配置 task:scheduler 參數(shù)的線程池，是為了根據(jù)任務總數(shù)來分配調(diào)度線程池的大小；而配置 task:executor ，是為了某個任務如果要異步的執(zhí)行時，實現(xiàn)當前任務內(nèi)的多線程并發(fā)。
總結(jié)
以上是生活随笔為你收集整理的Spring的任务调度@Scheduled注解——task:scheduler和task:executor的解析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 吴恩达深度学习笔记7-Course2-W
- 下一篇： 吴恩达深度学习笔记9-Course3-W