SpringBoot如何优雅的使⽤多线程实例详解
前⾔
本⽂带你快速了解@Async注解的⽤法，包括异步⽅法⽆返回值、有返回值，最后总结了@Async注解失效的⼏个坑。
在 SpringBoot 应⽤中，经常会遇到在⼀个接⼝中，同时做事情1，事情2，事情3，如果同步执⾏的话，则本次接⼝时间取决于事情1 2 3执⾏时间之和；如果三件事同时执⾏，则本次接⼝时间取决于事情1 2 3执⾏时间最长的那个，合理使⽤多线程，可以⼤⼤缩短接⼝时间。那么在 SpringBoot 应⽤中如何优雅的使⽤多线程呢？
Don't bb, show me code.
快速使⽤
SpringBoot应⽤中需要添加@EnableAsync注解，来开启异步调⽤，⼀般还会配置⼀个线程池，异步的⽅法交给特定的线程池完成，如下：
@Configuration
@EnableAsync
public class AsyncConfiguration {
@Bean("doSomethingExecutor")
public Executor doSomethingExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 核⼼线程数：线程池创建时候初始化的线程数
executor.setCorePoolSize(10);
// 最⼤线程数：线程池最⼤的线程数，只有在缓冲队列满了之后才会申请超过核⼼线程数的线程
executor.setMaxPoolSize(20);
// 缓冲队列：⽤来缓冲执⾏任务的队列
executor.setQueueCapacity(500);
/
/ 允许线程的空闲时间60秒：当超过了核⼼线程之外的线程在空闲时间到达之后会被销毁
executor.setKeepAliveSeconds(60);
// 线程池名的前缀：设置好了之后可以⽅便我们定位处理任务所在的线程池
executor.setThreadNamePrefix("do-something-");
// 缓冲队列满了之后的拒绝策略：由调⽤线程处理（⼀般是主线程）
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
executor.initialize();
return executor;
}
}
使⽤的⽅式⾮常简单，在需要异步的⽅法上加@Async注解
@RestController
public class AsyncController {
@Autowired
private AsyncService asyncService;
@GetMapping("/open/something")
public String something() {
int count = 10;
for (int i = 0; i < count; i++) {
asyncService.doSomething("index = " + i);
}
return "success";
}
}
@Slf4j
@Service
public class AsyncService {
// 指定使⽤beanname为doSomethingExecutor的线程池
@Async("doSomethingExecutor")
public String doSomething(String message) {
log.info("do something, message={}", message);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
<("do something error: ", e);
}
return message;
}
}
访问：127.0.0.1:8080/open/something，⽇志如下
2020-04-19 23:42:42.486  INFO 21168 --- [io-8200-exec-17] x.g.ller.AsyncController  : do
something end, time 8 milliseconds
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-1] x.gits.boot.system.service.AsyncService  : do
something, message=index = 0
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-5] x.gits.boot.system.service.AsyncService  : do
something, message=index = 4
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-4] x.gits.boot.system.service.AsyncService  : do
something, message=index = 3
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-6] x.gits.boot.system.service.AsyncService  : do
something, message=index = 5
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-9] x.gits.boot.system.service.AsyncService  : do
something, message=index = 8
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-8] x.gits.boot.system.service.AsyncService  : do
something, message=index = 7
2020-04-19 23:42:42.488  INFO 21168 --- [do-something-10] x.gits.boot.system.service.AsyncService  : do
something, message=index = 9
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-7] x.gits.boot.system.service.AsyncService  : do
something, message=index = 6
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-2] x.gits.boot.system.service.AsyncService  : do
something, message=index = 1
2020-04-19 23:42:42.488  INFO 21168 --- [ do-something-3] x.gits.boot.system.service.AsyncService  : do
something, message=index = 2
由此可见已经达到异步执⾏的效果了，并且使⽤到了咱们配置的线程池。
获取异步⽅法返回值
当异步⽅法有返回值时，如何获取异步⽅法执⾏的返回结果呢？这时需要异步调⽤的⽅法带有返回值CompletableFuture。CompletableFuture是对Feature的增强，Feature只能处理简单的异步任务，⽽CompletableFuture可以将多个异步任务进⾏复杂的组合。如下：
@RestController
public class AsyncController {
@Autowired
private AsyncService asyncService;
@SneakyThrows
@ApiOperation("异步有返回值")
@GetMapping("/open/somethings")
public String somethings() {
CompletableFuture<String> createOrder = asyncService.doSomething1("create order");
CompletableFuture<String> reduceAccount = asyncService.doSomething2("reduce account");
CompletableFuture<String> saveLog = asyncService.doSomething3("save log");
// 等待所有任务都执⾏完
CompletableFuture.allOf(createOrder, reduceAccount, saveLog).join();
// 获取每个任务的返回结果
String result = () + () + ();
return result;
}
}
@Slf4j
@Service
public class AsyncService {
@Async("doSomethingExecutor")
public CompletableFuture<String> doSomething1(String message) throws InterruptedException {
log.info("do something1: {}", message);
Thread.sleep(1000);
return CompletableFuturepletedFuture("do something1: " + message);
}
@Async("doSomethingExecutor")
public CompletableFuture<String> doSomething2(String message) throws InterruptedException {
log.info("do something2: {}", message);
Thread.sleep(1000);
return CompletableFuturepletedFuture("; do something2: " + message);
}
@Async("doSomethingExecutor")
public CompletableFuture<String> doSomething3(String message) throws InterruptedException {
log.info("do something3: {}", message);
Thread.sleep(1000);
return CompletableFuturepletedFuture("; do something3: " + message);
}
}
访问接⼝
C:\Users\Administrator>curl -X GET "localhost:8200/open/somethings" -H "accept: */*"
do something1: create order; do something2: reduce account; do something3: save log
控制台上关键⽇志如下：
2020-04-20 00:27:42.238  INFO 5672 --- [ do-something-3] x.gits.boot.system.service.AsyncService  : dogit使用详解
something3: save log
2020-04-20 00:27:42.238  INFO 5672 --- [ do-something-2] x.gits.boot.system.service.AsyncService  : do
something2: reduce account
2020-04-20 00:27:42.238  INFO 5672 --- [ do-something-1] x.gits.boot.system.service.AsyncService  : do
something1: create order
注意事项
@Async注解会在以下⼏个场景失效，也就是说明明使⽤了@Async注解，但就没有⾛多线程。
异步⽅法使⽤static关键词修饰；
异步类不是⼀个Spring容器的bean（⼀般使⽤注解@Component和@Service，并且能被Spring扫描到）；
SpringBoot应⽤中没有添加@EnableAsync注解；
在同⼀个类中，⼀个⽅法调⽤另外⼀个有@Async注解的⽅法，注解不会⽣效。原因是@Async注解的⽅法，是在代理类中执⾏的。
需要注意的是：
异步⽅法使⽤注解@Async的返回值只能为void或者Future及其⼦类，当返回结果为其他类型时，⽅法还是会异步执⾏，但是返回值都是null，部分源码如下：
AsyncExecutionInterceptor#invoke
通过上边⼏个⽰例，@Async实际还是通过Future或CompletableFuture来异步执⾏的，Spring⼜封装了⼀下，让我们使⽤的更⽅便。
本⽂⽰例代码：… ，搜索AsyncController可得。
总结
到此这篇关于Spring Boot如何优雅的使⽤多线程的⽂章就介绍到这了，更多相关Spring Boot优雅使⽤多线程内容请搜索以前的⽂章或继续浏览下⾯的相关⽂章希望⼤家以后多多⽀持！

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。