在java中实现completablefuture的选择执行，核心是利用静态方法 anyof 或 allof。若需任一任务完成即触发后续逻辑，应使用 anyof；若需所有任务完成后再处理，则使用 allof。这两个方法接收可变数量的 completablefuture 对象作为参数，返回一个新的 completablefuture，其结果类型取决于具体用法。
如何获取任意一个已完成的任务结果
要获取第一个完成的任务结果，必须调用 CompletableFuture.anyOf()。该方法会阻塞直到其中一个传入的Future完成，并返回该Future的结果。需要注意的是，anyOf 返回的是 Object 类型，因此在使用前需要进行强制类型转换。如果某个任务抛出异常，anyOf 也会立即传播该异常，除非通过 exceptionally 等方法进行了处理。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AnyOfExample {
public static void main(String[] args) throws ExecutionException, InterruptedException {
CompletableFuture<String> task1 = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(1000); } catch (InterruptedException e) {}
return "Task 1 Result";
});
CompletableFuture<String> task2 = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(500); } catch (InterruptedException e) {}
return "Task 2 Result";
});
// anyOf 返回 Object，需要强转
CompletableFuture<Object> anyResult = CompletableFuture.anyOf(task1, task2);
String result = (String) anyResult.get();
System.out.println("First completed: " + result);
}
}
如何等待所有任务完成后统一处理
如果需要等待所有任务都完成后再进行统一处理，应使用 CompletableFuture.allOf()。与 anyOf 不同，allOf 返回的是一个 CompletableFuture<void></void>，它本身不包含任何结果数据。因此，通常的做法是先收集所有任务的引用，调用 allOf 等待它们全部完成，然后遍历原始列表，逐个调用 get() 获取每个任务的具体结果。这种方式适合并行计算后合并结果的场景。
你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型
立即学习“Java免费学习笔记（深入）”；
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;
public class AllOfExample {
public static void main(String[] args) throws ExecutionException, InterruptedException {
List<CompletableFuture<Integer>> futures = Arrays.asList(
CompletableFuture.supplyAsync(() -> { try { Thread.sleep(1000); } catch (InterruptedException e) {} return 10; }),
CompletableFuture.supplyAsync(() -> { try { Thread.sleep(800); } catch (InterruptedException e) {} return 20; }),
CompletableFuture.supplyAsync(() -> { try { Thread.sleep(1200); } catch (InterruptedException e) {} return 30; })
);
// allOf 返回 Void，不直接包含结果
CompletableFuture<Void> allDone = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));
// 等待所有完成
allDone.join();
// 手动收集结果
List<Integer> results = futures.stream()
.map(CompletableFuture::join)
.collect(Collectors.toList());
System.out.println("All results: " + results);
}
}
当某个任务抛出异常时选择执行会怎样
当参与选择的任务中有一个抛出未捕获的异常时，anyOf 和 allOf 的行为有所不同。anyOf 会在第一个任务完成（无论是正常返回还是异常）后立即返回，如果那个任务是异常完成的，后续的 get() 或 join() 调用将抛出 ExecutionException。allOf 则会等待所有任务结束，如果其中任何一个任务抛出异常，allOf 返回的 Future 也会以异常状态结束。为了稳健地处理这种情况，建议在提交任务时使用 exceptionally 或 handle 来捕获异常，将其转换为默认值或特定错误码，从而避免整个流程中断。
