一 我们使用@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 运行在多线程环境中。