SpringBoot中定时任务开启多线程避免多任务堵塞

左手的ㄟ右手 2023-10-14 04:15 18阅读 0赞

## 场景 ##

SpringBoot中定时任务与异步定时任务的实现：

[SpringBoot中定时任务与异步定时任务的实现\_霸道流氓气质的博客-CSDN博客][SpringBoot_-CSDN]

使用SpringBoot原生方式实现定时任务，已经开启多线程支持，以上是方式之一。

除此之外还可通过如下方式。

为什么Spring Boot 定时任务是单线程的？

查看注解@EnableScheduling源码可知

protected void scheduleTasks() {
            if (this.taskScheduler == null) {
                this.localExecutor = Executors.newSingleThreadScheduledExecutor();
                this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
            }

![b7cdc43ffc914134ab2837a980d2130c.png][]

![Image 1][]

为了验证单线程，所以编写模拟堵塞的测试方法

import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    import java.time.LocalDateTime;
    import java.util.concurrent.TimeUnit;
    
    @Component
    @EnableScheduling
    public class TestTask {
    
        @Scheduled(fixedRateString = "15000")
        public void  test1() throws InterruptedException {
            System.out.println("task1:"+LocalDateTime.now());
            //moni  yanchi
            TimeUnit.SECONDS.sleep(10);
        }
    
        @Scheduled(fixedRateString = "3000")
        public void  test2() {
            System.out.println("task2:"+LocalDateTime.now());
        }
    }

执行结果

![ea5285b8d90d41f597f886bb48f99432.png][]

![Image 1][]

注：

博客：  
[霸道流氓气质\_C\#,架构之路,SpringBoot-CSDN博客][C_SpringBoot-CSDN]

## 实现 ##

1、方案一

Spring Boot quartz 已经提供了一个配置用来配置线程池的大小

添加如下配置

spring:
      task:
        scheduling:
          pool:
            size: 10

再次进行堵塞测试发现正常

![84d0f9f2a87d4784a69170b8f0341c39.png][]

![Image 1][]

2、方案二

重写SchedulingConfigurer\#configureTasks()

import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.SchedulingConfigurer;
    import org.springframework.scheduling.config.ScheduledTaskRegistrar;
    import java.util.concurrent.Executors;
    
    //直接实现SchedulingConfigurer这个接口，设置taskScheduler
    @Configuration
    public class ScheduleConfig implements SchedulingConfigurer {
        @Override
        public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
            taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));
        }
    }

3、方案三

参考上面结合@Async的方式。

[SpringBoot_-CSDN]: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/117083609
[b7cdc43ffc914134ab2837a980d2130c.png]: https://img-blog.csdnimg.cn/b7cdc43ffc914134ab2837a980d2130c.png
[Image 1]: 
[ea5285b8d90d41f597f886bb48f99432.png]: https://img-blog.csdnimg.cn/ea5285b8d90d41f597f886bb48f99432.png
[C_SpringBoot-CSDN]: https://blog.csdn.net/badao_liumang_qizhi
[84d0f9f2a87d4784a69170b8f0341c39.png]: https://img-blog.csdnimg.cn/84d0f9f2a87d4784a69170b8f0341c39.png