CompletableFuture方法介绍及代码示例

2. thenApply 和 thenAccept：

        - thenApply(Function fn)：当 CompletableFuture 计算完成后，应用一个函数到结果上，并返回一个新的 CompletableFuture。
   - thenAccept(Consumer action)：当 CompletableFuture 计算完成后，执行一个操作并消费结果，但不返回新的 CompletableFuture。

3. thenRun：

         - thenRun(Runnable action)：当 CompletableFuture 计算完成后，运行一个 Runnable，但不使用 CompletableFuture 的结果，也不返回新的 CompletableFuture。

 组合方法

4. thenCombine 和 thenCompose：

        - thenCombine(CompletionStage other, BiFunction fn)：当两个 CompletableFuture 都完成后，应用一个函数到两个结果上，并返回一个新的 CompletableFuture。
   - thenCompose(Function> fn)：当第一个 CompletableFuture 完成后，应用一个函数到结果上，返回一个新的 CompletableFuture。

5. allOf 和 anyOf：

         - allOf(CompletableFuture... cfs)：返回一个新的 CompletableFuture，当所有给定的 CompletableFuture 完成后，它也完成。
   - anyOf(CompletableFuture... cfs)：返回一个新的 CompletableFuture，当任意一个给定的 CompletableFuture 完成后，它也完成。

 异常处理方法

6. handle 和 exceptionally：

        - handle(BiFunction fn)：当 CompletableFuture 完成时，无论是正常还是异常完成，应用一个处理函数到结果或异常上，并返回一个新的 CompletableFuture。
   - exceptionally(Function fn)：当 CompletableFuture 异常完成时，应用一个函数到异常上，返回一个新的 CompletableFuture。

 实例详解

下面是一个使用 CompletableFuture 的实例代码：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
 
public class CompletableFutureExample {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        // 使用 supplyAsync 创建一个异步任务
        CompletableFuture future = CompletableFuture.supplyAsync(() -> {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Hello";
        });
 
        // thenApply 在前一个任务完成后应用一个函数
        CompletableFuture resultFuture = future.thenApply(result -> result + " World");
 
        // get() 方法阻塞，直到计算完成
        String result = resultFuture.get();
        System.out.println(result); // 输出 "Hello World"
    }
}

 解释

1. 创建异步任务：

   java
   CompletableFuture future = CompletableFuture.supplyAsync(() -> {
       try {
           Thread.sleep(2000);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
       return "Hello";
   });

这段代码创建了一个异步任务，经过 2 秒钟后返回字符串 "Hello"。

2. 应用函数：

CompletableFuture resultFuture = future.thenApply(result -> result + " World");

        当第一个 CompletableFuture 完成后，thenApply 方法应用一个函数，将结果 "Hello" 变为 "Hello World"。

3. 获取结果:

String result = resultFuture.get();

   get() 方法阻塞当前线程，直到 CompletableFuture 计算完成，并返回结果 "Hello World"。

CompletableFuture 提供了丰富的方法来处理异步编程的各种场景。它们的组合和使用可以使得异步代码更加简洁和易于理解。