最近要搞个小服务运行在多家客户的windows服务器上,里面有两个定时任务,一个是定时检查版本号,一个是定时向服务器汇报状态,都使用 spring 的@Scheduled实现。
昨天晚上让它们跑着,今天上午一看,居然没有汇报状态了,(无奈,肯定有bug)。
登录服务器,看到服务还在运行,看了一下没有打日志了,访问端口有数据返回,那这个服务应该还活着,定时器不跑了?
没有太多的办法,老实下载了一个jdk安装, jstack看一下,发现定时任务线程被阻塞了,而且居然是被RestTemplate阻塞的,想了一下,这个阻塞的原理可能比较复杂,暂不追究。
解决办法挺简单,老实地去设置了超时时间,想必下次不会阻塞这么久了。
等等,为什么我两个定时器,一个线程阻塞了,还有一个去哪儿了? 这个不会是单线程吧?!
找到日志看一下,确实只有一个叫schedule-1的线程在跑,==!
有点超出我的想像,需要来看下源码压压惊。
分析Spring的定时任务框架为什么线程是1, 从文档入手,很好,在文档中看到了配置类:
通过SchedulingConfiguration的初始化,创建了ScheduledAnnotationBeanPostProcessor来扫描代码创建定时任务。
查看初始过程,发现创建TaskScheduler的创建过程:
// Search for TaskScheduler bean...
this.registrar.setTaskScheduler(resolveSchedulerBean(this.beanFactory, TaskScheduler.class, false));
beanFactory是DefaultListableBeanFactory, 查看resolveSchedulerBean中代码:
private <T> T resolveSchedulerBean(BeanFactory beanFactory, Class<T> schedulerType, boolean byName) {
if (byName) {
//...
return scheduler;
}
else if (beanFactory instanceof AutowireCapableBeanFactory) {
NamedBeanHolder<T> holder = ((AutowireCapableBeanFactory) beanFactory).resolveNamedBean(schedulerType);
if (this.beanName != null && beanFactory instanceof ConfigurableBeanFactory) {
((ConfigurableBeanFactory) beanFactory).registerDependentBean(holder.getBeanName(), this.beanName);
}
return holder.getBeanInstance();
}
else {
return beanFactory.getBean(schedulerType);
}
}
这段是用beanFactory找到TaskScheduler.class的bean,并注册依赖关系。
好吧,找下哪里配置了TaskScheduler,然后发现了TaskSchedulingAutoConfiguration:
@Bean
@ConditionalOnBean(name = TaskManagementConfigUtils.SCHEDULED_ANNOTATION_PROCESSOR_BEAN_NAME)
@ConditionalOnMissingBean({ SchedulingConfigurer.class, TaskScheduler.class,
ScheduledExecutorService.class })
public ThreadPoolTaskScheduler taskScheduler(TaskSchedulerBuilder builder) {
return builder.build();
}
@Bean
@ConditionalOnMissingBean
public TaskSchedulerBuilder taskSchedulerBuilder(TaskSchedulingProperties properties,
ObjectProvider<TaskSchedulerCustomizer> taskSchedulerCustomizers) {
TaskSchedulerBuilder builder = new TaskSchedulerBuilder();
builder = builder.poolSize(properties.getPool().getSize());
builder = builder.threadNamePrefix(properties.getThreadNamePrefix());
builder = builder.customizers(taskSchedulerCustomizers);
return builder;
}
可以看到这里设置了poolSize, 配置来自TaskSchedulingProperties, 激动人心的时候到了,来看下TaskSchedulingProperties:
@ConfigurationProperties("spring.task.scheduling")
public class TaskSchedulingProperties {
//...
public static class Pool {
/**
* Maximum allowed number of threads.
*/
private int size = 1;
public int getSize() {
return this.size;
}
public void setSize(int size) {
this.size = size;
}
}
}
好吧,除了http阻塞的问题,一切都明白了。
spring boot 默认开启单线程的定时任务执行器, 然后某个定时器因为http阻塞被阻塞了,所有定时器都不跑了。