java怎么实现异步调用

60次阅读

共计 1238 个字符，预计需要花费 4 分钟才能阅读完成。

在 Java 中，可以使用多种方法实现异步调用，下面列举了其中的两种常用方式：

使用线程池：可以使用 Java 中的 ExecutorService 来创建线程池，然后使用 submit 方法提交一个任务给线程池执行，并使用 Future 对象获取异步调用的结果。以下是示例代码：

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

public class Main {public static void main(String[] args) {// 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(1);

        // 提交任务并获取 Future 对象
        Future<String> future = executorService.submit(() -> {// 异步调用的逻辑代码
            Thread.sleep(1000);
            return " 异步调用结果 ";
        });

        // 获取异步调用的结果
        try {String result = future.get();
            System.out.println(" 异步调用结果：" + result);
        } catch (Exception e) {e.printStackTrace();
        }

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

使用 CompletableFuture：CompletableFuture是 Java 8 中新增的一个类，可以方便地实现异步调用。以下是示例代码：

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

public class Main {public static void main(String[] args) {// 创建 CompletableFuture 对象
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 异步调用的逻辑代码
            try {Thread.sleep(1000);
            } catch (InterruptedException e) {e.printStackTrace();
            }
            return " 异步调用结果 ";
        });

        // 获取异步调用的结果
        try {String result = future.get();
            System.out.println(" 异步调用结果：" + result);
        } catch (InterruptedException | ExecutionException e) {e.printStackTrace();
        }
    }
}