ThreadPoolTaskExecutor 如何通知主线程

ThreadPoolTaskExecutor 是 Java 中的一个工具类，通常用于执行在后台线程池中运行的任务，而不需要直接关联到主线程。它的主要作用是异步执行任务，并且提供了回调或者监听机制来通知主线程任务的状态变化。

ThreadPoolTaskExecutor 提供了几种方式来通知主线程：

1. **Future<T> submit(Callable<T> task)** 或 **submit(Runnable task, T result)**：当异步执行完成后，可以通过返回的 Future 对象的 `get()` 方法获取结果或者使用 `isDone()`、`isCancelled()` 和 `isCompletedExceptionally()` 来检查任务状态。主线程可以通过这些方法来检查任务是否完成并处理结果。

2. **onAfterExecute(Runnable afterExecute)**：这个回调方法会在每个任务执行完成后调用，你可以在这里更新 UI 或者执行其他与主线程相关的操作。

3. **shutdown() / shutdownNow() / awaitTermination(long timeout, TimeUnit unit)**：在关闭线程池时，提供了方法来等待所有任务完成，这时主线程可以被通知线程池已关闭。

4. **setRejectedExecutionHandler(RejectedExecutionHandler handler)**：可以设置一个处理器来处理无法立即执行的任务，如拒绝策略，这样主线程可能也会收到一些通知。

5. **通过事件总线或者观察者模式**：如果应用框架支持事件或观察者模式，可以在 ThreadPoolTaskExecutor 中注册事件发布者，主线程作为事件监听器接收任务执行完成、错误等事件。

要确保通知的线程安全，通常需要在调用这些方法时使用正确的同步机制，如 SwingUtilities.invokeLater（如果是在 GUI 应用中）或者使用 ExecutorService 的响应式编程 API（如CompletableFuture）。