cancel方法用来取消任务,如果取消任务成功则返回true,如果取消任务失败则返回false。参数mayInterruptIfRunning表示是否允许取消正在执行却没有执行完毕的任务,如果设置true,则表示可以取消正在执行过程中的任务。如果任务已经完成,则无论mayInterruptIfRunning为true还是false,此方法肯定返回false,即如果取消已经完成的任务会返回false;如果任务正在执行,若mayInterruptIfRunning设置为true,则返回true,若mayInterruptIfRunning设置为false,则返回false;如果任务还没有执行,则无论mayInterruptIfRunning为true还是false,肯定返回true。

isCancelled方法表示任务是否被取消成功,如果在任务正常完成前被取消成功,则返回 true。

isDone方法表示任务是否已经完成,若任务完成,则返回true;

get()方法用来获取执行结果springboot定时任务,这个方法会产生阻塞,会一直等到任务执行完毕才返回;

get(long timeout, TimeUnit unit)用来获取执行结果,如果在指定时间内,还没获取到结果,就直接返回null。

3.也就是说Future提供了三种功能:

判断任务是否完成

能够中断任务

能够获取任务执行结果

4.1 编写动态Task类,主要实现通过URL控制任何的添加修改等等。

@RestController
public class DynamicTaskController {
    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;
    /**
     *
     * ThreadPoolTaskScheduler:线程池任务调度类,能够开启线程池进行任务调度。
     * ThreadPoolTaskScheduler.schedule()方法会创建一个定时计划ScheduledFuture,
     * 在这个方法需要添加两个参数,Runnable(线程接口类) 和CronTrigger(定时任务触发器)
     * @return
     */
    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        return new ThreadPoolTaskScheduler();
    }
    /**
     * 在ScheduledFuture中有一个cancel可以停止定时任务。
     */
    private ScheduledFuture future;
    /**
     * 启动任务
     **/
    @RequestMapping("/startTask")
    public String startCron() {
    //这里设定任务1秒执行一次
        future = threadPoolTaskScheduler.scheduleAtFixedRate(new TestRunnable(),1000);
        System.out.println("TaskController.startCron()");
        try{
            //get()方法用来获取执行结果,这个方法会产生阻塞,会一直等到任务执行完毕才返回;
            //future的get()设定超时时间
            Object o = future.get(3900, TimeUnit.MILLISECONDS);
            System.out.println(o);
            Object o1 = future.get();
            System.out.println(o1);
        }
        catch ( Exception e){
            System.out.println(e);
        }
        return "startTask";
    }
    /**
     * 停止任务
     **/
    @RequestMapping("/stop")
    public String stopCron() {
        if (future != null) {
            future.cancel(true);
        }
        System.out.println("stopCron()");
        return "stopTask";
    }
    /**
     * 前端页面输入任务间隔,再次启动任务
     **/
    @RequestMapping("/change")
     public String changeCron(@RequestParam int fixedRate) {
        stopCron();// 先停止,再开启.
        future = threadPoolTaskScheduler.scheduleAtFixedRate(new TestRunnable(),fixedRate);
        System.out.println("TaskController.changeCron()");
        return "change";
    }
}

4.2 编写一个简单的线程:

public class TestRunnable implements Runnable {
    @Override
    public void run() {
         Date date = new Date();
        System.out.println("现在执行函数的时间为:"+date);
    }
}

4.3 注:上面类中有几个点需要了解:

一个类ThreadPoolTaskScheduler:线程池任务调度类,能够开启线程池进行任务调度。

ThreadPoolTaskScheduler.schedule()方法会创建一个定时计划ScheduledFuture,在这个方法需要添加两个参数,Runnable(线程接口类) 和CronTrigger(定时任务触发器)

在ScheduledFuture中有一个cancel可以停止定时任务。

看到这里相信大家都已经进一步了解springboot定时任务,快动起来测试一下吧,

这里给大家测试一下变更时间springboot定时任务,其他的大家自行测试

启动程序在postman输入如下内容

在控制台打印如下内容表示更改时间成功

下面的图片列举了可以使用的方法有需要的可以试一试,今天就先说到这里后续也会给大家分享一些技术方面知识,感谢大家能阅读到这里希望能给你的工作提供帮助。

限时特惠:本站每日持续更新海量设计资源,一年会员只需29.9元,全站资源免费下载
站长微信:ziyuanshu688