Spring Boot 如何解决多个定时任务阻塞问题?

时间:2022-03-18 04:10:51

Spring Boot 如何解决多个定时任务阻塞问题?

最近长文撸多了,有点累,今天来点简单的。

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

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

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

  1. protected void scheduleTasks() {
  2. if (this.taskScheduler == null) {
  3. this.localExecutor = Executors.newSingleThreadScheduledExecutor();
  4. this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
  5. }
  6. }

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

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

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

1、重写SchedulingConfigurer#configureTasks()

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

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

2、通过配置开启

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

  1. spring.task.scheduling.pool.size=10

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

3、结合@Async

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

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

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

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

总结

本篇文章介绍了Spring Boot 中 实现多线程定时任务的三种方案,你喜欢哪一种?

原文链接:https://mp.weixin.qq.com/s/b_pIs6nKiINRDzowmxW2Ww