java定時(shí)任務(wù)目前主要有三種：

1. Java自帶的java.util.Timer類，這個(gè)類允許你調(diào)度一個(gè)java.util.TimerTask任務(wù)。使用這種方式可以讓你的程序按照某一個(gè)頻度執(zhí)行，但不能在指定時(shí)間運(yùn)行；而且作業(yè)類需要集成java.util.TimerTask，一般用的較少。
2. Spring3.0以后自帶的task，即：spring schedule，可以將它看成一個(gè)輕量級(jí)的Quartz，而且使用起來比Quartz簡(jiǎn)單許多。
3. Quartz，這是一個(gè)功能比較強(qiáng)大的的調(diào)度器，可以讓你的程序在指定時(shí)間執(zhí)行，也可以按照某一個(gè)頻度執(zhí)行；代碼稍顯復(fù)雜。

定時(shí)器算法

1.小頂堆

堆，實(shí)際上是一種經(jīng)過排序的完全二叉樹，其中任一非終端節(jié)點(diǎn)的數(shù)據(jù)值均不大于（或不小于）其左子節(jié)點(diǎn)和右子節(jié)點(diǎn)的值。

堆又分為兩種，最大堆、最小堆。
– 最大堆： 任一非葉子節(jié)點(diǎn)的值均大于其左子節(jié)點(diǎn)和右子節(jié)點(diǎn)的值。根節(jié)點(diǎn)的值是最大的。
– 最小堆： 任一非葉子節(jié)點(diǎn)的值均小于其左子節(jié)點(diǎn)和右子節(jié)點(diǎn)的值。根節(jié)點(diǎn)的值是最小的。

小頂堆的實(shí)現(xiàn)方式

由于堆是一種經(jīng)過排序的完全二叉樹，因此在構(gòu)建的時(shí)候需要對(duì)其新插入的節(jié)點(diǎn)進(jìn)行一些操作以使其符合堆的性質(zhì)。這種操作就叫上浮與下沉。

• 上浮：將當(dāng)前節(jié)點(diǎn)與其父節(jié)點(diǎn)相比，如果當(dāng)前節(jié)點(diǎn)的值比父節(jié)點(diǎn)小，就把當(dāng)前節(jié)點(diǎn)與父節(jié)點(diǎn)交換，然后繼續(xù)前面的交換，直到當(dāng)前節(jié)點(diǎn)比父節(jié)點(diǎn)的值大為止。上浮就是將符合條件的節(jié)點(diǎn)往上移的過程。
• 下沉：將當(dāng)前節(jié)點(diǎn)與其左、右子節(jié)點(diǎn)相比，如果當(dāng)前節(jié)點(diǎn)的值比其中一個(gè)或兩個(gè)子節(jié)點(diǎn)的值大，就把當(dāng)前節(jié)點(diǎn)與兩個(gè)子節(jié)點(diǎn)種比較小的那個(gè)交換，，然后繼續(xù)前面的比較，直到當(dāng)前節(jié)點(diǎn)的值比兩個(gè)子節(jié)點(diǎn)的值都小為止。下沉就是將符合條件的節(jié)點(diǎn)往下移的過程。

2.時(shí)間輪算法

見名知意，時(shí)間輪算法的數(shù)據(jù)結(jié)構(gòu)類似于鐘表上的數(shù)據(jù)指針，時(shí)間輪用環(huán)形數(shù)組的方式實(shí)現(xiàn)，數(shù)組中的每個(gè)元素都可以稱之為槽（和redis集群的槽一樣稱呼）。槽的內(nèi)部用雙向鏈表存儲(chǔ)著待執(zhí)行的任務(wù)，添加和刪除鏈表的操作時(shí)間復(fù)雜度為O（1），槽位本身也指代時(shí)間精度，比如一秒掃一個(gè)槽，那么這個(gè)時(shí)間輪的最高精度就是1秒。

當(dāng)有一個(gè)延遲任務(wù)要插入時(shí)間輪時(shí)，首先計(jì)算其延遲時(shí)間與單位時(shí)間的余值，從指針指向的當(dāng)前槽位移動(dòng)余值的個(gè)數(shù)槽位，就是該延遲任務(wù)需要被放入的槽位。

