Java函式的並發和多執行緒中如何使用Future和CompletableFuture？

Future 和 CompletableFuture 是 Java 中用於並發和多執行緒的工具。 Future 表示非同步計算結果，提供 get() 方法阻塞執行緒取得結果。 CompletableFuture 擴展了 Future，提供更豐富的功能，如組合計算、處理異常和使用回呼函數。

Java 函數的並發與多執行緒：使用Future 和CompletableFuture

概述

##Future 和CompletableFuture 是Java 8 中引入的並發工具，用於處理非同步操作和並發任務。它們允許您在不阻塞主執行緒的情況下執行長時間運行的操作，從而提高應用程式的效能和回應能力。 FutureFuture 是表示非同步計算結果的物件。它提供了一個方法 get()，用於阻塞當前線程直到結果可用。您也可以使用

isDone()

方法來檢查計算是否完成。

CompletableFuture

CompletableFuture 是 Future 的擴展，提供了更豐富的功能。它允許您組合非同步計算，處理異常，並使用回調函數。

實戰案例考慮以下範例，使用Future 來非同步載入檔案：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class FileLoader {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        Future<String> future = executorService.submit(() -> {
            // 异步加载文件
            return loadFile("file.txt");
        });

        // 继续执行其他任务，而不阻塞当前线程
        // ...

        // 当需要结果时，再阻塞主线程获取结果
        String result = future.get();
    }

    private static String loadFile(String filePath) {
        // 模拟文件加载操作
        return "File contents";
    }
}

在這個範例中，我們使用

ExecutorService### 建立了一個執行緒池，然後使用###submit()### 提交了一個非同步任務，該任務負責載入檔案。主執行緒繼續執行其他任務，而不阻塞等待檔案載入完成。最後，當需要檔案內容時，我們再呼叫 ###get()### 從 ###Future### 中取得結果。 #########使用CompletableFuture#########以下範例展示如何使用###CompletableFuture### 來組合非同步運算：###

import java.util.concurrent.CompletableFuture;

public class CompletableFutureExample {

    public static void main(String[] args) {
        // 定义第一个异步计算
        CompletableFuture<Integer> firstResult = CompletableFuture.supplyAsync(() -> {
            // 计算第一个结果
            return 5;
        });

        // 定义第二个异步计算
        CompletableFuture<Integer> secondResult = CompletableFuture.supplyAsync(() -> {
            // 计算第二个结果
            return 10;
        });

        // 组合两个计算，将它们的结果相加
        CompletableFuture<Integer> combinedResult = firstResult.thenCombine(secondResult, (x, y) -> x + y);

        // 获取最终结果
        int result = combinedResult.get();
    }
}

###在這個範例中，我們使用###CompletableFuture#supplyAsync()### 建立了兩個非同步計算。然後，我們使用 ###CompletableFuture#thenCombine()### 將它們組合起來，將它們的結果加起來。最後，我們使用 ###CompletableFuture#get()### 來取得最終結果。 ######總之，Future 和 CompletableFuture 是處理非同步操作和並發任務的強大工具。使用這些工具可以提高應用程式的效能和回應能力，從而創建更有效和可擴展的程式碼。 ###

以上是Java函式的並發和多執行緒中如何使用Future和CompletableFuture？的詳細內容。更多資訊請關注PHP中文網其他相關文章！