189 8069 5689
如何进行springboot2.0以上调度器配置线程池的实现，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
我们提供的服务有：网站制作、做网站、微信公众号开发、网站优化、网站认证、神池ssl等。为上千企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务，是有科学管理、有技术的神池网站制作公司
一 我们使用@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@Configurationpublic 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以上调度器配置线程池的实现的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注创新互联行业资讯频道，感谢各位的阅读！