乐趣区

关于java:又被问了Spring-Boot-定时任务开启后怎么符合条件自动停止

jiezi

背景

昨天，咱们的《常识星球：Java 技术栈》外面有粉丝向我发问：

问题大略就是：

Spring Boot 定时工作开启后，怎么符合条件主动进行？

过后我有空，尽管曾经给出了参考答案，但可能还有一些细节中央要留神的，另外，我也感觉这个问题特地有意思，当初特地拿进去整顿下，分享下给大家。

1、自定义任务调度

首先笼罩 TaskSchedulingAutoConfiguration 主动配置类外面的 ThreadPoolTaskScheduler Bean：

/**
 * 自定义任务调度
 * 公众号：Java 技术栈
 */
@Data
@Component
class CustomTaskScheduler extends ThreadPoolTaskScheduler {private Map<Object, ScheduledFuture<?>> scheduledTasks = new IdentityHashMap<>();

    @Override
    public ScheduledFuture<?> schedule(Runnable task, Trigger trigger) {ScheduledFuture<?> future = super.schedule(task, trigger);
        this.putScheduledTasks(task, future);
        return future;
    }

    @Override
    public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, long period) {ScheduledFuture<?> future = super.scheduleAtFixedRate(task, period);
        this.putScheduledTasks(task, future);
        return future;
    }

    @Override
    public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, Date startTime, long period) {ScheduledFuture<?> future = super.scheduleAtFixedRate(task, startTime, period);
        this.putScheduledTasks(task, future);
        return future;
    }

    private void putScheduledTasks(Runnable task, ScheduledFuture<?> future) {ScheduledMethodRunnable runnable = (ScheduledMethodRunnable) task;
        scheduledTasks.put(runnable.getTarget(), future);
    }
    
    // 重写所有 schedule* 办法...

}

Spring Boot 根底就不介绍了，举荐下这个实战教程：

https://github.com/javastacks…

重写所有 schedule* 办法 …

因为要进行一个工作，就必须调用 ScheduledFuture -> Future 接口中的 cancel 办法。

所以，思路就是在工作执行的时候，把工作所在的实例 Bean 和工作启动后的 ScheduledFuture 保护到一个 Map 外面，而后须要进行的时候，从 Map 外面取出来，再进行 cancel 进行即可。

2、按条件主动进行工作

新建一个每 3 秒执行一次的工作：

/**
 * 按条件主动进行工作
 * 公众号：Java 技术栈
 */
@Slf4j
@Component
public class AutoStopTask {

    @Autowired
    private CustomTaskScheduler customTaskScheduler;

    private int count;

    @Scheduled(cron = "*/3 * * * * *")
    public void printTask() {log.info("公众号 Java 技术栈，工作执行次数：{}", count + 1);

        count++;

        // 执行 3 次后主动进行
        if (count >= 3) {log.info("工作已执行指定次数，当初主动进行");
            boolean cancelled = customTaskScheduler.getScheduledTasks().get(this).cancel(true);
            
            // 进行后再次启动
            if (cancelled) {
                count = 0;
                ScheduledMethodRunnable runnable = new ScheduledMethodRunnable(this, ReflectionUtils.findMethod(this.getClass(), "printTask"));
                customTaskScheduler.schedule(runnable, new CronTrigger("*/3 * * * * *"));
            }
        }
    }

}

这里是统计执行，当执行次数超过 3 次时就主动进行。如果须要再次启动，下面也提供了参数代码。

须要留神的是，自定义调度外面绑定的是实例 Bean 和 Future 的关系，所以仅限 Bean 中的单个工作，如果一个 Bean 保护了多个工作，最初一个工作的启动就会笼罩之前的。

如果要保护 Bean 中的多个工作，主动进行该怎么做呢？

答案就是把工作的办法名和 Future 关联起来：

/scheduledMethodTasks.put(runnable.getMethod(), future);

取的的依据以后的办法名取就行了，这里是办法名，也可是类名+办法名+参数，避免反复。

对于这个问题，你还有哪些实现计划呢？欢送留言分享！

总结

本文残缺示例代码曾经上传到 Github：

https://github.com/javastacks…

如果你感兴趣的话，能够 Star 学习，后续会继续更新。

最初打一波咱们星球的广告：

  • 如果你也有许多疑难问题、纳闷无从解答，能够退出咱们的《常识星球：Java 技术栈》，只有栈长我晓得的我都会解答，还有 2500+ 球友也在；
  • 如果你学习没有方向、工作没有晋升，《常识星球：Java 技术栈》外面也积淀了大量技术常识、学习材料、面试题、简历模板等，退出就值回门票；

星球原价是 199 的，当初是流动优惠价 159 元，正是退出的好时候，过段时间必定会复原原价的。

公众号、微信下面好友太多，不可能一一答复每个人的问题，工夫精力不容许啊（答复是情分，不答复是任务），所以我就创立了《常识星球：Java 技术栈》，常识付费，当初就变成了一种责任了，栈长是实打实的纯技术人，不玩套路，也从不玩虚的，咱们的星球相对物超所值，欢送退出一起学习吧。

最初，如果你想关注和学习最新、最支流的 Java 技术，能够继续关注公众号 Java 技术栈，公众号第一工夫推送。

版权申明： 本文系公众号 “Java 技术栈 ” 原创，转载、援用本文内容请注明出处，剽窃、洗稿一律投诉侵权，后果自负，并保留追究其法律责任的权力。

近期热文举荐：

1.1,000+ 道 Java 面试题及答案整顿 (2022 最新版)

2. 劲爆！Java 协程要来了。。。

3.Spring Boot 2.x 教程，太全了！

4. 别再写满屏的爆爆爆炸类了，试试装璜器模式，这才是优雅的形式！！

5.《Java 开发手册（嵩山版）》最新公布，速速下载！

感觉不错，别忘了顺手点赞 + 转发哦！

退出移动版