Java中Callable接口本身不支持结果聚合，需配合ExecutorService、Future和集合操作实现：通过invokeAll()批量提交并获取Future列表，或逐个submit后手动处理get()异常，再用Stream API归约聚合，同时需健壮处理异常与取消状态。
Java 中 Callable 接口本身不直接支持结果聚合，它只定义了带返回值的异步任务（V call() throws Exception）。真正实现任务结果聚合，需要配合线程池、Future 和集合操作来完成。
使用 ExecutorService 提交多个 Callable 并收集 Future
这是最常用的方式：通过 ExecutorService.invokeAll() 批量提交 Callable 任务，它会返回一个 List<future>></future>，每个 Future 对应一个任务的结果。
-
invokeAll()会阻塞直到所有任务完成（或超时），适合“全量等待”场景 - 遍历
Future列表调用get()获取结果（已知已完成，通常不会阻塞） - 注意捕获
ExecutionException和CancellationException
手动聚合：遍历 Future 列表并提取结果
若需更灵活控制（如跳过失败任务、设置单个超时），可逐个提交并处理：
- 用
executor.submit(callable)得到单个Future - 存入
List<future>></future>等容器 - 后续循环调用
future.get(timeout, unit)，配合 try-catch 处理异常 - 成功结果 add 到结果集合，失败可记录日志或忽略
结合 Stream API 实现函数式聚合
获取全部结果后，可用 Java 8+ Stream 进行归约（reduce）、求和、拼接等操作：
立即学习“Java免费学习笔记（深入）”；
- 例如：所有
Callable<Integer>的结果求和 →results.stream().mapToInt(Integer::intValue).sum() - 字符串结果合并：→
results.stream().collect(Collectors.joining(", ")) - 自定义聚合逻辑（如取最大值、去重统计）也容易通过
collect()或reduce()实现
异常与取消的健壮性处理
聚合过程必须考虑任务失败或被取消的情况：
-
future.isDone()和future.isCancelled()可提前判断状态 - 对
get()做异常封装：捕获ExecutionException（包装任务异常）、TimeoutException、CancellationException - 建议将结果封装为
Optional<T>或自定义的Result<T>类型，明确区分成功/失败
