最近項目的一個業(yè)務(wù)場景需要使用異步 , 碼代碼到斷斷續(xù)續(xù)完善代碼 . 查詢了挺多的資料文檔, 現(xiàn)在記錄一下.
一 : 業(yè)務(wù)場景?
? ? ? ? 類似QQ 中的設(shè)置頁面 艾恼， 左側(cè)每個選項對應(yīng)右側(cè)的具體設(shè)置 桃序， 項目中暫且簡化為需要插入7條數(shù)據(jù)到不同數(shù)據(jù)表, 第一條數(shù)據(jù)和最后一條數(shù)據(jù)是為了提醒用戶開始和結(jié)束 裆站。 其中主方法是插入1 ,立刻給用戶返回數(shù)據(jù)(2-6的數(shù)據(jù)插入費時間,如果都等到插入成功再去返回給用戶體驗不好), 這時候我們需要開線程去分別執(zhí)行2-6的插入工作,同時,7的插入必須是在2-6插入之后才可以運行.(2-6是隨機的,可能全插入,可能全部不插) 蜡饵。 做的結(jié)果是 ： 第一條數(shù)據(jù)插入數(shù)據(jù)表弹渔，然后就直接返回用戶，執(zhí)行成功溯祸，中間2-6的執(zhí)行過程異步執(zhí)行肢专，然后第7條數(shù)據(jù)在異步結(jié)束之后插入
二 ： 參數(shù)?
? ? ? ? 創(chuàng)建一個是一個實體類來存儲2-6的所有字段，添加一個標識字段來區(qū)分焦辅。存入List中 博杖， LIst<T>?
三 ： 使用技術(shù)點
????????① ： spring boot 集成的異步，使用@Async來開啟異步筷登，模塊啟動類添加@EnableAsync 注解
? ? ? ? ? ? ? ? ? 實質(zhì)上是開啟線程執(zhí)行異步的類剃根，互不干擾執(zhí)行。
? ? ? ? ② ：?CountDownLatch的使用
? ? ? ? ? ? ? ? ?上面說到前方，我需要異步執(zhí)行2-6狈醉，返回結(jié)果之后才可以去執(zhí)行7廉油。 所以此時，我們使用到了CountDownLatch工具類來完成線程之間的堵塞苗傅。CountDownLatch是一種java.util.concurrent包下一個同步工具類抒线，它允許一個或多個線程等待直到在其他線程中一組操作執(zhí)行完成。
? ? ? ? ? ? ? ? ?1金吗、CountDownLatch latch =new CountDownLatch(count); //構(gòu)造對象時候 需要傳入?yún)?shù)count
? ? ? ? ? 2十兢、latch?.await() ?能夠阻塞線程 直到調(diào)用count次latch?.countDown() 方法才釋放線程
? ? ? ? ? 3、end.countDown() 可以在多個線程中調(diào)用 ?計算調(diào)用次數(shù)是所有線程調(diào)用次數(shù)的總和
? ? ? ? ? ? ? ? ? 具體代碼如下 ：
? ? ? ? ③ ：異步超時處理?
? ? ? ? ? ? ? ? 因為異步是在后臺執(zhí)行摇庙，該項目的異步執(zhí)行還需要調(diào)用其他模塊的接口（參考 ：spring cloud eureka的使用）旱物，導(dǎo)致執(zhí)行速度慢，考慮到異步可能會無限執(zhí)行下去卫袒，消耗資源宵呛，我們添加異步超時的處理。
? ? ? ? ? ? ? ? 這里使用了Future<T> 接口夕凝。????
? ??????????????boolean cancel(boolean mayInterruptIfRunning); 取消正在執(zhí)行的異步宝穗，取消成功返回true，取消失敗返回false码秉。參數(shù)填true既取消異步逮矛，填false既不取消異步。
? ??????????????boolean isCancelled();?任務(wù)是否被取消成功转砖，如果在任務(wù)正常完成前被取消成功须鼎，則返回 true。
? ??????????????boolean isDone(); 表示任務(wù)是否已經(jīng)完成府蔗，完成返回true 晋控，反之false。
? ??????????????V get()throws InterruptedException, ExecutionException; 獲取異步線程的執(zhí)行結(jié)果姓赤，這個方法是存在堵塞效果的赡译，任務(wù)執(zhí)行完成之后就會返回執(zhí)行結(jié)果，true或false返回的數(shù)據(jù)類型預(yù)Future<T> 的T一致
? ??????????????Vget(long timeout, TimeUnit unit)throws InterruptedException, ExecutionException, TimeoutException;? 設(shè)置超時時間不铆，設(shè)置時間內(nèi)異步完成則則成功蝌焚，超時則返回失敗，返回的數(shù)據(jù)類型預(yù)Future<T> 的T一致
? ? ? ? ? ? ? ? 參考上圖誓斥，我們使用到了取消和設(shè)置超時時間的方法????
? ? ? ? ? ? ? ? 注意 ： 在寫代碼的過程中综看，我們一開始是直接在controller上面開啟異步，2-6直接在異步類中開啟超時岖食，這時候不生效红碑。查看原因是我們在異步類中的總方法調(diào)用另外五個異步，他們實際上還是一個線程。此時我們在service中調(diào)用析珊，主方法的異步在service層羡鸥，剩下五個小的異步在異步類，此時是6個線程忠寻，調(diào)用成功惧浴。
? ? ? ? ④ ： 異步的事務(wù)
? ??????????????在Async 方法上標注@Transactional是沒用的。?
????????????????在Async 方法調(diào)用的Service上標注@Transactional 有效奕剃。
