如何動態添加修改刪除定時任務?那么我們一起看看具體怎么實現,先看下本節大綱:
(1)思路說明;
(2)代碼解析;
(3)修改定時任務執行周期特別說明;
接下來看看本節的大綱:
(1)思路說明;
(a)首先這里我們需要重新認識一個類ThreadPoolTaskScheduler:線程池任務調度類,能夠開啟線程池進行任務調度。
(b)ThreadPoolTaskScheduler.schedule()方法會創建一個定時計劃ScheduledFuture,在這個方法需要添加兩個參數,Runnable(線程接口類)和CronTrigger(定時任務觸發器)
(c)在ScheduledFuture中有一個cancel可以停止定時任務。
(2)代碼解析;
根據以上的思路分析,我們很容易就知道如何進行編碼了,先提供代碼如下:
package com.kfit.task;
**import **java.util.concurrent.ScheduledFuture;
**import **org.springframework.beans.factory.annotation.Autowired;
**import **org.springframework.context.annotation.Bean;
importorg.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
**import **org.springframework.scheduling.support.CronTrigger;
**import **org.springframework.stereotype.Component;
**import **org.springframework.web.bind.annotation.RequestMapping;
**import **org.springframework.web.bind.annotation.RestController;
/**
- @author Angel --守護天使
- @version v.0.1
- @date 2017年4月6日
*/
@RestController
@Component
**public **class DynamicTask {
@Autowired
**private** ThreadPoolTaskSchedulerthreadPoolTaskScheduler;
**private **ScheduledFuture? future;
@Bean
**public** ThreadPoolTaskSchedulerthreadPoolTaskScheduler() {
**return****new**ThreadPoolTaskScheduler();
}
@RequestMapping("/startCron")
**public** String startCron() {
future = threadPoolTaskScheduler.schedule(**new** MyRunnable(), **new** CronTrigger("0/5 * * * * *"));
System. ***out*** .println("DynamicTask.startCron()");
**return ** "startCron";
}
@RequestMapping("/stopCron")
**public** String stopCron() {
**if** (future != **null** ) {
future.cancel( **true** );
}
System. ***out*** .println("DynamicTask.stopCron()");
**return ** "stopCron";
}
@RequestMapping("/changeCron10")
**public** String startCron10() {
stopCron();// 先停止,在開啟.
future = threadPoolTaskScheduler.schedule(**new** MyRunnable(), **new** CronTrigger("*/10 * * * * *"));
System. ***out*** .println("DynamicTask.startCron10()");
**return ** "changeCron10";
}
**private ****class** MyRunnable **implements** Runnable {
@Override
**public ****void** run() {
System. ***out*** .println("DynamicTask.MyRunnable.run()," + **new** Date());
}
}
}
(a)我們首先了一個類DynamicTask;
(b)定義了兩個變量,threadPoolTaskScheduler和future 其中future是treadPoolTaskScheduler執行方法schedule的返回值,主要用于定時任務的停止。
(c)編寫啟動定時器的方法startCron();
(d)編寫停止方法stopCron(),這里編碼的時候,需要注意下需要判斷下future為null的時候,不然就很容易拋出NullPointerException;
(e)編寫修改定時任務執行周期方法changeCron10(),這里的原理就是關閉之前的定時器,創新在創建一個新的定時器。
(3)修改定時任務執行周期特別說明;
在上一篇博客中,我們使用了一種方式通過全局變量的方式修改cron參數的值,那么在這里的我們也是可以這么做的,這里簡單提供下思路,大家自己去實現。
注意ThreadPoolTaskScheduler中的schedule()第二個參數支持Trigger:
ThreadPoolTaskScheduler.schedule([Runnable]( "in java.lang") arg0, [Trigger]( "in org.springframework.scheduling")arg1)
那么我們就可以自己定義一個Trigger,然后動態進行修改了,這里提供核心的代碼如下:
private String cronStr = "*/5 * * * * *";
@RequestMapping("/startCron1")
**public** String startCron1(){
System. ***out*** .println("startCron1 >>>>");
threadPoolTaskScheduler.schedule(**new** MyRunnable(), **new** Trigger(){
@Override
**public** DatenextExecutionTime(TriggerContext triggerContext){
**return****new** CronTrigger(cronStr).nextExecutionTime(triggerContext);
}
});
System. ***out*** .println("startCron1 <<<<");
**return ** "startCron1";
}
-
JAVA
+關注
關注
19文章
2966瀏覽量
104702 -
代碼
+關注
關注
30文章
4779瀏覽量
68525
發布評論請先 登錄
相關推薦
評論