关于@Scheduled定时任务同一时间只能执行一个任务的问题

约定不等于承诺〃 2023-10-10 22:56 41阅读 0赞

今天在做定时任务时遇到了需要几个定时任务方法同一时间跑的问题，但是在运行过程中发现，当多个任务时只能执行一个任务，其他任务需要等这个任务执行完毕后才能继续执行，经过我大量百度和研究发现了问题所在以及解决方法。

### 一、测试 ###

我创建了一个测试类进行了下测试。

@Component
    @Slf4j
    public class ExecuteTaskJob {
        
        /**
         * 执行除定时存储任务外的所有定时任务(异步执行)
         */
        @Scheduled(cron = "* * * * * ? ")
        public void executeTask() throws InterruptedException {
        
            //获取除定时存储任务外的定时任务,包括历史任务
            System.err.println("测试执行了---------------" + Thread.currentThread().getName());
            TimeUnit.SECONDS.sleep(3);
        }
    
        @Scheduled(cron = "* * * * * ? ")
        public void test() throws InterruptedException {
        
            //获取除定时存储任务外的定时任务,包括历史任务
            System.err.println("测试任务测试执行了---------------" + Thread.currentThread().getName());
        }
    }

执行测试后我发现打印出来的线程名都是一样的，按说应该是不同线程来执行的所以是有问题的。

测试任务测试执行了---------------scheduling-1
    测试执行了---------------scheduling-1
    测试任务测试执行了---------------scheduling-1
    测试执行了---------------scheduling-1

让我带着这个疑问去探索一下。

### 二、探索定时任务为什么不是多线程在执行 ###

让我们打开@EnableScheduling注解

@Target(ElementType.TYPE)
    @Retention(RetentionPolicy.RUNTIME)
    @Import(SchedulingConfiguration.class)
    @Documented
    public @interface EnableScheduling {
        
    
    }

我们打开EnableScheduling 注解后，发现他引入了SchedulingConfiguration类，我们进入到SchedulingConfiguration类中看一下。

@Configuration(proxyBeanMethods = false)
    @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    public class SchedulingConfiguration {
        
    
    	@Bean(name = TaskManagementConfigUtils.SCHEDULED_ANNOTATION_PROCESSOR_BEAN_NAME)
    	@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    	public ScheduledAnnotationBeanPostProcessor scheduledAnnotationProcessor() {
        
    		return new ScheduledAnnotationBeanPostProcessor();
    	}
    
    }

可以看到他创建了一个ScheduledAnnotationBeanPostProcessor对象，我们点到ScheduledAnnotationBeanPostProcessor对象中看一下。

public ScheduledAnnotationBeanPostProcessor() {
        
    		this.registrar = new ScheduledTaskRegistrar();
    	}

点进去后创建了一个ScheduledTaskRegistrar类并赋值了，我们点到ScheduledTaskRegistrar类中。

public class ScheduledTaskRegistrar implements ScheduledTaskHolder, InitializingBean, DisposableBean {

点进去它实现了很多接口，看一下InitializingBean接口。

public interface InitializingBean {
        
    	void afterPropertiesSet() throws Exception;
    }

接口里面的这个方法在ScheduledTaskRegistrar 是被实现了的我们找一下。

@Override
    	public void afterPropertiesSet() {
        
    		scheduleTasks();
    	}

可以看到他调用了一个scheduleTasks方法，我们点进去。

@SuppressWarnings("deprecation")
    	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));
    			}
    		}
    	}

这里最主要的是他判断如果taskScheduler 是空的话就会默认创建一个定时任务的线程池，调用了这个方法 Executors.newSingleThreadScheduledExecutor()，我们点进去看一下。

public static ScheduledExecutorService newSingleThreadScheduledExecutor() {
        
            return new DelegatedScheduledExecutorService
                (new ScheduledThreadPoolExecutor(1));
        }

发现他在创建定时任务的线程池的时候传入了一个1，这个1表示的就是线程的数量就是1，如果不明白的可以自己往里面再点一点，后面就是如何创建线程池了，就不多叙述了。

其实到这里也就看明白了，定时任务自己内部实现的时候创建的线程池是单个的，所以会造成阻塞，那么我们来谈解决方案，我们把他创建称多个的线程池就好了。

### 三、解决定时任务阻塞的问题 ###

我们在启动类里创建一个定时任务的线程池，指定自己的线程数。

@EnableScheduling
    @SpringBootApplication
    public class JobApplication {
        
        public static void main(String[] args) {
        
            SpringApplication.run(JobApplication.class,args);
        }
    
        /**
         * 因为定时器默认创建的线程池为一个线程的所以这里需要改成多个线程的，不然相同时间段任务执行时会等待,因为只有一个线程在工作
         * @return
         */
        @Bean
        public TaskScheduler taskScheduler() {
        
            ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
            taskScheduler.setPoolSize(10);
            return taskScheduler;
        }
    }

至此，定时任务相同时间任务只能执行一个的问题就解决了，我们再来测试一下。

测试任务测试执行了---------------taskScheduler-4
    测试任务测试执行了---------------taskScheduler-6
    测试任务测试执行了---------------taskScheduler-1
    测试任务测试执行了---------------taskScheduler-5
    测试执行了---------------taskScheduler-4
    测试任务测试执行了---------------taskScheduler-5
    测试任务测试执行了---------------taskScheduler-5
    测试任务测试执行了---------------taskScheduler-1
    测试任务测试执行了---------------taskScheduler-8
    测试执行了---------------taskScheduler-4

可以看到，现在执行的时候线程名称已经不再是一个线程在执行任务，证明问题解决了。