SpringBoot中如何优雅的使用多线程

　　在SpringBoot应用中，经常会遇到在一个接口中，同时做事情1，事情2，事情3，如果同步执行的话，则本次接口时间取决于事情123执行时间之和；如果三件事同时执行，则本次接口时间取决于事情123执行时间最长的那个，合理使用多线程，可以大大缩短接口时间。那么在SpringBoot应用中如何优雅的使用多线程呢？
　　Dontbb，showmecode。快速使用
　　SpringBoot应用中需要添加EnableAsync注解，来开启异步调用，一般还会配置一个线程池，异步的方法交给特定的线程池完成，如下：ConfigurationEnableAsyncpublicclassAsyncConfiguration｛Bean（doSomethingExecutor）publicExecutordoSomethingExecutor（）｛ThreadPoolTaskExecutorexecutornewThreadPoolTaskExecutor（）；核心线程数：线程池创建时候初始化的线程数executor。setCorePoolSize（10）；最大线程数：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程executor。setMaxPoolSize（20）；缓冲队列：用来缓冲执行任务的队列executor。setQueueCapacity（500）；允许线程的空闲时间60秒：当超过了核心线程之外的线程在空闲时间到达之后会被销毁executor。setKeepAliveSeconds（60）；线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池executor。setThreadNamePrefix（dosomething）；缓冲队列满了之后的拒绝策略：由调用线程处理（一般是主线程）executor。setRejectedExecutionHandler（newThreadPoolExecutor。DiscardPolicy（））；executor。initialize（）；returnexecutor；｝｝复制代码
　　使用的方式非常简单，在需要异步的方法上加Async注解RestControllerpublicclassAsyncController｛AutowiredprivateAsyncServiceasyncService；GetMapping（opensomething）publicStringsomething（）｛intcount10；for（inti0；icount；i）｛asyncService。doSomething（indexi）；｝returnsuccess；｝｝Slf4jServicepublicclassAsyncService｛指定使用beanname为doSomethingExecutor的线程池Async（doSomethingExecutor）publicStringdoSomething（Stringmessage）｛log。info（dosomething，message｛｝，message）；try｛Thread。sleep（1000）；｝catch（InterruptedExceptione）｛log。error（dosomethingerror：，e）；｝returnmessage；｝｝复制代码
　　访问：127。0。0。1：8080opensomething，日志如下2020041923：42：42。486INFO21168〔io8200exec17〕x。g。b。system。controller。AsyncController：dosomethingend，time8milliseconds2020041923：42：42。488INFO21168〔dosomething1〕x。gits。boot。system。service。AsyncService：dosomething，messageindex02020041923：42：42。488INFO21168〔dosomething5〕x。gits。boot。system。service。AsyncService：dosomething，messageindex42020041923：42：42。488INFO21168〔dosomething4〕x。gits。boot。system。service。AsyncService：dosomething，messageindex32020041923：42：42。488INFO21168〔dosomething6〕x。gits。boot。system。service。AsyncService：dosomething，messageindex52020041923：42：42。488INFO21168〔dosomething9〕x。gits。boot。system。service。AsyncService：dosomething，messageindex82020041923：42：42。488INFO21168〔dosomething8〕x。gits。boot。system。service。AsyncService：dosomething，messageindex72020041923：42：42。488INFO21168〔dosomething10〕x。gits。boot。system。service。AsyncService：dosomething，messageindex92020041923：42：42。488INFO21168〔dosomething7〕x。gits。boot。system。service。AsyncService：dosomething，messageindex62020041923：42：42。488INFO21168〔dosomething2〕x。gits。boot。system。service。AsyncService：dosomething，messageindex12020041923：42：42。488INFO21168〔dosomething3〕x。gits。boot。system。service。AsyncService：dosomething，messageindex2复制代码
　　由此可见已经达到异步执行的效果了，并且使用到了咱们配置的线程池。获取异步方法返回值
　　当异步方法有返回值时，如何获取异步方法执行的返回结果呢？这时需要异步调用的方法带有返回值CompletableFuture。
　　CompletableFuture是对Feature的增强，Feature只能处理简单的异步任务，而CompletableFuture可以将多个异步任务进行复杂的组合。如下：RestControllerpublicclassAsyncController｛AutowiredprivateAsyncServiceasyncService；SneakyThrowsApiOperation（异步有返回值）GetMapping（opensomethings）publicStringsomethings（）｛CompletableFutureStringcreateOrderasyncService。doSomething1（createorder）；CompletableFutureStringreduceAccountasyncService。doSomething2（reduceaccount）；CompletableFutureStringsaveLogasyncService。doSomething3（savelog）；等待所有任务都执行完CompletableFuture。allOf（createOrder，reduceAccount，saveLog）。join（）；获取每个任务的返回结果StringresultcreateOrder。get（）reduceAccount。get（）saveLog。get（）；returnresult；｝｝Slf4jServicepublicclassAsyncService｛Async（doSomethingExecutor）publicCompletableFutureStringdoSomething1（Stringmessage）throwsInterruptedException｛log。info（dosomething1：｛｝，message）；Thread。sleep（1000）；returnCompletableFuture。completedFuture（dosomething1：message）；｝Async（doSomethingExecutor）publicCompletableFutureStringdoSomething2（Stringmessage）throwsInterruptedException｛log。info（dosomething2：｛｝，message）；Thread。sleep（1000）；returnCompletableFuture。completedFuture（；dosomething2：message）；｝Async（doSomethingExecutor）publicCompletableFutureStringdoSomething3（Stringmessage）throwsInterruptedException｛log。info（dosomething3：｛｝，message）；Thread。sleep（1000）；returnCompletableFuture。completedFuture（；dosomething3：message）；｝｝复制代码
　　访问接口C：UsersAdministratorcurlXGEThttp：localhost：8200opensomethingsHaccept：dosomething1：createorder；dosomething2：reduceaccount；dosomething3：savelog复制代码
　　控制台上关键日志如下：2020042000：27：42。238INFO5672〔dosomething3〕x。gits。boot。system。service。AsyncService：dosomething3：savelog2020042000：27：42。238INFO5672〔dosomething2〕x。gits。boot。system。service。AsyncService：dosomething2：reduceaccount2020042000：27：42。238INFO5672〔dosomething1〕x。gits。boot。system。service。AsyncService：dosomething1：createorder复制代码注意事项
　　Async注解会在以下几个场景失效，也就是说明明使用了Async注解，但就没有走多线程。异步方法使用static关键词修饰；异步类不是一个Spring容器的bean（一般使用注解Component和Service，并且能被Spring扫描到）；SpringBoot应用中没有添加EnableAsync注解；在同一个类中，一个方法调用另外一个有Async注解的方法，注解不会生效。原因是Async注解的方法，是在代理类中执行的。
　　需要注意的是：异步方法使用注解Async的返回值只能为void或者Future及其子类，当返回结果为其他类型时，方法还是会异步执行，但是返回值都是null，部分源码如下：
　　AsyncExecutionInterceptorinvoke
　　通过上边几个示例，Async实际还是通过Future或CompletableFuture来异步执行的，Spring又封装了一下，让我们使用的更方便。