ThreadPoolTaskExecutor 合并线程结果

`ThreadPoolTaskExecutor` 是 Java 中 `java.util.concurrent` 包下的一个组件，用于异步执行任务，通常在多线程环境下使用。它是一个实现了 `ExecutorService` 接口的工具类，能够将任务提交到一个由线程池管理的工作队列中，这些任务会在线程池中并发执行。

当你将任务提交给 `ThreadPoolTaskExecutor` 后，任务会被放入线程池的内部队列，线程池会根据其配置（线程数量、拒绝策略等）来处理这些任务。默认情况下，任务的结果并不会直接返回给调用者，而是被存储在线程池内部，除非任务是 `Future` 或 `Callable` 类型，这样你可以获取一个表示任务结果的 `Future` 对象。

合并线程结果，通常有两种方式：

1. **同步获取**：如果你想要立即获得所有任务的结果，并且这些任务是可等待的（例如 `Future` 对象），你可以遍历 `ThreadPoolTaskExecutor` 的完成的任务集合，逐个获取它们的结果。这可能会阻塞主线程直到所有任务完成。

ExecutorService executor = ...;
List<Future<?>> futures = executor.invokeAll(tasks);
for (Future<?> future : futures) {
    try {
        Object result = future.get(); // 获取结果
        // 处理结果
    } catch (InterruptedException | ExecutionException e) {
        // 处理异常
    }
}
executor.shutdown();

2. **使用回调或监听器**：如果你的任务没有返回值，或者你不想阻塞主线程，可以使用 `ThreadPoolTaskExecutor` 提供的 `submit` 方法，并为每个任务提供一个接受结果的回调函数。这个函数会在任务完成后被调用。

executor.execute(new Runnable() {
    @Override
    public void run() {
        // 执行任务
        // 结果不需要保存，但可以通过某种形式（如日志、事件系统）通知主线程
    }

    // 可选的，如果任务有结果需要处理，这里添加处理逻辑
});