CompletableFuture使用IOC容器中自定义线程池
- 创建自定义线程池,并交给ioc容器管理
@Configuration
public class ThreadPoolConfig {
@Bean
public Executor asyncServiceExecutor(){
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(8);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(100);
executor.setKeepAliveSeconds(60);
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.setThreadNamePrefix("qzzThread");
executor.initialize();
return executor;
}
}
- 新建一个类,使用
@Autowired
配合@Qualifier
注解注入我们自定义线程池
@Component
@Async //该类下所有方法都会另起线程执行
public class MyTest {
@Autowired
@Qualifier("asyncServiceExecutor") //注入指定名称的bean
private Executor executor;
public CompletableFuture<String> future() throws Exception {
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
System.err.println(Thread.currentThread().getName() + ":执行了");
return "1号选手";
}, executor).whenComplete((res, e) -> {
System.err.println(Thread.currentThread().getName() + ":2执行了");
res += "--2号选手";
System.err.println(res + "-" + e);
});
System.err.println(future.get());
return future;
}
}
- 最终效果