Scheduled定时任务异步执行

news2024/11/19 15:36:38

1.使用配置

我在使用SpringBoot配置定时任务的过程中,使用@Scheduled配置了多个定时任务,但是在项目启动的时候每次只会启动一个定时任务,只好搜索一波,直到看到了 ThreadPoolTaskScheduler的源码,才发现默认开启的线程数是 1

@Configuration
public class ScheduledPoolConfig implements SchedulingConfigurer {


    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(4);
        taskRegistrar.setScheduler(scheduledExecutorService);
    }
}

创建一个线程为四个的线程池

2.使用@Async注解

1.创建线程池

@SpringBootConfiguration
public class SpringAsyncConfig implements AsyncConfigurer {
	 
	 @Bean("taskExecutor")
     public Executor taskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(80);
         executor.setMaxPoolSize(80);
         executor.setQueueCapacity(1000);
         executor.setKeepAliveSeconds(60);
         executor.setThreadNamePrefix("taskExecutor-");
         executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
         return executor;
     }


}

主要参数

一、corePoolSize 线程池核心线程大小

线程池中会维护一个最小的线程数量，即使这些线程处理空闲状态，他们也不会被销毁，除非设置了allowCoreThreadTimeOut。这里的最小线程数量即是corePoolSize。任务提交到线程池后，首先会检查当前线程数是否达到了corePoolSize，如果没有达到的话，则会创建一个新线程来处理这个任务。

二、maximumPoolSize 线程池最大线程数量

当前线程数达到corePoolSize后，如果继续有任务被提交到线程池，会将任务缓存到工作队列（后面会介绍）中。如果队列也已满，则会去创建一个新线程来出来这个处理。线程池不会无限制的去创建新线程，它会有一个最大线程数量的限制，这个数量即由maximunPoolSize指定。

三、keepAliveTime 空闲线程存活时间

一个线程如果处于空闲状态，并且当前的线程数量大于corePoolSize，那么在指定时间后，这个空闲线程会被销毁，这里的指定时间由keepAliveTime来设定

四、unit 空闲线程存活时间单位

keepAliveTime的计量单位

2.主启动类添加@EnableAsync注解开启异步

@SpringBootApplication(exclude= DataSourceAutoConfiguration.class)
@EnableTransactionManagement
@ComponentScan("cn.com.geostar")
@MapperScan("cn.com.geostar.external.mapper")
@ServletComponentScan
@EnableAsync
@EnableScheduling
@EnableDiscoveryClient
@EnableCaching
public class SpringBootStartApplication extends SpringBootServletInitializer {

	public static void main(String[] args) { SpringApplication.run(SpringBootStartApplication.class, args); }

}

在主启动类上添加@EnableAsync注解代表开启异步，如不开启的话，则无法进行异步，此处相当于开关