Java CompletableFuture结果聚合：allOf与anyOf的艺术

在现代多线程编程中，Java的CompletableFuture类以其强大的异步处理能力备受青睐。其中，allOf和anyOf方法更是为结果聚合提供了便捷的途径。本文将深入探讨这两个方法的妙用，带你领略异步编程的魅力。

allOf：等待所有任务完成

CompletableFuture.allOf方法接受一系列CompletableFuture对象作为参数，返回一个新的CompletableFuture。这个新对象将在所有输入的CompletableFuture都完成时完成。这对于需要并行执行多个任务，并在所有任务完成后进行后续处理的场景非常适用。

示例代码

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

public class AllOfExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
        CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "World");
        CompletableFuture<String> future3 = CompletableFuture.supplyAsync(() -> "Java");

        CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(future1, future2, future3);

        combinedFuture.get(); // 等待所有任务完成

        // 获取各个任务的结果
        String result1 = future1.get();
        String result2 = future2.get();
        String result3 = future3.get();

        System.out.println(result1 + " " + result2 + " " + result3);
    }
}

应用场景

数据聚合：从多个数据源并行获取数据，待所有数据都准备好后再进行汇总处理。
批量操作：执行多个独立的数据库更新操作，确保所有操作完成后才提交事务。

anyOf：等待任意一个任务完成

与allOf不同，CompletableFuture.anyOf方法接受一系列CompletableFuture对象，返回一个新的CompletableFuture，这个新对象将在任意一个输入的CompletableFuture完成时完成。这对于那些只需任意一个任务完成即可继续执行的场景非常适用。

示例代码

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

public class AnyOfExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "First";
        });
        CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "Second");
        CompletableFuture<String> future3 = CompletableFuture.supplyAsync(() -> "Third");

        CompletableFuture<Object> anyFuture = CompletableFuture.anyOf(future1, future2, future3);

        Object result = anyFuture.get(); // 等待任意一个任务完成
        System.out.println("Completed task result: " + result);
    }
}

应用场景

快速响应：在多个服务中查询数据，只要有一个服务响应即可返回结果。
竞速条件：多个任务竞争执行，只需最快完成的任务结果。

结合使用：灵活应对复杂场景

在实际应用中，allOf和anyOf往往需要结合使用，以应对更复杂的业务需求。例如，可以先使用anyOf等待任意一个任务完成，再使用allOf确保所有任务最终都完成。

示例代码

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

public class CombinedExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Task 1");
        CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "Task 2");
        CompletableFuture<String> future3 = CompletableFuture.supplyAsync(() -> "Task 3");

        CompletableFuture<Object> anyFuture = CompletableFuture.anyOf(future1, future2, future3);
        CompletableFuture<Void> allFuture = CompletableFuture.allOf(future1, future2, future3);

        Object firstResult = anyFuture.get(); // 等待任意一个任务完成
        System.out.println("First completed task: " + firstResult);

        allFuture.get(); // 确保所有任务都完成
        System.out.println("All tasks completed.");
    }
}