Java CompletableFuture结果合并：thenCombine的妙用

在现代多线程编程中，Java的CompletableFuture无疑是一个强大的工具，它提供了丰富的API来处理异步编程。其中，thenCombine方法尤为引人注目，它允许我们将两个独立的异步任务的结果合并起来，生成一个新的结果。本文将深入探讨thenCombine的用法及其在实际应用中的创意实现。

什么是thenCombine？

thenCombine是CompletableFuture类中的一个方法，用于将两个独立的CompletableFuture任务的结果合并起来。其基本语法如下：

public <U, V> CompletableFuture<V> thenCombine(
    CompletionStage<? extends U> other,
    BiFunction<? super T, ? super U, ? extends V> fn
)

• other：另一个CompletableFuture任务。
• fn：一个双函数接口，用于定义如何合并两个任务的结果。

基本用法示例

假设我们有两个异步任务，一个计算平方，另一个计算立方，我们希望将这两个结果相加：

public static void main(String[] args) {
    CompletableFuture<Integer> square = CompletableFuture.supplyAsync(() -> 2 * 2);
    CompletableFuture<Integer> cube = CompletableFuture.supplyAsync(() -> 3 * 3 * 3);

    CompletableFuture<Integer> result = square.thenCombine(cube, (s, c) -> s + c);

    result.thenAccept(System.out::println); // 输出 11
}

在这个例子中，thenCombine将平方和立方的结果相加，最终输出11。

创意应用：并行数据处理

在实际应用中，thenCombine可以用于并行处理数据，提高程序的效率。以下是一个创意示例：假设我们需要处理一个大型的数据集，将其分为两部分，分别进行不同的处理，最后将结果合并。

public static void main(String[] args) {
    List<Integer> data = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

    CompletableFuture<List<Integer>> oddNumbers = CompletableFuture.supplyAsync(() ->
        data.stream().filter(n -> n % 2 != 0).collect(Collectors.toList())
    );

    CompletableFuture<List<Integer>> evenNumbers = CompletableFuture.supplyAsync(() ->
        data.stream().filter(n -> n % 2 == 0).collect(Collectors.toList())
    );

    CompletableFuture<List<Integer>> combinedResult = oddNumbers.thenCombine(evenNumbers, (odds, evens) -> {
        List<Integer> result = new ArrayList<>();
        result.addAll(odds);
        result.addAll(evens);
        return result;
    });

    combinedResult.thenAccept(System.out::println); // 输出 [1, 3, 5, 7, 9, 2, 4, 6, 8, 10]
}

在这个例子中，我们并行处理奇数和偶数，最后将结果合并。这种方式大大提高了数据处理的速度。

高级用法：链式调用

thenCombine可以与其他CompletableFuture方法结合使用，形成链式调用，进一步提升代码的简洁性和可读性。以下是一个示例：

public static void main(String[] args) {
    CompletableFuture<Integer> first = CompletableFuture.supplyAsync(() -> 10);
    CompletableFuture<Integer> second = CompletableFuture.supplyAsync(() -> 20);

    CompletableFuture<Integer> result = first.thenCombine(second, (f, s) -> f + s)
                                           .thenCombine(CompletableFuture.supplyAsync(() -> 30), (sum, third) -> sum + third);

    result.thenAccept(System.out::println); // 输出 60
}

在这个例子中，我们首先将first和second的结果相加，然后将这个结果与第三个异步任务的结果再相加，最终输出60。

总结

CompletableFuture的thenCombine方法为Java异步编程提供了强大的支持，使得并行数据处理和结果合并变得简单而高效。通过合理的运用thenCombine，我们不仅可以提高程序的执行效率，还能使代码更加简洁和易于维护。希望本文的示例和创意应用能为你带来灵感，让你在Java多线程编程中游刃有余。