如何進行springboot2.0以上調度器配置線程池的實現

如何進行springboot2.0以上調度器配置線程池的實現，相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。

一 我們使用@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以上調度器配置線程池的實現的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！