springboot2.0以上调度器配置线程池的实现
2020-03-11 17:51
756 查看
一 我们使用@EnableScheduling 开启spring task 调度器的时候,发现此调度器默认配置为单线程的。
二 打开注解发现其配置信息在此SchedulingConfiguration类中。发现其创建了ScheduledTaskRegistrar类
研读代码不难发现调度器默认配置是如下代码,线程池为单线程的。
protected void scheduleTasks() { if (this.taskScheduler == null) { this.localExecutor = Executors.newSingleThreadScheduledExecutor(); this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor); } if (this.triggerTasks != null) { for (TriggerTask task : this.triggerTasks) { addScheduledTask(scheduleTriggerTask(task)); } } if (this.cronTasks != null) { for (CronTask task : this.cronTasks) { addScheduledTask(scheduleCronTask(task)); } } if (this.fixedRateTasks != null) { for (IntervalTask task : this.fixedRateTasks) { addScheduledTask(scheduleFixedRateTask(task)); } } if (this.fixedDelayTasks != null) { for (IntervalTask task : this.fixedDelayTasks) { addScheduledTask(scheduleFixedDelayTask(task)); } } }
如何改变此配置呢?
如果想改变其中配置则只需要如下核心代码
package com.ccbobe.common.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.config.ScheduledTaskRegistrar; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; @EnableScheduling @Configuration public class SchedulerConfig implements SchedulingConfigurer { @Bean public ScheduledExecutorService concurrentTaskScheduler(){ ScheduledThreadPoolExecutor executorService = new ScheduledThreadPoolExecutor(20); executorService.setMaximumPoolSize(20); executorService.setRejectedExecutionHandler(new ScheduledThreadPoolExecutor.CallerRunsPolicy()); return executorService; } @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setScheduler(concurrentTaskScheduler()); } }
其中Scheduler 支持两种,种分别是:TaskScheduler 和 ScheduledExecutorService
/** * Set the {@link TaskScheduler} to register scheduled tasks with, or a * {@link java.util.concurrent.ScheduledExecutorService} to be wrapped as a * {@code TaskScheduler}. */ public void setScheduler(@Nullable Object scheduler) { if (scheduler == null) { this.taskScheduler = null; } else if (scheduler instanceof TaskScheduler) { this.taskScheduler = (TaskScheduler) scheduler; } else if (scheduler instanceof ScheduledExecutorService) { this.taskScheduler = new ConcurrentTaskScheduler(((ScheduledExecutorService) scheduler)); } else { throw new IllegalArgumentException("Unsupported scheduler type: " + scheduler.getClass()); } }
完成以上配置,即可让spring task 运行在多线程环境中。
以上就是本文的全部内容,希望对大家的学习有所帮助
您可能感兴趣的文章:
相关文章推荐
- SpringBoot2.0 基础案例(16):配置Actuator组件,实现系统监控
- SpringBoot2.0 基础案例(15):配置MongoDB数据库,实现增删改查逻辑
- 直接使用security.basic.path无效|——springboot2.0以上的security的配置
- SpringBoot2.0 基础案例(14):基于Yml配置方式,实现文件上传逻辑
- springboot2.0以上配置拦截器
- SpringBoot2.0 基础案例(15):配置MongoDB数据库,实现增删改查逻辑
- SpringBoot2.0 基础案例(02):配置Log4j2,实现不同环境日志打印
- SpringBoot2.0 基础案例(16):配置Actuator组件,实现系统监控
- SpringBoot 线程池配置 实现AsyncConfigurer接口方法
- spring boot 2.0以上版本 配置https,并且输入http自动转为https
- SpringBoot2.0 基础案例(14):基于Yml配置方式,实现文件上传逻辑
- SpringBoot2.0 基础案例(02):配置Log4j2,实现不同环境日志打印
- springboot2.0以上整合security的基本环境搭建,注解实现角色控制。
- SpringBoot2.0 基础案例(15):配置MongoDB数据库,实现增删改查逻辑
- spring boot 集成quartz 2.0 实现前端动态配置(获取spring上下文)的两种方式,启动数据库中已开启定时任务
- SpringBoot学习教程 - 02 - 配置DevTools,实现热部署
- Spring Boot 揭秘与实战 自己实现一个简单的自动配置模块
- spring-boot 线程池 @Async 的使用、自定义Executor的配置方法
- Spring-Boot 多数据源配置+动态数据源切换+多数据源事物配置实现主从数据库存储分离
- SpringBoot下如何配置实现跨域请求?