Spring Boot ThreadPoolTaskExecutor使用

快来打我* 2022-03-15 02:24 207阅读 0赞

*  初始化线程池

@Configuration
    @EnableAsync
    public class TaskExecutorConfiguration implements AsyncConfigurer {
    
        @Override
        public Executor getAsyncExecutor() {
            ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
            taskExecutor.setKeepAliveSeconds(1000);// 空闲时间
            taskExecutor.setCorePoolSize(5);// 线程池大小
            taskExecutor.setMaxPoolSize(10);// 线程池最大线程数
            taskExecutor.setQueueCapacity(25);// 最大等待任务数
            taskExecutor.initialize();
            return taskExecutor;
        }
    
        @Override
        public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
            return null;
        }
    
    }

>  *  `corePoolSize` 线程池维护线程的最少数量
>  *  `keepAliveSeconds` 线程池维护线程所允许的空闲时间
>  *  `maxPoolSize` 线程池维护线程的最大数量
>  *  `queueCapacity` 线程池所使用的缓冲队列

当一个任务通过execute(Runnable)方法欲添加到线程池时：

>  *  如果此时线程池中的数量小于`corePoolSize`，即使线程池中的线程都处于空闲状态，也要创建新的线程来处理被添加的任务。
>  *  如果此时线程池中的数量等于 `corePoolSize`，但是缓冲队列`workQueue`未满，那么任务被放入缓冲队列。
>  *  如果此时线程池中的数量大于`corePoolSize`，缓冲队列`workQueue`满，并且线程池中的数量小于`maximumPoolSize`，建新的线程来处理被添加的任务。
>  *  如果此时线程池中的数量大于`corePoolSize`，缓冲队列`workQueue`满，并且线程池中的数量等于`maximumPoolSize`，那么通过 handler所指定的策略来处理此任务。也就是：处理任务的优先级为：核心线程`corePoolSize`、任务队列`workQueue`、最大线程 `maximumPoolSize`，如果三者都满了，使用handler处理被拒绝的任务。
>  *  当线程池中的线程数量大于 `corePoolSize`时，如果某线程空闲时间超过`keepAliveTime`，线程将被终止。这样，线程池可以动态的调整池中的线程数。

*  创建异步任务类

@Slf4j
    @Service("asyncService")
    public class AsyncService {
    
        @Async
        public void executorAsyncTask(String name){
            log.info("执行异步：{}" ,name);
        }
    }

> @Slf4j是`lombok`注解，自动注入`log`对象

*  测试类

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class SpringBootTempleteApplicationTests {
        
        @Autowired
        private AsyncService asyncService;
    
        @Test
        public void testThread() {
            for(int i=0; i < 10;i++) {
                asyncService.executorAsyncTask(i + "");
            }
        }
    }

方式二

@Service
    public class Test{
       @Autowired
        private ThreadPoolTaskExecutor threadPoolTaskExecutor;
     
     threadPoolTaskExecutor.submit(() -> {
                    dosomething();
                }).get();
            } catch (InterruptedException | ExecutionException e) {
                throw e;
            }
    }

*  输出

> 执行异步：0  
> 执行异步：5  
> 执行异步：6  
> 执行异步：7  
> 执行异步：8  
> 执行异步：9  
> 执行异步：3  
> 执行异步：2  
> 执行异步：4  
> 执行异步：1