Java CompletableFuture结果合并与异常处理的艺术

在Java并发编程的世界里，CompletableFuture无疑是一颗璀璨的明珠。它不仅提供了强大的异步编程能力，还能优雅地处理多任务的结果合并与异常管理。本文将深入探讨CompletableFuture在结果合并与异常处理方面的应用，带你领略其独特的魅力。

结果合并：thenCombine与thenCompose

thenCombine：并行任务的完美融合

thenCombine方法允许我们将两个独立的异步任务的结果合并起来。假设我们有两个任务：一个是获取用户信息，另一个是获取用户的订单信息。我们可以使用thenCombine将这两个任务的结果合并为一个完整的用户资料。

CompletableFuture<User> getUser = CompletableFuture.supplyAsync(() -> fetchUser());
CompletableFuture<List<Order>> getOrders = CompletableFuture.supplyAsync(() -> fetchOrders());

CompletableFuture<UserProfile> combined = getUser.thenCombine(getOrders, (user, orders) -> {
    return new UserProfile(user, orders);
});

thenCompose：链式调用的优雅实现

与thenCombine不同，thenCompose用于将前一个任务的结果作为下一个任务的输入，从而实现链式调用。假设我们需要先获取用户ID，再根据用户ID获取用户详细信息，thenCompose可以优雅地实现这一需求。

CompletableFuture<String> getUserId = CompletableFuture.supplyAsync(() -> fetchUserId());
CompletableFuture<User> getUserDetails = getUserId.thenCompose(id -> CompletableFuture.supplyAsync(() -> fetchUserDetails(id)));

异常处理：exceptionally与handle

exceptionally：简单的异常处理

exceptionally方法允许我们在任务执行过程中出现异常时，提供一个备选的返回值。假设我们有一个任务可能会抛出异常，我们可以使用exceptionally来处理这种情况。

CompletableFuture<String> task = CompletableFuture.supplyAsync(() -> {
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Something went wrong");
    }
    return "Success";
});

CompletableFuture<String> handledTask = task.exceptionally(ex -> "Default Value");

handle：全面的异常处理

handle方法不仅能在任务出现异常时进行处理，还能在任务正常完成时对结果进行进一步的加工。这使得handle成为异常处理的瑞士军刀。

CompletableFuture<String> task = CompletableFuture.supplyAsync(() -> {
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Something went wrong");
    }
    return "Success";
});

CompletableFuture<String> handledTask = task.handle((result, ex) -> {
    if (ex != null) {
        return "Error: " + ex.getMessage();
    }
    return "Processed: " + result;
});

综合应用：结果合并与异常处理的完美结合

在实际应用中，我们往往需要将结果合并与异常处理结合起来，以确保程序的健壮性和灵活性。以下是一个综合示例，展示了如何在一个复杂的异步任务链中同时处理结果合并和异常。

CompletableFuture<String> task1 = CompletableFuture.supplyAsync(() -> {
    // 模拟任务1
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Task1 failed");
    }
    return "Result1";
});

CompletableFuture<String> task2 = CompletableFuture.supplyAsync(() -> {
    // 模拟任务2
    if (new Random().nextBoolean()) {
        throw new RuntimeException("Task2 failed");
    }
    return "Result2";
});

CompletableFuture<String> combined = task1.thenCombine(task2, (result1, result2) -> {
    return "Combined: " + result1 + " + " + result2;
}).handle((result, ex) -> {
    if (ex != null) {
        return "Error: " + ex.getMessage();
    }
    return result;
});

System.out.println(combined.join());

在这个示例中，我们首先定义了两个独立的异步任务task1和task2，然后使用thenCombine将它们的结果合并起来。最后，通过handle方法对合并后的结果进行异常处理，确保无论任务是否成功，我们都能得到一个合理的输出。

CompletableFuture作为Java并发编程的利器，提供了强大的结果合并与异常处理能力。通过灵活运用thenCombine、thenCompose、exceptionally和handle等方法，我们可以构建出既高效又健壮的异步程序。希望本文能为你打开一扇通往异步编程新世界的大门。