美文网首页
为什么我的定时器不跑了

为什么我的定时器不跑了

作者: 阿亚2011 | 来源:发表于2019-11-15 21:11 被阅读0次

最近要搞个小服务运行在多家客户的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阻塞被阻塞了,所有定时器都不跑了。

相关文章

  • 为什么我的定时器不跑了

    最近要搞个小服务运行在多家客户的windows服务器上,里面有两个定时任务,一个是定时检查版本号,一个是定时向服务...

  • IOS常见问题分析

    1、定时器问题 1) 定时器在子线程中不启动: 子线程中启动定时器的方法:

  • swift Timer 定时器

    方式1 方式2 这种定时器的创建需要使用 fire 来启动定时器。否则,该定时器不起作用。如果定时器不添加到 Ru...

  • 横板格斗类游戏实战:定时器Timer模块设计

    Cocos Creator 代码组件自己带了Schedule定时器的功能为什么我们还要自己开发定时器Timer模块...

  • 我为什么不怕我的“老婆”跑了

    ——我老婆最萌! ——除了老婆剩下的我都出了! 作为一个玩家,穿梭在各个游戏群的时候,关于“老婆”的嘶吼总是不绝于...

  • iOS延迟执行的常用方法

    1、NSTimer(不阻塞线程)//创建一个定时器 //延迟要做的事 //取消定时器 2、performSelec...

  • [定时器]使用NSTimer定时器出现内存泄漏问题

    有没有发现在使用NSTimer类的定时器,实现定时器的类并没有走dealloc方法?这是为什么? NSTimer常...

  • 我的🐖跑了

    我有一只狮子 他是一只猪 他跑我等 他归我等 为什么总是跑掉呢 不够喜欢我 为什么总是守不住呢 对他不够好 我的猪...

  • 2017-06-21

    如此基本的定义就可以了,实在不懂为什么还要添加定时器和增添回调函数 谁能告诉我设定时器和立flag的意义在哪

  • 刘淑芬,除了去死,你有N种方式走出僵尸婚姻

    看完《无问西东》,朋友感慨说,陈鹏看到李想握住王敏佳的手臂为什么转头就跑了,面对爱情为什么不勇敢的争取?我说,那个...

网友评论

      本文标题:为什么我的定时器不跑了

      本文链接:https://www.haomeiwen.com/subject/xbfeictx.html