如何進(jìn)行springboot2.0以上調(diào)度器配置線程池的實(shí)現(xiàn)

如何進(jìn)行springboot2.0以上調(diào)度器配置線程池的實(shí)現(xiàn)，相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

一 我們使用@EnableScheduling 開啟spring task 調(diào)度器的時(shí)候，發(fā)現(xiàn)此調(diào)度器默認(rèn)配置為單線程的。

二 打開注解發(fā)現(xiàn)其配置信息在此SchedulingConfiguration類中。發(fā)現(xiàn)其創(chuàng)建了ScheduledTaskRegistrar類研讀代碼不難發(fā)現(xiàn)調(diào)度器默認(rèn)配置是如下代碼，線程池為單線程的。

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 運(yùn)行在多線程環(huán)境中。

看完上述內(nèi)容，你們掌握如何進(jìn)行springboot2.0以上調(diào)度器配置線程池的實(shí)現(xiàn)的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！