迹忆客 专注技术分享

在本文中，我们将学习如何在 Java 中异步调用函数。

首先，我们将了解一些 Java 内置的异步编程工具，例如 FutureTask 和 CompletableFuture。然后我们将了解一些提供开箱即用解决方案的库，例如 EA Async 和 Cactoos。

使用 Thread 异步调用 Java 中的方法

我们可以开始一个新线程来执行任何异步操作。它更容易理解。

让我们创建一个添加两个整数并打印结果的新线程：

class example {
  public static void main(String[] args) {
    int num1 = 4;
    int num2 = 5;
    int result = num1 + num2;
    Thread T = new Thread(
        () -> { System.out.println("Addition of " + num1 + " and " + num2 + " is " + result); });
    T.start();
  }
}

在 Java 中使用 FutureTask 异步调用方法

Future 接口允许你使用 FutureTask 执行异步操作。我们可以使用 ExecutorService 的 submit 方法来异步运行项目并返回一个 FutureTask 对象。

例如，这里是如何找到一个数字的阶乘：

int num1 = 9;

ExecutorService tp = Executors.newCachedThreadPool();
Future<double> futureTask = tp.submit(() -> factorial(num1));

while (!futureTask.isDone()) {
  System.out.println("Still processing the task");
}
double result = futureTask.get();
tp.shutdown();

我们使用了 Future 界面的 isDone 功能来查看工作是否已经完成。之后，我们使用 get 方法获取结果。

在 Java 中使用 CompletableFuture 异步调用方法

作为 Future 和 CompletionStage 的混合体，CompletableFuture 是在 Java 8 中引入的。它具有异步编程技术，例如 supplyAsync、runAsync 和 thenApplyAsync。

CompletionStage 是一个承诺。它保证计算将在某个时候完成。

CompletionStage 很有用，因为它提供了几种方法来附加要在阶段完成时执行的回调。

让我们从头开始，做一个简单的异步计算。

在 Java 中使用 supplyAsync 和 CompletableFuture 异步调用方法

CompletableFuture.supplyAsync(this::sendMsg);

就这么简单，supplyAsync 函数接受包含异步代码的供应商。我们希望在本例中使用 sendMsg 函数。

在 Java 中使用 thenAccept 和 CompletableFuture 异步调用方法

CompletableFuture.supplyAsync(this::sendMsg).thenAccept(this::notify);

在第一个示例中，我们执行 sendMsg 以异步发送消息。所以让我们添加一个回调来提醒我们消息的传递状态。

可以通过多种方式引入回调；一种方法是使用 thenAccept。在此示例中，它需要通知用户一旦完成就处理先前计算的结果。

使用 EA Async 异步调用 Java 中的方法

这是 Java 的另一个特性，它允许你逐步编写异步代码，从而使编程和扩展变得更加容易。Electronic Arts 是 async-await 功能的创建者，该功能可通过 ea-async 包在 Java 环境中使用。

此功能转换运行时代码并重写 await 方法调用，与 completeableFuture 相当。

所以我们可以使用被称为 await 方法的 EA-sync 方法来实现上述 completeableFuture 代码，方法是调用 Async.init 函数来初始化 Async 运行时。

在这里，我们将使用 EA 的 Async 类提供的 await 函数来修改前面描述的 CompletableFuture 代码：

static {
  Async.init();
}

为了设置 Async 运行时分析，我们使用 Async.init 函数作为静态函数。

public double example2(int num1) {
  CompletableFuture<double> cf = CompletableFuture.supplyAsync(() -> factorial(num1));
  double result = Async.await(cf);
}

在运行时，async 函数会更改代码并重写 await 方法调用以类似地操作，利用 CompletableFuture 链。

使用 Cactoos 库异步调用 Java 中的方法

对于异步任务，这个库提供了一个 Async 类。Cactoos 库具有广泛的曲目，从文本操作到数据结构。

该库的原始类型和功能与其他库（如 Guava 和 Apache Commons）提供的类似，尽管它们更侧重于面向对象的设计概念。

在这里，使用 Cactoos 的 Async 类的一个实例，我们将找到一个数字的阶乘。

Async<Integer, Double> a = new Async<Integer, Double>(inputdata -> factorial(inputdata));
Future<Double> asyncFuture = a.apply(num1);
Double result = asyncFuture.get();

apply 函数使用 ExecutorService.submit 方法执行并返回一个 Future 接口对象。Cactoos 库提供的类执行与 Apache Commons 库中的静态方法相同的功能。