SpringBoot異步調(diào)用方法并接收返回值
項目中肯定會遇到異步調(diào)用其他方法的場景,比如有個計算過程,需要計算很多個指標(biāo)的值,但是每個指標(biāo)計算的效率快慢不同,如果采用同步執(zhí)行的方式,運行這一個過程的時間是計算所有指標(biāo)的時間之和。比如:
方法A:計算指標(biāo)x,指標(biāo)y,指標(biāo)z的值,其中計算指標(biāo)x需要1s,計算指標(biāo)y需要2s,指標(biāo)z需要3s。最終執(zhí)行完方法A就是5s。
現(xiàn)在用異步的方式優(yōu)化一下
方法A異步調(diào)用方法B,方法C,方法D,方法B,方法C,方法D分別計算指標(biāo)x,指標(biāo)y,指標(biāo)z的值,那么最終執(zhí)行完方法A的時間則是3s。
步驟1:配置線程池,添加@Configuration和@EnableAsync注解
@Configuration @EnableAsync public class ExecutorConfig { /** * 線程池 * * @return */ @Bean(name = "asyncExecutor") public Executor asyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(10); executor.setMaxPoolSize(15); executor.setQueueCapacity(25); executor.setKeepAliveSeconds(200); executor.setThreadNamePrefix("async-"); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 等待所有任務(wù)都完成再繼續(xù)銷毀其他的Bean executor.setWaitForTasksToCompleteOnShutdown(true); // 線程池中任務(wù)的等待時間,如果超過這個時候還沒有銷毀就強制銷毀,以確保應(yīng)用最后能夠被關(guān)閉,而不是阻塞住 executor.setAwaitTerminationSeconds(60); executor.initialize(); return executor; } }
步驟2:定義方法A,方法B,方法C,方法D
@Service public class AsyncService { @Async("asyncExecutor") public Future<Integer> methodB(){ try{ Thread.sleep(1000); } catch (Exception e) { e.printStackTrace(); } return new AsyncResult<>(1); } @Async("asyncExecutor") public Future<Integer> methodC(){ try{ Thread.sleep(2000); } catch (Exception e) { e.printStackTrace(); } return new AsyncResult<>(2); } @Async("asyncExecutor") public Future<Integer> methodD(){ try{ Thread.sleep(3000); } catch (Exception e) { e.printStackTrace(); } return new AsyncResult<>(3); } } @GetMapping("test") public Integer methodA() throws Exception{ long start = System.currentTimeMillis(); Future<Integer> future1 = asyncService.methodB(); Future<Integer> future2 = asyncService.methodC(); Future<Integer> future3 = asyncService.methodD(); Integer x = future1.get(); Integer y = future2.get(); Integer z = future3.get(); long end = System.currentTimeMillis(); System.out.println("耗時:" + (end - start)); return x + y +z; } }
結(jié)果:
關(guān)于Futura類的詳解請移步:了解JAVA Future類
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
RocketMQ生產(chǎn)者一個應(yīng)用不能發(fā)送多個NameServer消息解決
這篇文章主要為大家介紹了RocketMQ生產(chǎn)者一個應(yīng)用不能發(fā)送多個NameServer消息原因及解決方法詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-11-11MyBatis-Plus中SimpleQuery查詢實現(xiàn)
本文主要介紹了MyBatis-Plus中SimpleQuery查詢實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08Intellij IDEA 2019 最新亂碼問題及解決必殺技(必看篇)
大家在使用Intellij IDEA 的時候會經(jīng)常遇到各種亂碼問題,今天小編給大家分享一些關(guān)于Intellij IDEA 2019 最新亂碼問題及解決必殺技,感興趣的朋友跟隨小編一起看看吧2020-04-04Spring?Data?Elasticsearch?5.0.x修改數(shù)據(jù)后無法立即刷新解決方法示例
這篇文章主要為大家介紹了Spring?Data?Elasticsearch?5.0.x修改數(shù)據(jù)后無法立即刷新解決方法示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-08-08springmvc無法訪問/WEB-INF/views下的jsp的解決方法
本篇文章主要介紹了springmvc無法訪問/WEB-INF/views下的jsp的解決方法,非常具有實用價值,需要的朋友可以參考下2017-10-10