1. 程式人生 > >springboot定時任務

springboot定時任務

factor 添加 actor 返回值 olt adp 思路分析 web ack

(1)思路說明;

(a)首先這裏我們需要重新認識一個類ThreadPoolTaskScheduler:線程池任務調度類,能夠開啟線程池進行任務調度。

(b)ThreadPoolTaskScheduler.schedule()方法會創建一個定時計劃ScheduledFuture,在這個方法需要添加兩個參數,Runnable(線程接口類) 和CronTrigger(定時任務觸發器)

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

(2)代碼解析;

根據以上的思路分析,我們很容易就知道如何進行編碼了,先提供代碼如下:

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;

import org.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 ThreadPoolTaskScheduler threadPoolTaskScheduler;

private ScheduledFuture<?> future;

@Bean

public ThreadPoolTaskScheduler threadPoolTaskScheduler() {

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 arg0, Trigger arg1)

那麽我們就可以自己定義一個Trigger,然後動態進行修改了,這裏提供核心的代碼如下:

private String cronStr = "*/5 * * * * *";

@RequestMapping("/startCron1")

public String startCron1(){

System.out.println("startCron1 >>>>");

threadPoolTaskScheduler.schedule(new MyRunnable(), new Trigger(){

@Override

public Date nextExecutionTime(TriggerContext triggerContext){

returnnew CronTrigger(cronStr).nextExecutionTime(triggerContext);

}

});

System.out.println("startCron1 <<<<");

return "startCron1";

}

springboot定時任務