使用Spring的@Schedule别忘了这件事
哪件事？
替换@Schedule定时任务的调度器，改变线程池大小，具体数值需要根据自己业务中的定时任务情况来评估。
@Configuration
@Slf4j
public class SchedulingConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
log.info("replace DEFAULT THREAD-POOL of @Schedule");
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setPoolSize(POOL_SIZE);
scheduler.setThreadNamePrefix("schedule-thread-pool-");
scheduler.initialize();
taskRegistrar.setScheduler(scheduler);
}
}
为什么要替换调度器
下面是spring源码的一个片段，当@Schedule执行定时任务时，如果我们没有指定自己的执行器，那么spring就会使用一个默认的执行器，其中是只有一个核心线程数的线程池。如此一来，就会导致一些异常。
protected void scheduleTasks() {
if (this.taskScheduler == null) {
this.localExecutor = Executors.newSingleThreadScheduledExecutor();
this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
}
if (this.triggerTasks != null) {
for (TriggerTask task : this.triggerTasks) {
addScheduledTask(scheduleTriggerTask(task));
}
}
if (this.cronTasks != null) {
for (CronTask task : this.cronTasks) {
addScheduledTask(scheduleCronTask(task));
}
}
if (this.fixedRateTasks != null) {
for (IntervalTask task : this.fixedRateTasks) {
addScheduledTask(scheduleFixedRateTask(task));
}
}
if (this.fixedDelayTasks != null) {
for (IntervalTask task : this.fixedDelayTasks) {
addScheduledTask(scheduleFixedDelayTask(task));
}
}
}
不替换的话有什么问题
@EnableScheduling
@Configuration
@Slf4j
public class XxxJob {
@Scheduled(cron = "0 0 13 * * ? ")
public void taskA(){
log.info("taskA run");
}
@Scheduled(cron = "0 0 13 * * ? ")
public void taskB() throws InterruptedException {
Thread.sleep(100000);
log.info("taskB run");
}
}
有两个本地定时任务taskA和taskB，这两个任务都是需要在13点钟准时执行，但是taskB需要很长时间才能执行完毕，这样就会导致taskA没能准时执行，引起业务上或者逻辑上的异常。
本文参与 腾讯云自媒体分享计划，分享自微信公众号。
原始发表：2021-06-13，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录