如何在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来实现异步通信。具体实现方式可以根据具体的需求和场景来选择。