共计 2991 个字符,预计需要花费 8 分钟才能阅读完成。
背景
昨天,咱们的《常识星球: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 开发手册(嵩山版)》最新公布,速速下载!
感觉不错,别忘了顺手点赞 + 转发哦!