異步調用

同步調用,即:程序按定義的順序依次執行的過程,每一行代碼執行過程必須等待上一行代碼執行完畢后才執行。而異步調用指:程序在執行時,無需等待執行的返回值可繼續執行后面的代碼。回調。其主要是解決異步方法執行結果的處理方法,比如在希望異步調用結束時返回執行結果,這個時候就可以考慮使用回調機制。

　　需要在啟動類加入@EnableAsync使異步調用@Async注解生效

@Componentpublic class SyncService {        @Async    public void asyncEvent() throws InterruptedException {        //休眠1s        Thread.sleep(1000);        //log.info("異步方法輸出:{}!", System.currentTimeMillis());    }}

　　在默認情況下,未設置TaskExecutor時,默認是使用SimpleAsyncTaskExecutor這個線程池,但此線程不是真正意義上的線程池,因為線程不重用,每次調用都會創建一個新的線程?？赏ㄟ^控制臺日志輸出可以看出,每次輸出線程名都是遞增的。

調用的異步方法,不能為同一個類的方法,因為Spring在啟動掃描時會為其創建一個代理類,而同類調用時,還是調用本身的代理類的,所以和平常調用是一樣的。其他的注解如@Cache等也是一樣的道理,就是Spring的代理機制造成的。

　　創建一個自定義的ThreadPoolTaskExecutor線程池:

@Configurationpublic class Config {    /**     * 配置線程池     * @return     */    @Bean(name = "asyncPoolTaskExecutor")    public ThreadPoolTaskExecutor getAsyncThreadPoolTaskExecutor() {        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();        taskExecutor.setCorePoolSize(20);        taskExecutor.setMaxPoolSize(200);        taskExecutor.setQueueCapacity(25);        taskExecutor.setKeepAliveSeconds(200);        taskExecutor.setThreadNamePrefix("King-");        // 線程池對拒絕任務(無線程可用)的處理策略,目前只支持AbortPolicy、CallerRunsPolicy;默認為后者        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());        //調度器shutdown被調用時等待當前被調度的任務完成        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);        //等待時長        taskExecutor.setAwaitTerminationSeconds(60);        taskExecutor.initialize();        return taskExecutor;     } }

　　若需要在關閉線程池時等待當前調度任務完成后才開始關閉,可以通過簡單的配置,進行優雅的停機策略配置。關鍵就是通過setWaitForTasksToCompleteOnShutdown(true)和setAwaitTerminationSeconds方法。

• setWaitForTasksToCompleteOnShutdown:表明等待所有線程執行完,默認為false。
• setAwaitTerminationSeconds:等待的時間,因為不能無限的等待下去。

使用的是就只需要在@Async加入線程池名稱即可:

@Async("asyncPoolTaskExecutor")    public void asyncEvent() throws InterruptedException {        //休眠1s        Thread.sleep(1000);        log.info("異步方法內部線程名稱:{}!", Thread.currentThread().getName());    }

異步回調及超時處理

　　需要異步回調的返回值時,就需要使用異步回調來完成了。主要就是通過Future進行異步回調。

@Async("asyncPoolTaskExecutor")public Future<String> asyncEvent() throws InterruptedException {    //休眠1s    Thread.sleep(1000);    log.info("異步方法內部線程名稱:{}!", Thread.currentThread().getName());    return new AsyncResult<>("異步方法返回值");}

AsyncResult是Spring提供的一個Future接口的子類。然后通過isDone方法,判斷是否已經執行完畢。

超時處理

對于Future配置超時,很簡單,通過get方法即可,具體如下:

//get方法會一直堵塞,直到等待執行完成才返回//get(long timeout, TimeUnit unit) 在設置時間類未返回結果,會直接排除異常TimeoutException,messages為nullString result = doFutrue.get(60, TimeUnit.SECONDS);//60s

　　超時后,會拋出異常TimeoutException類,此時可進行統一異常捕獲即可

注意:

　　@Async所修飾的函數不要定義為static類型,這樣異步調用不會生效,

@Async調用中的事務處理機制

　　在@Async標注的方法,同時也適用了@Transactional進行了標注;在其調用數據庫操作之時,將無法產生事務管理的控制,原因就在于其是基于異步處理的操作。那該如何給這些操作添加事務管理呢?可以將需要事務管理操作的方法放置到異步方法內部,在內部被調用的方法上添加@Transactional. 　　例如: 方法A,使用了@Async/@Transactional來標注,但是無法產生事務控制的目的。方法B,使用了@Async來標注, B中調用了C、D,C/D分別使用@Transactional做了標注,則可實現事務控制的目的。 基于@Async調用中的異常處理機制　　在異步方法中,如果出現異常,對于調用者caller而言,是無法感知的。

154204.html