spring ThreadPoolTaskExecutor 异常处理

在Spring中，可以使用ThreadPoolTaskExecutor来创建线程池并执行异步任务。当线程池中的线程抛出异常时，可以通过设置异常处理器来处理这些异常。

以下是一个示例代码，演示了如何配置ThreadPoolTaskExecutor并处理异常：

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

public class MyTaskExecutor {

    private ThreadPoolTaskExecutor threadPoolTaskExecutor;

    public MyTaskExecutor() {
        threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
        threadPoolTaskExecutor.setCorePoolSize(5);
        threadPoolTaskExecutor.setMaxPoolSize(50);
        threadPoolTaskExecutor.setQueueCapacity(100);
        threadPoolTaskExecutor.setKeepAliveSeconds(30000);
        threadPoolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        threadPoolTaskExecutor.setThreadNamePrefix("MyTaskExecutor-");
        threadPoolTaskExecutor.initialize();
    }

    public void executeTask(Runnable task) {
        threadPoolTaskExecutor.execute(task);
    }

    public void shutdown() {
        threadPoolTaskExecutor.shutdown();
    }

    public int getActiveCount() {
        return threadPoolTaskExecutor.getActiveCount();
    }
}

在上面的代码中，我们创建了一个名为MyTaskExecutor的类，它使用ThreadPoolTaskExecutor来执行任务。我们设置了核心线程数、最大线程数、缓冲任务队列的长度和线程的存活时间。我们还设置了拒绝策略为CallerRunsPolicy，这意味着当线程池无法接受新任务时，会使用调用线程来执行任务。

你可以根据自己的需求来配置ThreadPoolTaskExecutor，并在executeTask方法中执行你的任务。如果任务抛出异常，你可以在任务的代码中进行异常处理。