如何動態(tài)添加修改刪除定時任務？

如何動態(tài)添加修改刪除定時任務？那么我們一起看看具體怎么實現(xiàn)，先看下本節(jié)大綱：

（1）思路說明；

（2）代碼解析；

（3）修改定時任務執(zhí)行周期特別說明；

接下來看看本節(jié)的大綱：

（1）思路說明；

（a）首先這里我們需要重新認識一個類ThreadPoolTaskScheduler：線程池任務調(diào)度類，能夠開啟線程池進行任務調(diào)度。

（b）ThreadPoolTaskScheduler.schedule()方法會創(chuàng)建一個定時計劃ScheduledFuture，在這個方法需要添加兩個參數(shù)，Runnable（線程接口類）和CronTrigger（定時任務觸發(fā)器）

（c）在ScheduledFuture中有一個cancel可以停止定時任務。

（2）代碼解析；

根據(jù)以上的思路分析，我們很容易就知道如何進行編碼了，先提供代碼如下：

package com.kfit.task;

import java.util.Date;

**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執(zhí)行方法schedule的返回值，主要用于定時任務的停止。

（c）編寫啟動定時器的方法startCron()；

（d）編寫停止方法stopCron(),這里編碼的時候，需要注意下需要判斷下future為null的時候，不然就很容易拋出NullPointerException；

（e）編寫修改定時任務執(zhí)行周期方法changeCron10（），這里的原理就是關(guān)閉之前的定時器，創(chuàng)新在創(chuàng)建一個新的定時器。

（3）修改定時任務執(zhí)行周期特別說明；

在上一篇博客中，我們使用了一種方式通過全局變量的方式修改cron參數(shù)的值，那么在這里的我們也是可以這么做的，這里簡單提供下思路，大家自己去實現(xiàn)。

注意ThreadPoolTaskScheduler中的schedule（）第二個參數(shù)支持Trigger:

ThreadPoolTaskScheduler.schedule([Runnable]( "in java.lang") arg0, [Trigger]( "in org.springframework.scheduling")arg1)

那么我們就可以自己定義一個Trigger，然后動態(tài)進行修改了，這里提供核心的代碼如下：

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";

}