在 Java 中异步调用方法
-
使用
Thread
异步调用 Java 中的方法 -
在 Java 中使用
FutureTask
异步调用方法 -
在 Java 中使用
CompletableFuture
异步调用方法 -
使用
EA Async
异步调用 Java 中的方法 - 使用 Cactoos 库异步调用 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
异步调用方法
作为 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 库中的静态方法相同的功能。
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