什么是異步編程

在實現(xiàn)異步調(diào)用之前，我們先了解一下，什么是異步編程？什么場景下適用等等情況。

我們都知道，在傳統(tǒng)的同步編程中，當(dāng)一個操作開始執(zhí)行時，程序會阻塞并等待該操作完成，然后才能繼續(xù)執(zhí)行后續(xù)代碼。這種阻塞等待的方式可能會導(dǎo)致程序響應(yīng)性能下降，因為在等待的過程中無法同時處理其他任務(wù)。這種顯而易見的，在某種耗時的場景下，就顯得無用了，甚至很影響體驗。

如文件讀寫、網(wǎng)絡(luò)請求或計算密集型任務(wù)，再如人臉融合特效等等，都是耗時的操作，這個時候，我們就需要異步編程了。

異步編程則不會阻塞程序的執(zhí)行，它將耗時的操作提交給后臺線程或其他執(zhí)行環(huán)境，并立即返回，使得程序可以繼續(xù)執(zhí)行其他任務(wù)。當(dāng)耗時操作完成后，會通過回調(diào)、事件或者輪詢等方式通知主線程，主線程再去處理操作結(jié)果或執(zhí)行相應(yīng)的回調(diào)函數(shù)。

CompletableFuture

今天我們就來了解下 CompletableFuture，它Java 8引入的一種功能強大的異步編程工具，可以用于實現(xiàn)復(fù)雜的異步操作和處理鏈?zhǔn)降漠惒饺蝿?wù)。

從這個JDK里，可以看出，它既實現(xiàn)了 Future 接口，擁有 Future 所有的特性，比如可以使用 get() 方法獲取返回值等。

也實現(xiàn)了CompletionStage接口，提供了豐富的方法來管理異步任務(wù)的執(zhí)行和處理任務(wù)結(jié)果。并且這些接口多達40多個，完全足夠我們?nèi)粘Ｋ褂昧恕?/p>

1. supplyAsync

 CompletableFuture<T> supplyAsync(Supplier<? extends T> supplier)

該方法接受一個Supplier函數(shù)式接口作為參數(shù)，用于執(zhí)行一個有返回值的異步任務(wù)。返回一個CompletableFuture對象，可以用于獲取異步任務(wù)的執(zhí)行結(jié)果。

參數(shù)：

Supplier：一個無參的函數(shù)式接口，用于提供異步任務(wù)的結(jié)果。

2. runAsync

CompletableFuture<Void> runAsync(Runnable runnable)

該方法接受一個Runnable函數(shù)式接口作為參數(shù)，用于執(zhí)行一個無返回值的異步任務(wù)。返回一個CompletableFuture對象，可以用于等待異步任務(wù)完成。

參數(shù)：Runnable：一個無參的函數(shù)式接口，用于執(zhí)行異步任務(wù)。

3. thenApply

CompletableFuture<T> thenApply(Function<? super T,? extends U> function)

該方法接受一個Function函數(shù)式接口作為參數(shù)，用于對CompletableFuture的結(jié)果進行處理，并返回新的CompletableFuture對象。

參數(shù)：Function：一個帶有一個參數(shù)的函數(shù)式接口，用于對異步任務(wù)的結(jié)果進行轉(zhuǎn)換或處理。

4. thenAccept

CompletableFuture<Void> thenAccept(Consumer<? super T> consumer)

該方法接受一個Consumer函數(shù)式接口作為參數(shù)，用于對CompletableFuture的結(jié)果進行消費，沒有返回值。

參數(shù)：

Consumer：一個帶有一個參數(shù)的函數(shù)式接口，用于消費異步任務(wù)的結(jié)果。

5. thenRun

CompletableFuture<Void> thenRun(Runnable action)

該方法接受一個Runnable函數(shù)式接口作為參數(shù)，用于在CompletableFuture的結(jié)果完成后執(zhí)行指定的操作，沒有返回值。

參數(shù)：BiFunction：一個帶有兩個參數(shù)的函數(shù)式接口，用于合并兩個CompletableFuture的結(jié)果。

6. thenCombine

CompletableFuture<U> thenCombine(CompletionStage<? extends V> other, BiFunction<? super T,? super U,? extends V> fn)

該方法接受一個CompletionStage對象和一個BiFunction函數(shù)式接口作為參數(shù)，用于等待當(dāng)前CompletableFuture和另一個CompletionStage對象都完成后，將其結(jié)果進行組合處理，并返回新的CompletableFuture對象。

參數(shù)：

CompletionStage：代表一個異步任務(wù)的執(zhí)行狀態(tài)。

返回值：

• CompletableFuture<T>：表示一個異步任務(wù)的結(jié)果，可以通過該對象獲取異步任務(wù)的執(zhí)行結(jié)果。
• CompletableFuture<Void>：表示一個異步任務(wù)的結(jié)果，沒有返回值。

java 演示

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class CompletableFutureExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 使用supplyAsync方法創(chuàng)建一個CompletableFuture對象來執(zhí)行有返回值的異步任務(wù)
        CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("異步任務(wù)正在執(zhí)行");
            return 100;
        });
        // 使用thenApply方法對異步任務(wù)的結(jié)果進行處理，并返回新的CompletableFuture對象
        CompletableFuture<String> processedFuture = future.thenApply(result -> {
            System.out.println("對異步任務(wù)結(jié)果進行處理");
            return "處理后的結(jié)果：" + result * 2;
        });
        // 使用get方法阻塞當(dāng)前線程，并獲取異步任務(wù)的執(zhí)行結(jié)果
        String result = processedFuture.get();
        System.out.println(result);
    }
}

異步任務(wù)正在執(zhí)行
對異步任務(wù)結(jié)果進行處理
處理后的結(jié)果：200

到此這篇關(guān)于java 如何快速實現(xiàn)異步調(diào)用方法的文章就介紹到這了,更多相關(guān)java異步調(diào)用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論