如何在Java API中實現異步通信

在Java API中實現異步通信可以使用Java的Future和CompletableFuture類來處理。下面是一個簡單的示例：

import java.util.concurrent.CompletableFuture;

public class AsyncCommunicationExample {

    public static void main(String[] args) {
        // 創建一個CompletableFuture對象，并指定一個異步任務
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            try {
                Thread.sleep(2000);  // 模擬耗時操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Hello, async communication!";
        });

        // 當異步任務完成后，執行回調函數
        future.thenAccept(result -> {
            System.out.println("Received message: " + result);
        });

        // 主線程可以繼續執行其他操作
        System.out.println("Main thread is still running...");

        // 阻塞主線程，等待異步任務完成
        future.join();
    }
}

在這個示例中，我們使用了CompletableFuture.supplyAsync方法創建了一個異步任務，并通過thenAccept方法設置了一個回調函數，當異步任務完成后會執行這個回調函數。主線程可以繼續執行其他操作，不必等待異步任務完成。最后通過future.join()方法阻塞主線程，等待異步任務完成。

除了CompletableFuture，還可以使用ExecutorService來實現異步通信。具體實現方式可以根據具體的需求和場景來選擇。