舉個(gè)例子，時(shí)間輪有8個(gè)槽位，編號(hào)為 0 ~ 7 。指針當(dāng)前指向槽位 2 。新增一個(gè)延遲時(shí)間為 4 秒的延遲任務(wù)，4 % 8 = 4，因此該任務(wù)會(huì)被插入 4 2 = 6，也就是槽位6的延遲任務(wù)隊(duì)列。

時(shí)間槽位的實(shí)現(xiàn)方式

時(shí)間輪的槽位實(shí)現(xiàn)可以采用循環(huán)數(shù)組的方式達(dá)成，也就是讓指針在越過數(shù)組的邊界后重新回到起始下標(biāo)。概括來說，可以將時(shí)間輪的算法描述為:

用隊(duì)列來存儲(chǔ)延遲任務(wù)，同一個(gè)隊(duì)列中的任務(wù)，其延遲時(shí)間相同。用循環(huán)數(shù)組的方式來存儲(chǔ)元素，數(shù)組中的每一個(gè)元素都指向一個(gè)延遲任務(wù)隊(duì)列。有一個(gè)當(dāng)前指針指向數(shù)組中的某一個(gè)槽位，每間隔一個(gè)單位時(shí)間，指針就移動(dòng)到下一個(gè)槽位。被指針指向的槽位的延遲隊(duì)列，其中的延遲任務(wù)全部被觸發(fā)。在時(shí)間輪中新增一個(gè)延遲任務(wù)，將其延遲時(shí)間除以單位時(shí)間得到的余值，從當(dāng)前指針開始，移動(dòng)余值對(duì)應(yīng)個(gè)數(shù)的槽位，就是延遲任務(wù)被放入的槽位。

基于這樣的數(shù)據(jù)結(jié)構(gòu)，插入一個(gè)延遲任務(wù)的時(shí)間復(fù)雜度就下降到 O(1) 。而當(dāng)指針指向到一個(gè)槽位時(shí)，該槽位連接的延遲任務(wù)隊(duì)列中的延遲任務(wù)全部被觸發(fā)。

延遲任務(wù)的觸發(fā)和執(zhí)行不應(yīng)該影響指針向后移動(dòng)的時(shí)間精確性。因此一般情況下，用于移動(dòng)指針的線程只負(fù)責(zé)任務(wù)的觸發(fā)，任務(wù)的執(zhí)行交由其他的線程來完成。比如，可以將槽位上的延遲任務(wù)隊(duì)列放入到額外的線程池中執(zhí)行，然后在槽位上新建一個(gè)空白的新的延遲任務(wù)隊(duì)列用于后續(xù)任務(wù)的添加。

代碼實(shí)現(xiàn)

Timer

/**
* @className: TimerTest
* @description: 測(cè)試java.util.Timer的定時(shí)器實(shí)現(xiàn)
* @author: charon
* @create: 2021-10-10 10:35
*/
public class TimerTest {
public static void main(String[] args) {
Timer timer = new Timer();
// 延遲1s執(zhí)行任務(wù)
timer.schedule(new TimerTask() {
@Override
public void run() {
System.out.println("延遲1s執(zhí)行的任務(wù)" new Date());
}
},1000);
// 延遲3s執(zhí)行任務(wù)，每隔5s執(zhí)行一次
timer.schedule(new TimerTask() {
@Override
public void run() {
System.out.println("延遲3s每隔5s執(zhí)行一次的任務(wù)" new Date());
}
},3000,5000);
// try {
// Thread.sleep(5000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// timer.cancel();
// System.out.println("任務(wù)執(zhí)行完畢" new Date());
}
}

延遲1s執(zhí)行的任務(wù)Sun Oct 10 14:34:13 CST 2021
延遲3s執(zhí)行的任務(wù)Sun Oct 10 14:34:15 CST 2021
延遲3s執(zhí)行的任務(wù)Sun Oct 10 14:34:20 CST 2021
延遲3s執(zhí)行的任務(wù)Sun Oct 10 14:34:25 CST 2021
延遲3s執(zhí)行的任務(wù)Sun Oct 10 14:34:30 CST 2021

Timer的實(shí)現(xiàn)方式比較簡(jiǎn)單，其內(nèi)部有兩個(gè)主要的屬性：

/**
* 用于存放定時(shí)任務(wù)TimeTask的列表
*/
private final TaskQueue queue = new TaskQueue();
/**
* 用于執(zhí)行定時(shí)任務(wù)的線程
*/
private final TimerThread thread = new TimerThread(queue);

