高防服务器

Spring Boot多个定时任务阻塞问题的解决方法是什么


Spring Boot多个定时任务阻塞问题的解决方法是什么

发布时间:2022-01-05 15:23:34 来源:高防服务器网 阅读:82 作者:柒染 栏目:开发技术

Spring Boot多个定时任务阻塞问题的解决方法是什么,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。

前言

今天介绍一下Spring Boot 中 如何开启多线程定时任务?

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

想要解释为什么,一定要从源码入手,直接从@EnableScheduling这个注解入手,找到了这个ScheduledTaskRegistrar类,其中有一段代码如下:

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

如果taskScheduler为null,则创建单线程的线程池:Executors.newSingleThreadScheduledExecutor()。

多线程定时任务如何配置?

下面介绍三种方案配置多线程下的定时任务。

1、重写SchedulingConfigurer#configureTasks()

直接实现SchedulingConfigurer这个接口,设置taskScheduler,代码如下:

@Configuration  public class ScheduleConfig implements SchedulingConfigurer {      @Override      public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {          //设定一个长度10的定时任务线程池          taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));      }  }

2、通过配置开启

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

spring.task.scheduling.pool.size=10

只需要在配置文件中添加如上的配置即可生效!

3、结合@Async

@Async这个注解都用过,用来开启异步任务的,使用@Async这个注解之前一定是要先配置线程池的,配置如下:

    @Bean      public ThreadPoolTaskExecutor taskExecutor() {          ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();          poolTaskExecutor.setCorePoolSize(4);          poolTaskExecutor.setMaxPoolSize(6);          // 设置线程活跃时间(秒)          poolTaskExecutor.setKeepAliveSeconds(120);          // 设置队列容量          poolTaskExecutor.setQueueCapacity(40);          poolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());          // 等待所有任务结束后再关闭线程池          poolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true);          return poolTaskExecutor;      }

然后在@Scheduled方法上标注@Async这个注解即可实现多线程定时任务,代码如下:

 @Async      @Scheduled(cron = "0/2 * * * * ? ")      public void test2() {          System.out.println("..................执行test2.................");      }

看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注高防服务器网行业资讯频道,感谢您对高防服务器网的支持。

[微信提示:高防服务器能助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。

[图文来源于网络,不代表本站立场,如有侵权,请联系高防服务器网删除]
[