阅读 17 SEO

定时任务的线程池默认为1

背景

在真实的Java开发环境中,我们经常会需要用到定时任务来帮助我们完成一些特殊的任务,比如我最近写的晚上11点定时拉取第三方的数据入库,晚上12点清理脏数据等等。

如果我们使用SpringBoot来开发,那么定时任务将会变得非常简单。SpringBoot默认已经帮我们封装好了相关定时任务的组件和配置,我们只需要在相应的地方加上@Schedule注解就可以实现定时任务。

启动定时任务

SpringBoot项目只需要在启动类上加上@EnableScheduling即可开启定时任务

@SpringBootApplication
@EnableScheduling
public class ScheduleTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(ScheduleTestApplication.class, args);
    }

}

创建定时任务

SpringBoot的Scheduler支持四种定时任务格式

  • fixedRate:固定速率执行,例如每3秒执行一次
  • fixedDelay:固定延迟执行,例如距离上一次调用成功后3秒执行
  • initialDelay:初始延迟任务,例如任务开启过3秒后再执行,之后以固定频率或者间隔执行
  • cron:使用 Cron 表达式执行定时任务

以上在企业开发中经常用到的是cron表达式,可以说掌握了cron表达式,基本就掌握了SpringBoot的定时任务了。

使用cron表达式

@Component
public class ScheduleTask {

    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    //每隔5秒执行一次该方法
    @Scheduled(cron = "*/5 * * * * ?")
    public void testScheduleTask() {
        System.out.println("SpringBoot的定时任务" + Thread.currentThread().getName() + sdf.format(new Date()));
    }

}
image

@Schedule默认线程池大小

其实@Schedule默认线程池大小为1,我们可以实验得出这个结论。

@Component
public class ScheduleTask {

    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    //固定2秒执行一次该方法
    @Scheduled(fixedRate = 2000)
    public void testScheduleTask() {
        try{
            Thread.sleep(6000);
            System.out.println("SpringBoot的定时任务" + Thread.currentThread().getName() + sdf.format(new Date()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}
image

结果每隔6秒执行一次,可以看到线程的名字为scheduleing-12021-01-12,表示都是用的同一个线程,默认@Schedule是开启一个线程。

一般情况下使用默认@Schedule没有问题,但是如果有多个定时任务,每个定时任务执行时间可能不短的情况下,会有可能出现定时任务一直没有机会执行的情况。

第一种解决方案:异步执行定时任务

给该方法加上@Async进行异步处理,看看会是什么效果~

@Component
@EnableAsync
public class ScheduleTask {

    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    @Async
    @Scheduled(fixedRate = 2000)
    public void testScheduleTask() {
        try{
            Thread.sleep(6000);
            System.out.println("SpringBoot的定时任务" + Thread.currentThread().getName() + sdf.format(new Date()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}
image

可以看出线程的名字都是不一样的,然后每隔2秒的执行一次该方法,异步处理不受方法内的时间影响,并行执行。

第二种解决方案:调整定时任务的线程池数量

Spring Boot 版本2.1.0之后,可以直接在配置文件中设置 spring.task.scheduling.pool.size 的值来配置计划任务线程池的容量,而不需要额外再写一个类。

spring.task.scheduling.pool.size=5

作者:flyjar

原文链接:https://www.jianshu.com/p/adbbb7e2b6b6

文章分类
后端
文章标签
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 gxwowoo@163.com 举报,一经查实,本站将立刻删除。
相关推荐