Java CompletableFuture链式依赖的艺术

在Java并发编程的世界里，CompletableFuture无疑是一颗璀璨的明珠。它不仅提供了强大的异步编程能力，还能通过链式调用来构建复杂的任务依赖关系。本文将深入探讨CompletableFuture在结果转换链式依赖中的应用，揭示其优雅与高效。

初识CompletableFuture

CompletableFuture是Java 8引入的一个用于异步编程的类，它继承自Future接口，并提供了丰富的异步操作方法。通过这些方法，我们可以轻松地实现任务的链式调用和结果转换。

基本用法

首先，我们来看一个简单的例子：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");
future.thenApply(s -> s + " World")
      .thenAccept(System.out::println);

在这个例子中，supplyAsync方法异步生成一个字符串"Hello"，thenApply方法将结果转换为"Hello World"，最后thenAccept方法将结果打印出来。

链式依赖的构建

在实际应用中，我们经常需要将多个异步任务串联起来，形成链式依赖。CompletableFuture提供了多种方法来实现这一点。

thenCompose方法

thenCompose方法用于将前一个任务的结果作为参数，生成一个新的CompletableFuture。例如：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello")
    .thenCompose(s -> CompletableFuture.supplyAsync(() -> s + " World"));

future.thenAccept(System.out::println);

在这个例子中，第一个异步任务生成"Hello"，第二个异步任务在此基础上生成"Hello World"。

thenCombine方法

thenCombine方法用于将两个独立的CompletableFuture的结果合并起来。例如：

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> " World");

CompletableFuture<String> combined = future1.thenCombine(future2, (s1, s2) -> s1 + s2);

combined.thenAccept(System.out::println);

在这个例子中，future1和future2分别生成"Hello"和" World"，thenCombine方法将它们合并为"Hello World"。

结果转换的魔法

CompletableFuture不仅支持链式依赖，还提供了强大的结果转换功能。通过thenApply、thenAccept和thenRun等方法，我们可以灵活地处理异步任务的结果。

thenApply方法

thenApply方法用于对前一个任务的结果进行转换。例如：

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> "Hello")
    .thenApply(String::length);

future.thenAccept(length -> System.out.println("Length: " + length));

在这个例子中，thenApply方法将字符串"Hello"的长度转换为整数5。

thenAccept方法

thenAccept方法用于消费前一个任务的结果，但不返回新的结果。例如：

CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> "Hello")
    .thenAccept(System.out::println);

future.join();

在这个例子中，thenAccept方法将字符串"Hello"打印出来。

thenRun方法

thenRun方法用于执行一个无参数的Runnable，不关心前一个任务的结果。例如：

CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> "Hello")
    .thenRun(() -> System.out.println("Task completed"));

future.join();

在这个例子中，thenRun方法在字符串"Hello"生成后执行一个打印操作。

实战应用

在实际项目中，CompletableFuture的链式依赖和结果转换功能可以大大简化异步编程的复杂性。以下是一个模拟用户注册流程的例子：

CompletableFuture<Void> registerUser(String username) {
    return CompletableFuture.supplyAsync(() -> validateUsername(username))
        .thenCompose(valid -> {
            if (valid) {
                return CompletableFuture.supplyAsync(() -> createUser(username));
            } else {
                throw new IllegalArgumentException("Invalid username");
            }
        })
        .thenAccept(user -> sendWelcomeEmail(user.getEmail()));
}

boolean validateUsername(String username) {
    // 验证用户名逻辑
    return true;
}

User createUser(String username) {
    // 创建用户逻辑
    return new User(username, username + "@example.com");
}

void sendWelcomeEmail(String email) {
    // 发送欢迎邮件逻辑
    System.out.println("Welcome email sent to: " + email);
}

public static void main(String[] args) {
    registerUser("john_doe").join();
}

在这个例子中，registerUser方法首先异步验证用户名，然后根据验证结果创建用户，最后发送欢迎邮件。整个过程通过CompletableFuture的链式调用和结果转换