Java异步调用方法

在本文中，极悦小白将告诉大家如何在 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. 我们可以使用 的 submit 方法ExecutorService来异步运行项目并返回一个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，在 Java 8CompletionStage中CompletableFuture引入。它具有异步编程技术，例如supplyAsync、runAsync和thenApplyAsync。

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

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

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

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

CompletableFuture.supplyAsync(this::sendMsg);

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

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

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

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

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

用于EA Async在 Java 中异步调用方法

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

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

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

在这里，我们将使用 EAAsync类提供的 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)提供的类似，尽管它们更侧重于面向对象的设计概念。

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

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 库中的静态方法相同的功能。