Spring 自定义线程池

Spring 提供了一种方便的方式来创建和管理线程池，即使用 ThreadPoolTaskExecutor 类。该类实现了 Spring 的 TaskExecutor 接口，可以用来执行异步任务，也可以用来管理线程池。下面是一个简单的例子：

@Configuration
@EnableAsync
public class AppConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(2);
        executor.setMaxPoolSize(5);
        executor.setQueueCapacity(10);
        executor.initialize();
        return executor;
    }

}

在这个例子中，我们使用了 @Configuration 注解来表示这是一个配置类。@EnableAsync 注解表示启用异步方法的执行。AsyncConfigurer 接口提供了一个 getAsyncExecutor 方法，用来返回一个 Executor 对象，即线程池。在这个方法中，我们创建了一个 ThreadPoolTaskExecutor 对象，并设置了核心线程数、最大线程数和队列容量。最后，我们调用了 executor.initialize() 方法来初始化线程池，并将它返回。

使用自定义的线程池时，我们可以在异步方法上使用 @Async 注解来指定使用哪个线程池。例如：

@Service
public class MyService {

    @Async("myExecutor")
    public void doSomething() {
        // ...
    }

}

在这个例子中，我们在 doSomething 方法上使用了 @Async("myExecutor") 注解，指定使用名为 myExecutor 的线程池来执行该方法。我们可以在配置类中通过设置 executor.setBeanName("myExecutor") 来为线程池指定名称。

除了上面的方式，我们还可以通过 XML 配置文件来创建和管理线程池，具体可以参考 Spring 文档。