java异步调用 怎样实现非阻塞

在Java中，实现非阻塞的异步调用通常使用以下几种方法：

1. 使用CompletableFuture：

CompletableFuture是Java 8引入的一个强大的异步编程工具。它允许你以非阻塞的方式执行异步任务，并提供了丰富的方法来处理异步计算的结果。以下是一个简单的示例：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class AsyncNonBlockingExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            // 模拟耗时操作
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "异步任务结果";
        });

        // 在异步任务完成之前，可以执行其他操作
        System.out.println("异步任务开始");

        // 获取异步任务的结果，非阻塞方式
        String result = future.get();
        System.out.println("异步任务结果: " + result);

        System.out.println("异步任务结束");
    }
}

2. 使用ExecutorService：

ExecutorService是Java提供的用于管理和调度线程的接口。你可以使用Executors工具类创建一个固定大小的线程池，然后将异步任务提交给线程池执行。以下是一个简单的示例：

import java.util.concurrent.*;

public class AsyncNonBlockingExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(1);

        // 提交异步任务
        Future<String> future = executorService.submit(() -> {
            // 模拟耗时操作
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "异步任务结果";
        });

        // 在异步任务完成之前，可以执行其他操作
        System.out.println("异步任务开始");

        // 获取异步任务的结果，非阻塞方式
        try {
            String result = future.get();
            System.out.println("异步任务结果: " + result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        // 关闭线程池
        executorService.shutdown();

        System.out.println("异步任务结束");
    }
}

在这两个示例中，我们使用了非阻塞的方式来执行异步任务。当调用future.get()时，如果异步任务还没有完成，它会立即返回一个Future对象，而不会阻塞当前线程。这样，你可以在等待异步任务完成的同时执行其他操作。