Spring Boot 如何解决多个定时任务阻塞问题？
点击关注公众号，Java干货及时送达👇
今天这篇文章介绍一下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.................");
}
总结
本篇文章介绍了Spring Boot 中 实现多线程定时任务的三种方案，你喜欢哪一种？
最近面试BAT，整理一份面试资料《Java面试BATJ通关手册》，覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。
获取方式：点“在看”，关注公众号并回复 Java 领取，更多内容陆续奉上。
PS：因公众号平台更改了推送规则，如果不想错过内容，记得读完点一下“在看”，加个“星标”，这样每次新文章推送才会第一时间出现在你的订阅列表里。
点“在看”支持一下吧😀！
评论