在 Java 中异步调用方法

Muhammad Zeeshan 2023年1月30日 2022年4月22日
  1. 使用 Thread 异步调用 Java 中的方法
  2. 在 Java 中使用 FutureTask 异步调用方法
  3. 在 Java 中使用 CompletableFuture 异步调用方法
  4. 使用 EA Async 异步调用 Java 中的方法
  5. 使用 Cactoos 库异步调用 Java 中的方法
在 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 执行异步操作。我们可以使用 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 异步调用方法

作为 FutureCompletionStage 的混合体,CompletableFuture 是在 Java 8 中引入的。它具有异步编程技术,例如 supplyAsyncrunAsyncthenApplyAsync

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

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

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

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

CompletableFuture.supplyAsync(this::sendMsg);

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

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

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

Muhammad Zeeshan avatar Muhammad Zeeshan avatar

I have been working as a Flutter app developer for a year now. Firebase and SQLite have been crucial in the development of my android apps. I have experience with C#, Windows Form Based C#, C, Java, PHP on WampServer, and HTML/CSS on MYSQL, and I have authored articles on their theory and issue solving. I'm a senior in an undergraduate program for a bachelor's degree in Information Technology.

LinkedIn

相关文章 - Java Method