Scheduled定时任务异步执行

「爱情、让人受尽委屈。」 2023-10-02 23:37 21阅读 0赞

### 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注解代表开启异步，如不开启的话，则无法进行异步，此处相当于开关

#### 3.在定时任务中添加注解@Async ####

![2bd665e3ee5546359e59d59daec581b8.png][]

在定时任务上面添加注解@Async注解，注解中的value代表线程池，如果没有自定义的线程池，可以无需填写，系统回使用默认的线程池使用，使用自定义线程池是为了方便管理

[2bd665e3ee5546359e59d59daec581b8.png]: https://img-blog.csdnimg.cn/2bd665e3ee5546359e59d59daec581b8.png