TimerTask是一個(gè)實(shí)現(xiàn)了Runnable接口的抽象類。其run（）方法用于提供具體的延時(shí)任務(wù)邏輯。

TaskQueue內(nèi)部采用的是小頂堆的算法實(shí)現(xiàn)。根據(jù)任務(wù)的觸發(fā)時(shí)間采用死循環(huán)的方式進(jìn)行排序，將執(zhí)行時(shí)間最小的任務(wù)放在前面。

void add(TimerTask task) {
// Grow backing store if necessary
if (size 1 == queue.length)
queue = Arrays.copyOf(queue, 2*queue.length);

queue[ size] = task;
fixUp(size);
}

private void fixUp(int k) {
while (k > 1) {
int j = k >> 1;
if (queue[j].nextExecutionTime <= queue[k].nextExecutionTime)
break;
TimerTask tmp = queue[j]; queue[j] = queue[k]; queue[k] = tmp;
k = j;
}
}

這樣的方式就會(huì)有三個(gè)問題：

1. 由于執(zhí)行任務(wù)的線程只有一個(gè)，所以如果某個(gè)任務(wù)的執(zhí)行時(shí)間過長(zhǎng)，那么將破壞其他任務(wù)的定時(shí)精確性。如一個(gè)任務(wù)每1秒執(zhí)行一次，而另一個(gè)任務(wù)執(zhí)行一次需要5秒，那么如果是固定速率的任務(wù)，那么會(huì)在5秒這個(gè)任務(wù)執(zhí)行完成后連續(xù)執(zhí)行5次，而固定延遲的任務(wù)將丟失4次執(zhí)行。
2. 如果執(zhí)行某個(gè)任務(wù)過程中拋出了異常，那么執(zhí)行線程將會(huì)終止，導(dǎo)致Timer中的其他任務(wù)也不能再執(zhí)行。
3. Timer使用的是絕對(duì)時(shí)間，即是某個(gè)時(shí)間點(diǎn)，所以它執(zhí)行依賴系統(tǒng)的時(shí)間，如果系統(tǒng)時(shí)間修改了的話，將導(dǎo)致任務(wù)可能不會(huì)被執(zhí)行。

由于Timer存在上面說的這些缺陷，在JDK1.5中，我們可以使用ScheduledThreadPoolExecutor來代替它，使用Executors.newScheduledThreadPool工廠方法或使用ScheduledThreadPoolExecutor的構(gòu)造函數(shù)來創(chuàng)建定時(shí)任務(wù)，它是基于線程池的實(shí)現(xiàn)，不會(huì)存在Timer存在的上述問題，當(dāng)線程數(shù)量為1時(shí)，它相當(dāng)于Timer。

schedule

Spring Schedule在使用前都需要引入spring的包。

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>

在這里我主要是使用spring boot注解的方式來實(shí)現(xiàn)：

/**
* 在spring boot的啟動(dòng)類上面添加 @EnableScheduling 注解
*/
@SpringBootApplication
@EnableScheduling
public class ScheduleApplication {
public static void main(String[] args) {
SpringApplication.run(ScheduleApplication.class,args);
}
}

新創(chuàng)建一個(gè)類，用來實(shí)現(xiàn)定時(shí)任務(wù)，這個(gè)類要注冊(cè)成為Bean才行。

/**
* @className: ScheduleTest
* @description: 測(cè)試schedule的執(zhí)行器
* @author: charon
* @create: 2021-10-10 19:04
*/
@Component
public class ScheduleTest {
/**
* corn表達(dá)式：秒、分、時(shí)、日、月、星期
* 值可以是數(shù)字，也可以是以下符號(hào)：
* *：所有值都匹配 示例： 0 0 * * * *：每小時(shí)（當(dāng)秒和分都為0的時(shí)候）
* ?：只能用在日期和星期兩個(gè)表達(dá)式中 示例： 0 0 12 * * ? 每天中午12點(diǎn)觸發(fā)
* ,：或者 示例：0 0 9,13 * * *：每天的9點(diǎn)和13點(diǎn)
* /：增量值 示例: */10 * * * * *：每10秒
* -：區(qū)間 示例： 0 0/30 9-17 * * ? ： 朝九晚五工作時(shí)間內(nèi)每半小時(shí)
*/
@Scheduled(cron="0 * * * * *")
public void doSomething(){
System.out.println("測(cè)試schedule的定時(shí)器，當(dāng)秒為0的時(shí)候執(zhí)行一次：" new Date());
}
}

