Spring Boot利用@Async異步調(diào)用:使用Future及定義超時詳解
前言
之前連續(xù)寫了幾篇關(guān)于使用@Async實現(xiàn)異步調(diào)用的內(nèi)容,也得到不少童鞋的反饋,其中問題比較多的就是關(guān)于返回Future的使用方法以及對異步執(zhí)行的超時控制,所以這篇就來一起講講這兩個問題的處理。
如果您對于@Async注解的使用還不了解的話,可以看看之前的文章,具體如下:
- 使用@Async實現(xiàn)異步調(diào)用
- 使用@Async實現(xiàn)異步調(diào)用:自定義線程池
- 使用@Async實現(xiàn)異步調(diào)用:資源優(yōu)雅關(guān)閉
定義異步任務(wù)
首先,我們先使用@Async注解來定義一個異步任務(wù),這個方法返回Future類型,具體如下:
@Slf4j @Component public class Task { public static Random random = new Random(); @Async("taskExecutor") public Future<String> run() throws Exception { long sleep = random.nextInt(10000); log.info("開始任務(wù),需耗時:" + sleep + "毫秒"); Thread.sleep(sleep); log.info("完成任務(wù)"); return new AsyncResult<>("test"); } }
Tips:什么是Future類型?
Future是對于具體的Runnable或者Callable任務(wù)的執(zhí)行結(jié)果進行取消、查詢是否完成、獲取結(jié)果的接口。必要時可以通過get方法獲取執(zhí)行結(jié)果,該方法會阻塞直到任務(wù)返回結(jié)果。
它的接口定義如下:
public interface Future<V> { boolean cancel(boolean mayInterruptIfRunning); boolean isCancelled(); boolean isDone(); V get() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; }
它聲明這樣的五個方法:
- cancel方法用來取消任務(wù),如果取消任務(wù)成功則返回true,如果取消任務(wù)失敗則返回false。參數(shù)mayInterruptIfRunning表示是否允許取消正在執(zhí)行卻沒有執(zhí)行完畢的任務(wù),如果設(shè)置true,則表示可以取消正在執(zhí)行過程中的任務(wù)。如果任務(wù)已經(jīng)完成,則無論mayInterruptIfRunning為true還是false,此方法肯定返回false,即如果取消已經(jīng)完成的任務(wù)會返回false;如果任務(wù)正在執(zhí)行,若mayInterruptIfRunning設(shè)置為true,則返回true,若mayInterruptIfRunning設(shè)置為false,則返回false;如果任務(wù)還沒有執(zhí)行,則無論mayInterruptIfRunning為true還是false,肯定返回true。
- isCancelled方法表示任務(wù)是否被取消成功,如果在任務(wù)正常完成前被取消成功,則返回 true。
- isDone方法表示任務(wù)是否已經(jīng)完成,若任務(wù)完成,則返回true;
- get()方法用來獲取執(zhí)行結(jié)果,這個方法會產(chǎn)生阻塞,會一直等到任務(wù)執(zhí)行完畢才返回;
- get(long timeout, TimeUnit unit)用來獲取執(zhí)行結(jié)果,如果在指定時間內(nèi),還沒獲取到結(jié)果,就直接返回null。
也就是說Future提供了三種功能:
- 判斷任務(wù)是否完成;
- 能夠中斷任務(wù);
- 能夠獲取任務(wù)執(zhí)行結(jié)果。
測試執(zhí)行與定義超時
在完成了返回Future的異步任務(wù)定義之后,我們來嘗試實現(xiàn)一個單元測試來使用這個Future完成任務(wù)的執(zhí)行,比如:
@Slf4j @RunWith(SpringJUnit4ClassRunner.class) @SpringBootTest public class ApplicationTests { @Autowired private Task task; @Test public void test() throws Exception { Future<String> futureResult = task.run(); String result = futureResult.get(5, TimeUnit.SECONDS); log.info(result); } }
上面的代碼中,我們在get方法中還定義了該線程執(zhí)行的超時時間,通過執(zhí)行這個測試我們可以觀察到執(zhí)行時間超過5秒的時候,這里會拋出超時異常,該執(zhí)行線程就能夠因執(zhí)行超時而釋放回線程池,不至于一直阻塞而占用資源。
完整示例:
讀者可以根據(jù)喜好選擇下面的兩個倉庫中查看Chapter4-1-4項目:
Github:https://github.com/dyc87112/SpringBoot-Learning/
Gitee:https://gitee.com/didispace/SpringBoot-Learning/
本地下載:http://xiazai.jb51.net/201805/yuanma/SpringBoot-Learning(jb51.net).rar
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,如果有疑問大家可以留言交流,謝謝大家對腳本之家的支持。
相關(guān)文章
JVM內(nèi)存模型/內(nèi)存空間:運行時數(shù)據(jù)區(qū)
這篇文章主要介紹了JVM內(nèi)存模型/內(nèi)存空間的相關(guān)資料,幫助大家更好的理解和學(xué)習(xí)Java虛擬機,感興趣的朋友可以了解詳細,希望能夠給你帶來幫助2021-08-08springboot基于IDEA環(huán)境熱加載與熱部署教程
這篇文章主要為大家介紹了springboot在IDEA環(huán)境下的熱加載與熱部署教程,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步2022-03-03java8 利用reduce實現(xiàn)將列表中的多個元素的屬性求和并返回操作
這篇文章主要介紹了java8 利用reduce實現(xiàn)將列表中的多個元素的屬性求和并返回操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-08-08Java?List集合取交集的8種不同實現(xiàn)方式總結(jié)
工作中經(jīng)常遇到需要取兩個集合之間的交集、差集情況,下面這篇文章主要給大家總結(jié)介紹了關(guān)于Java?List集合取交集的8種不同實現(xiàn)方式,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2024-04-04Java使用HttpClient實現(xiàn)Post請求實例
本篇文章主要介紹了Java使用HttpClient實現(xiàn)Post請求實例,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-02-02