最近长文撸多了, 有点累, 今天来点简单的.
今天这篇文章介绍一下 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 中 实现多线程定时任务的三种方案, 你喜欢哪一种?
来源: http://developer.51cto.com/art/202201/697762.htm