測(cè)試schedule的定時(shí)器，當(dāng)秒為0的時(shí)候執(zhí)行一次：Sun Oct 10 19:18:00 CST 2021
測(cè)試schedule的定時(shí)器，當(dāng)秒為0的時(shí)候執(zhí)行一次：Sun Oct 10 19:19:00 CST 2021
測(cè)試schedule的定時(shí)器，當(dāng)秒為0的時(shí)候執(zhí)行一次：Sun Oct 10 19:20:00 CST 2021

@Scheduled注解的另外兩個(gè)重要屬性：fixedRate和fixedDelay

• fixedDelay：上一個(gè)任務(wù)結(jié)束后多久執(zhí)行下一個(gè)任務(wù)
• fixedRate：上一個(gè)任務(wù)的開始到下一個(gè)任務(wù)開始時(shí)間的間隔

/**
* 測(cè)試fixedRate，每2s執(zhí)行一次
* @throws Exception
*/
@Scheduled(fixedRate = 2000)
public void fixedRate() throws Exception {
System.out.println("fixedRate開始執(zhí)行時(shí)間:" new Date(System.currentTimeMillis()));
//休眠1秒
Thread.sleep(1000);
System.out.println("fixedRate執(zhí)行結(jié)束時(shí)間:" new Date(System.currentTimeMillis()));
}

fixedRate開始執(zhí)行時(shí)間:Sun Oct 10 19:59:05 CST 2021
fixedRate執(zhí)行結(jié)束時(shí)間:Sun Oct 10 19:59:06 CST 2021
fixedRate開始執(zhí)行時(shí)間:Sun Oct 10 19:59:07 CST 2021
fixedRate執(zhí)行結(jié)束時(shí)間:Sun Oct 10 19:59:08 CST 2021
fixedRate開始執(zhí)行時(shí)間:Sun Oct 10 19:59:09 CST 2021
fixedRate執(zhí)行結(jié)束時(shí)間:Sun Oct 10 19:59:10 CST 2021

/**
* 等上一次執(zhí)行完等待1s執(zhí)行
* @throws Exception
*/
@Scheduled(fixedDelay = 1000)
public void fixedDelay() throws Exception {
System.out.println("fixedDelay開始執(zhí)行時(shí)間:" new Date(System.currentTimeMillis()));
//休眠兩秒
Thread.sleep(1000 * 2);
System.out.println("fixedDelay執(zhí)行結(jié)束時(shí)間:" new Date(System.currentTimeMillis()));
}

fixedDelay執(zhí)行結(jié)束時(shí)間:Sun Oct 10 20:07:23 CST 2021
fixedDelay開始執(zhí)行時(shí)間:Sun Oct 10 20:07:24 CST 2021
fixedDelay執(zhí)行結(jié)束時(shí)間:Sun Oct 10 20:07:26 CST 2021
fixedDelay開始執(zhí)行時(shí)間:Sun Oct 10 20:07:27 CST 2021
fixedDelay執(zhí)行結(jié)束時(shí)間:Sun Oct 10 20:07:29 CST 2021

如果是強(qiáng)調(diào)任務(wù)間隔的定時(shí)任務(wù)，建議使用fixedRate和fixedDelay，如果是強(qiáng)調(diào)任務(wù)在某時(shí)某分某刻執(zhí)行的定時(shí)任務(wù)，建議使用cron表達(dá)式。

Spring Schedule的Corn是使用的時(shí)間輪算法（分層時(shí)間輪,每個(gè)時(shí)間粒度對(duì)應(yīng)一個(gè)時(shí)間輪，多個(gè)時(shí)間輪時(shí)間進(jìn)行級(jí)聯(lián)協(xié)調(diào)）。

在CronSequenceGenerator.java這個(gè)類中，對(duì)每個(gè)CornTask都維護(hù)了一下7個(gè)Bitset（使用位數(shù)組而不用list，set之類的數(shù)據(jù)結(jié)構(gòu)，一方面是因?yàn)榭臻g效率，更重要的是接下來的操作主要是判斷某個(gè)值是否匹配和從某個(gè)值開始找最近的下一個(gè)能夠匹配的值）

private final BitSet months = new BitSet(12);

private final BitSet daysOfMonth = new BitSet(31);

private final BitSet daysOfWeek = new BitSet(7);

