Java异步编程：使用 CompletableFuture 和 async/await 方法

原创心已赠人 2024-11-13 04:54 33阅读 0赞

Java异步编程是一种编程范式，它允许程序在等待一个长时间运行的任务完成时继续执行其他任务。在 Java 中，`CompletableFuture` 是一个非常重要的类，它提供了一种简洁的方式来编写异步代码。从 Java9 开始，`CompletableFuture`还支持 `async` 和 `await` 方法，这些方法与 JavaScript 中的 `async/await`语法类似，使得异步代码的编写更加直观和易于理解。

### CompletableFuture`CompletableFuture` 是一个可以异步完成的 `Future`，它提供了更多的功能，比如可以附加回调函数、组合多个 `CompletableFuture` 实例等。

### async 方法`CompletableFuture` 的 `async` 方法用于异步执行一个任务。它接受一个 `Runnable` 或 `Callable` 对象，并返回一个 `CompletableFuture` 实例。`async` 方法默认使用 `ForkJoinPool`来执行任务，但你也可以提供一个自定义的 `Executor`。

```javaCompletableFuture<Void> future = CompletableFuture.async(() -> {
//执行异步任务});
```### await 方法`await` 方法用于等待一个 `CompletableFuture` 实例完成。它会阻塞当前线程直到 `CompletableFuture`完成。

```javaCompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
//异步计算结果 return "Hello, World!";
});

String result = future.join(); //也可以使用 join() 方法来等待结果```### async/await 示例下面是一个使用 `CompletableFuture` 和 `async/await` 方法的简单示例：

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

public class CompletableFutureExample {
 public static void main(String[] args) throws ExecutionException, InterruptedException {
 CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
//模拟一个耗时操作 try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
 }
 return "Hello, World!";
 });

//执行其他任务 System.out.println("Doing other tasks...");

//等待异步任务完成String result = future.get(); //这里使用 get() 方法等待结果，也可以使用 join() 方法 System.out.println(result);
 }
}
```在这个示例中，我们使用 `supplyAsync` 方法来异步执行一个返回字符串的任务。在等待结果的同时，我们打印了一条消息表示正在执行其他任务。最后，我们使用 `get` 方法来等待异步任务完成并获取结果。

请注意，`get` 方法会阻塞当前线程直到 `CompletableFuture`完成，这可能会导致性能问题。在实际应用中，你可能会使用回调函数或其他非阻塞的方式来处理异步结果。