springboot定时任务

标签：变量   out   简单   new   定时器   hang   auto   bin   print   

（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());

       }

    }

}

（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定时任务

标签：变量   out   简单   new   定时器   hang   auto   bin   print   

原文地址：http://www.cnblogs.com/java-xz/p/7744097.html