private final BitSet hours = new BitSet(24);

private final BitSet minutes = new BitSet(60);

private final BitSet seconds = new BitSet(60);

然后根據(jù)配置的corn值計(jì)算這個(gè)任務(wù)對(duì)應(yīng)的值計(jì)算每個(gè)bit的值。如我這里配置的每分鐘執(zhí)行一次的CornTask的結(jié)果如下：

CronSequenceGenerator負(fù)責(zé)解析用戶配置的Cron表達(dá)式，并提供next方法，根據(jù)給定的時(shí)間獲取符合cron表達(dá)式規(guī)則的最近的下一個(gè)時(shí)間。CronTrigger實(shí)現(xiàn)Trigger的nextExecutionTime方法，根據(jù)定時(shí)任務(wù)執(zhí)行的上下文環(huán)境(最近調(diào)度時(shí)間和最近完成時(shí)間)決定查找下一次執(zhí)行時(shí)間的左邊界，之后調(diào)用CronSequenceGenerator的next方法從左邊界開始找下一次的執(zhí)行時(shí)間。

CronSequenceGenerator的doNext算法從指定時(shí)間開始(包括指定時(shí)間)查找符合cron表達(dá)式規(guī)則下一個(gè)匹配的時(shí)間。如圖3-4所示，其整體思路是：沿著秒→分→時(shí)→日→月逐步檢查指定時(shí)間的值。如果所有域上的值都已經(jīng)符合規(guī)則那么指定時(shí)間符合cron表達(dá)式，算法結(jié)束。否則，必然有某個(gè)域的值不符合規(guī)則，調(diào)整該域到下一個(gè)符合規(guī)則的值(可能調(diào)整更高的域)，并將較低域的值調(diào)整到最小值，然后從秒開始重新檢查和調(diào)整。

private void doNext(Calendar calendar, int dot) {
List<Integer> resets = new ArrayList<>();

int second = calendar.get(Calendar.SECOND);
List<Integer> emptyList = Collections.emptyList();
int updateSecond = findNext(this.seconds, second, calendar, Calendar.SECOND, Calendar.MINUTE, emptyList);
if (second == updateSecond) {
resets.add(Calendar.SECOND);
}

int minute = calendar.get(Calendar.MINUTE);
int updateMinute = findNext(this.minutes, minute, calendar, Calendar.MINUTE, Calendar.HOUR_OF_DAY, resets);
if (minute == updateMinute) {
resets.add(Calendar.MINUTE);
}
else {
doNext(calendar, dot);
}

int hour = calendar.get(Calendar.HOUR_OF_DAY);
int updateHour = findNext(this.hours, hour, calendar, Calendar.HOUR_OF_DAY, Calendar.DAY_OF_WEEK, resets);
if (hour == updateHour) {
resets.add(Calendar.HOUR_OF_DAY);
}
else {
doNext(calendar, dot);
}

int dayOfWeek = calendar.get(Calendar.DAY_OF_WEEK);
int dayOfMonth = calendar.get(Calendar.DAY_OF_MONTH);
int updateDayOfMonth = findNextDay(calendar, this.daysOfMonth, dayOfMonth, this.daysOfWeek, dayOfWeek, resets);
if (dayOfMonth == updateDayOfMonth) {
resets.add(Calendar.DAY_OF_MONTH);
}
else {
doNext(calendar, dot);
}

int month = calendar.get(Calendar.MONTH);
int updateMonth = findNext(this.months, month, calendar, Calendar.MONTH, Calendar.YEAR, resets);
if (month != updateMonth) {
if (calendar.get(Calendar.YEAR) – dot > 4) {
throw new IllegalArgumentException("Invalid cron expression "" this.expression
"" led to runaway search for next trigger");
}
doNext(calendar, dot);
}

}

private int findNext(BitSet bits, int value, Calendar calendar, int field, int nextField, List<Integer> lowerOrders) {
int nextValue = bits.nextSetBit(value);
// 下一個(gè)匹配值是－1，則將對(duì)更高的域做加1操作，從0開始查找下一個(gè)匹配值,將當(dāng)前域設(shè)置為下一個(gè)匹配值，重置比當(dāng)前域低的所有域設(shè)置為最小值，遞歸調(diào)度本算法。
if (nextValue == -1) {
calendar.add(nextField, 1);
reset(calendar, Collections.singletonList(field));
nextValue = bits.nextSetBit(0);
}
// 下一個(gè)匹配值不是當(dāng)前值但也不是－1，則將當(dāng)前域設(shè)置為下一個(gè)匹配值，將比當(dāng)前域低的所有域設(shè)置為最小值，遞歸調(diào)度本算法
if (nextValue != value) {
calendar.set(field, nextValue);
reset(calendar, lowerOrders);
}
// 下一個(gè)匹配值就是當(dāng)前值，則匹配通過，如果當(dāng)前域是月則算法結(jié)束，否則繼續(xù)處理下一個(gè)更高的域。
return nextValue;
}

Quartz

在這里還是使用Spring Boot 集成Quartz；

引入依賴：

<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.0</version>
</dependency>

測(cè)試的job業(yè)務(wù)處理類：

/**
* @className: QuartzJob
* @description: 業(yè)務(wù)邏輯處理類
* @author: charon
* @create: 2021-10-11 14:32
*/
public class QuartzJob implements Job {
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
System.out.println("執(zhí)行quartz定時(shí)器開始：" new Date());
// 模擬業(yè)務(wù)邏輯
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("執(zhí)行quartz定時(shí)器結(jié)束：" new Date());
}
}

