springboot设置同一个任务之间并发执行（接上篇）

待我称王封你为后i 2022-04-03 06:07 317阅读 0赞

接[前面一篇][Link 1]文章中，讲了如何设置**不同任务之间**的并发执行。没有说明单任务的并发执行  
在这里，再说明下。  
单任务并发执行，使用@Async注解，自定义一个线程池。因为@Async默认线程池是100，一般用不了这么多。  
**注**：**@Async注解只能实现同一个任务的并发执行**，如果需要实现不同任务之间的并发执行，则需要参考[**前一篇**][Link 1]文章。

#### @Async的使用 ####

@Async自定义线程池：

@EnableAsync
    @Configuration
    public class TaskPoolConfig { 
        @Bean("taskExecutor")
        public Executor taskExecutor() { 
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
            executor.setCorePoolSize(10);
            executor.setMaxPoolSize(20);
            executor.setQueueCapacity(200);
            executor.setKeepAliveSeconds(60);
            executor.setThreadNamePrefix("taskExecutorTest-");
            executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
            return executor;
        }
    }

测试

结果：可以发现，任务没5秒执行一次，并没有阻塞  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70]

### 注意： ###

@Async(“taskExecutor”)只能保证同一个任务可以并发执行，但如果有多个不同的任务，任务执行会阻塞。

如果把task改成下面，观察任务一和任务二：

@Service
    @EnableAsync
    public class Task { 
        @Scheduled(cron = "*/5 * * * * ?")
        @Async("taskExecutor")
        public void task1() throws InterruptedException { 
            System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " " + Thread.currentThread().getName() + " 任务一启动");
            Thread.sleep(10000);
            System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " " + Thread.currentThread().getName() + " 任一结束");
    
        }
    
        @Scheduled(cron = "*/5 * * * * ?")
        public void task2() throws InterruptedException { 
            System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " " + Thread.currentThread().getName() + " 任务二启动");
            Thread.sleep(100000000);// 这里时间设置长一点，假设任务长时间阻塞
            System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " " + Thread.currentThread().getName() + " 任二结束");
        }
    }

结果：可以看到控制台只输出了一个“任务二”，因为任务二阻塞了任务一  
![在这里插入图片描述][20181220175037941.png]  
解决办法如下

### 同时实现同一个任务并发和不同任务之间并发执行 ###

所以如果要想多个任务之间并发执行，@Async并不满足，在上面配置基础上，则另外加入一个线程池配置。方法如下，选择其一即可。  
方法一、

@Configuration
    public class TestConfiguration implements SchedulingConfigurer { 
    
        @Override
        public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { 
            taskRegistrar.setScheduler(TaskScheduler());
        }
        @Bean(destroyMethod = "shutdown")
        public Executor TaskScheduler() { 
            return Executors.newScheduledThreadPool(10);
        }
    }

方法二：

@Configuration
    public class TestConfiguration { 
    
        @Bean(destroyMethod = "shutdown")
        public Executor TesttaskScheduler222() { 
            return Executors.newScheduledThreadPool(10);
        }
    }

方法三：

@Configuration
    public class TestConfiguration{ 
    
        @Bean
        public TaskScheduler taskScheduler(){ 
            ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
            taskScheduler.setPoolSize(10);
            taskScheduler.initialize();
            return taskScheduler;
        }
    }

结果:可以看到，即使任务二长时间阻塞了，任务一依然可以同时执行。  
![在这里插入图片描述][20181220185541300.png]

[Link 1]: https://blog.csdn.net/a718515028/article/details/80396102
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70]: /images/20220403/8ffad4b060b1435eab463fc79b67e303.png
[20181220175037941.png]: /images/20220403/a6c5b987f134496e8eafbdb4e0a11967.png
[20181220185541300.png]: /images/20220403/1f8a104778c44662b8a1e0b78a09c4f9.png