Spring:@Async注解和AsyncResult與CompletableFuture使用問題

更新時間：2024年08月21日 15:53:39 作者：?abc!

這篇文章主要介紹了Spring:@Async注解和AsyncResult與CompletableFuture使用問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

@Async概述

Spring中用@Async注解標記的方法，稱為異步方法，它會在調(diào)用方的當前線程之外的獨立的線程中執(zhí)行，

其實就相當于我們自己

new Thread(()-> System.out.println("hello world !"))

這樣在另一個線程中去執(zhí)行相應的業(yè)務邏輯

異步方法實際的執(zhí)行交給了 Spring 的 TaskExecutor 來完成。

@Async使用

@Async注解如果用在類的方法上，則說明改方法是異步方法
@Async注解如果用在類上，那么這個類所有的方法都是異步執(zhí)行的
@Async注解方法的類對象應該是Spring容器管理的bean對象
調(diào)用異步方法類上需要配置上注解@EnableAsync，或者是在啟動類上加上@EnableAsync

@Async注意

默認情況下（@EnableAsync注解的mode=AdviceMode.PROXY），同一個類內(nèi)部沒有使用@Async注解修飾的方法調(diào)用@Async注解修飾的方法，是不會異步執(zhí)行的
如果想實現(xiàn)類內(nèi)部自調(diào)用也可以異步，則需要切換@EnableAsync注解的mode=AdviceMode.ASPECTJ
任意參數(shù)類型都是支持的，但是方法返回值必須是void或者Future類型

@Async代碼示例

使用1代碼實現(xiàn)：調(diào)用異步方法類上配置@EnableAsync

import org.springframework.scheduling.annotation.Async;
 
public interface TestService {
    @Async
    void test();
}

import com.example.service.TestService;
import org.springframework.stereotype.Service;
 
@Service
public class TestServiceImpl implements TestService {
    @Override
    public void test() {
        //...
    }
}

調(diào)用異步方法的controller類

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.web.bind.annotation.*;
 
 
@RestController
@RequestMapping(value = "/test")
@EnableAsync
public class TestContoller {
 
    @Autowired
    private TestService testService;
 
    @GetMapping(value = "/testAsync")
    public void print() {
       testService.test();
    }
}

如果我們?nèi)コ齌estController上的@EnableAsync或者new 一個TestService對象（該對象沒有加載進Spring的容器中），那么TestController中的print()方法都會同步執(zhí)行，后臺打印日志也可以看到只有一個線程在執(zhí)行

使用2代碼實現(xiàn)：在啟動類上配置@EnableAsync

如果啟動類上配置@EnableAsync，那么在上例代碼中，便不需要再在Controller上面加上@EnableAsync這個注解

入口類增加了 @EnableAsync 注解，主要是為了掃描范圍包下的所有 @Async 注解。

注意1代碼實現(xiàn)：@Async沒有生效

@Async 修飾test()方法，test2()方法不修飾

public interface TestService {
    @Async
    void test();
 
    void test2();
}

public class TestServiceImpl implements TestService{
    @Override
    public void test() {
        //...
    }
 
    @Override
    public void test2() {
        test();//自調(diào)用test()方法
    }
}

這種情況下“：test2()方法調(diào)用的test()方法并沒有異步執(zhí)行，只有一個線程

AsyncResult

Spring中提供了一個 Future 接口的子類：AsyncResult，所以我們可以返回 AsyncResult 類型的值。

AsyncResult是異步方式，異步主要用于調(diào)用的代碼需要長時間運行，才能返回結果的時候，可以不阻塞調(diào)用者

public class AsyncResult<V> implements ListenableFuture<V> {
    private final V value;
    private final ExecutionException executionException;
    //...
}

AsyncResult實現(xiàn)了ListenableFuture接口，該對象內(nèi)部有兩個屬性：返回值和異常信息。

public interface ListenableFuture<T> extends Future<T> {
    void addCallback(ListenableFutureCallback<? super T> var1);
    void addCallback(SuccessCallback<? super T> var1, FailureCallback var2);
}

AsyncResult代碼示例

獲取異步方法返回值的實現(xiàn)：返回String

public Future<String> test() throws Exception {
        log.info("開始做任務");
        long start = System.currentTimeMillis();
        Thread.sleep(1000);
        long end = System.currentTimeMillis();
        log.info("完成任務，耗時：" + (end - start) + "毫秒");
        return new AsyncResult<>("任務完成，耗時" + (end - start) + "毫秒");
}

返回自定義類型的話，在上面的Future里面的String改為對應的實體類

CompletableFuture

統(tǒng)計一下三個任務并發(fā)執(zhí)行共耗時多少，這就需要等到上述三個函數(shù)都完成調(diào)動之后記錄時間，并計算結果。

也可以使用CompletableFuture來返回異步調(diào)用的結果

通過CompletableFuture.allOf(task1, task2, task3).join()實現(xiàn)三個異步任務都結束之前的阻塞效果
三個任務都完成之后，根據(jù)結束時間 - 開始時間，計算出三個任務并發(fā)執(zhí)行的總耗時。

CompletableFuture代碼示例

@Async
public CompletableFuture<String> doTaskOne() throws Exception {
    log.info("開始做任務一");
    long start = System.currentTimeMillis();
    Thread.sleep(random.nextInt(10000));
    long end = System.currentTimeMillis();
    log.info("完成任務一，耗時：" + (end - start) + "毫秒");
    return CompletableFuture.completedFuture("任務一完成");
}

@Test
public void test() throws Exception {
    long start = System.currentTimeMillis();
    CompletableFuture<String> task1 = asyncTasks.test();
    CompletableFuture<String> task2 = asyncTasks.test();
    CompletableFuture<String> task3 = asyncTasks.test();
    CompletableFuture.allOf(task1, task2, task3).join();
    long end = System.currentTimeMillis();
    log.info("任務全部完成，總耗時：" + (end - start) + "毫秒");
}