實(shí)例化Job，將任務(wù)觸發(fā)器加入任務(wù)調(diào)度中：

/**
* @className: QuartzConfig
* @description: scheduler的啟動(dòng)、結(jié)束等控制類
* @author: charon
* @create: 2021-10-11 14:38
*/
@Configuration
public class QuartzConfig {

@Autowired
private Scheduler scheduler;

/**
* 開始定時(shí)器
*/
public void startJob() throws SchedulerException {
// 通過JobBuilder構(gòu)建JobDetail實(shí)例，JobDetail規(guī)定只能是實(shí)現(xiàn)Job接口的實(shí)例
// JobDetail 是具體Job實(shí)例
JobDetail jobDetail = JobBuilder.newJob(QuartzJob.class).withIdentity("job", "group").build();
// 基于表達(dá)式構(gòu)建觸發(fā)器 每5秒種執(zhí)行一次
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");
// CronTrigger表達(dá)式觸發(fā)器 繼承于Trigger
// TriggerBuilder 用于構(gòu)建觸發(fā)器實(shí)例
CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("job1", "group1")
.withSchedule(cronScheduleBuilder).build();
scheduler.scheduleJob(jobDetail, cronTrigger);
}

/**
* 刪除某個(gè)任務(wù)
*
* @param name job的名稱
* @param group job的分組
* @throws SchedulerException
*/
public void deleteJob(String name, String group) throws SchedulerException {
JobKey jobKey = new JobKey(name, group);
if (scheduler.checkExists(jobKey)){
scheduler.deleteJob(jobKey);
}
}

測(cè)試類（spring容器初始化完成后執(zhí)行）：

/**
* @className: QuartzTest
* @description: 測(cè)試quartz的定時(shí)器
* @author: charon
* @create: 2021-10-11 10:33
*/
@Configuration
public class QuartzTest implements ApplicationListener<ContextRefreshedEvent> {

@Autowired
private QuartzConfig quartzConfig;

/**
* 監(jiān)聽初始化quartz
* @param event
*/
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
System.out.println("容器初始化完成");
try {
quartzConfig.startJob();
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}

容器初始化完成
2021-10-11 15:02:46.947 INFO 19628 — [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 7010 (http) with context path ''
2021-10-11 15:02:49.558 INFO 19628 — [ main] c.c.ScheduleApplication : Started ScheduleApplication in 10.734 seconds (JVM running for 11.644)
執(zhí)行quartz定時(shí)器開始：Mon Oct 11 15:02:50 CST 2021
執(zhí)行quartz定時(shí)器結(jié)束：Mon Oct 11 15:02:52 CST 2021
執(zhí)行quartz定時(shí)器開始：Mon Oct 11 15:02:55 CST 2021
執(zhí)行quartz定時(shí)器結(jié)束：Mon Oct 11 15:02:57 CST 2021
執(zhí)行quartz定時(shí)器開始：Mon Oct 11 15:03:00 CST 2021
執(zhí)行quartz定時(shí)器結(jié)束：Mon Oct 11 15:03:02 CST 2021

作者 | pluto_charon

來源 | cnblogs.com/pluto-charon/p/15451928.html