我们在实际项目中有些复杂运算、耗时操作，就可以利用多线程来充分利用CPU，提高系统吞吐量。SpringBoot对多线程支持非常好，对我们的开发非常便捷。
1.需要的注解
springboot 配置多线程需要两个注解
- @EnableAsync
在配置类中通过加@EnableAsync开启对异步任务的支持 - @Async
在需要执行的方法上加@Async表明该方法是个异步方法，如果加在类级别上，则表明类所有的方法都是异步方法
2.配置代码
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
//核心线程数
taskExecutor.setCorePoolSize(8);
//最大线程数
taskExecutor.setMaxPoolSize(16);
//队列大小
taskExecutor.setQueueCapacity(100);
taskExecutor.initialize();
return taskExecutor;
}
}
3.Service
@Service
public class AsyncService {
@Async
public void executeAsync1() {
Thread.sleep(20);
System.out.println("异步任务::1");
}
@Async
public void executeAsync2() {
System.out.println("异步任务::2");
}
}
【注】这里的方法自动被注入使用上文配置的ThreadPoolTaskExecutor
4.测试代码
@Resource
private AsyncService asyncService;
@Test
public void asyncTest() throws InterruptedException {
for (int i = 0; i < 10; i++) {
asyncService.executeAsync1();
asyncService.executeAsync2();
}
Thread.sleep(1000);
}
5.运行结果
异步任务::2
异步任务::2
异步任务::2
异步任务::2
异步任务::2
异步任务::2
异步任务::2
异步任务::1
异步任务::1
异步任务::1
异步任务::1
异步任务::1
异步任务::1
异步任务::1
异步任务::1
异步任务::2
异步任务::2
异步任务::2
异步任务::1
异步任务::1
【注】本文基于SpringBoot 2.0
感谢《Spring Boot实战 JavaEE开发的颠覆者》
