如何使用 Java Executors 和 CompletableFuture 非阻塞地執行任務？

使用Java 執行器執行非阻塞任務

在處理多個任務佇列時，避免可能消耗過多資源的阻塞操作至關重要堆疊空間。本文探討如何利用 Java 的 java.util.concurrent 套件在不阻塞的情況下將任務提交給執行器，並利用任務完成通知的回呼。

回調方法

定義接受任務所需結果或完成狀態的回調介面。實作一個接受任務和回呼的包裝類別。當任務完成時，包裝器會呼叫回調。

CompletableFuture 和非同步執行

Java 8 引入了 CompletableFuture，它提供了更複雜的機制來組合非同步和條件管道。建立一個在執行緒池中執行任務的 CompletableFuture。然後，將一個偵聽器附加到將在任務完成時呼叫的 future。

範例

以下程式碼片段示範如何使用CompletableFuture 進行非阻塞任務執行:

import java.util.concurrent.CompletableFuture;

// Service class to perform the task
class ExampleService {
    public String work() {
        // Simulated work
        char[] str = new char[5];
        ThreadLocalRandom current = ThreadLocalRandom.current();
        for (int idx = 0; idx < str.length; ++idx)
            str[idx] = (char) ('A' + current.nextInt(26));
        String msg = new String(str);
        System.out.println("Generated message: " + msg);
        return msg;
    }
}

// Main class
public class Main {
    public static void main(String[] args) {
        ExampleService svc = new ExampleService();
        CompletableFuture<String> f = CompletableFuture.supplyAsync(svc::work);
        
        // Attach a listener to the future
        f.thenAccept(result -> System.out.println("Result: " + result));
        
        // Main method can continue execution without blocking
        System.out.println("Main method exiting");
    }
}

此程式碼建立一個非同步執行work( ) 方法的CompletableFuture。 thenAccept() 方法附加一個偵聽器，該偵聽器將在 CompletableFuture 完成時調用，從而允許非阻塞執行任務。

以上是如何使用 Java Executors 和 CompletableFuture 非阻塞地執行任務？的詳細內容。更多資訊請關注PHP中文網其他相關文章！