

























在 Spring Boot 的 Web 容器中,完全可以维护多个线程池,这是一种非常常见的架构设计。不同业务场景对线程模型的需求不同,通过隔离线程池可以避免相互影响,提升系统的稳定性和可观测性。
以下是 Web 容器内常见的几种线程池及其用途:
处理非阻塞、可异步化的业务逻辑 。
public class ThreadPoolConfig {
@Bean("businessExecutor")
public ThreadPoolTaskExecutor businessExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(10);
executor.setMaxPoolSize(20);
executor.setQueueCapacity(100);
executor.setThreadNamePrefix("business-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
适用于大量 IO 操作(数据库查询、HTTP 调用、文件读写等),通常设置较大的线程数。
public ThreadPoolTaskExecutor ioExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(50);
executor.setMaxPoolSize(100);
executor.setQueueCapacity(500);
executor.setThreadNamePrefix("io-");
适用于计算密集型任务,线程数通常设置为 CPU 核心数。
public ThreadPoolTaskExecutor cpuExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
int processors = Runtime.getRuntime().availableProcessors();
executor.setCorePoolSize(processors);
executor.setMaxPoolSize(processors);
executor.setThreadNamePrefix("cpu-");
处理 @Scheduled 注解的定时任务,可以独立配置。
@Bean("scheduledExecutor")
public ThreadPoolTaskScheduler scheduledExecutor() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setPoolSize(10);
scheduler.setThreadNamePrefix("scheduled-");
用于 @Async 异步方法或应用事件监听器的处理。
public ThreadPoolTaskExecutor asyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(50);
executor.setThreadNamePrefix("async-");
Tomcat/Jetty/Undertow 处理 HTTP 请求的线程池,可在配置文件中调整:
虽然不是线程池,但 HikariCP 等连接池也维护着工作线程,需要合理配置。
connection-timeout: 30000
线程池隔离:将 IO 密集型、CPU 密集型、定时任务等不同负载类型的任务分配到不同的线程池
命名规范:为每个线程池设置有意义的名称前缀,便于问题排查
监控告警:对核心线程池添加监控,关注活跃线程数、队列大小、拒绝任务数等指标
拒绝策略:根据业务场景选择合适的拒绝策略:
CallerRunsPolicy:降级,由调用线程执行
AbortPolicy:抛出异常
DiscardPolicy:静默丢弃
DiscardOldestPolicy:丢弃最旧的任务
优雅关闭:在应用关闭时确保线程池正确关闭,避免数据丢失
businessExecutor().shutdown();
通过合理配置多个线程池,可以让 Spring Boot 应用更好地应对复杂业务场景,提升系统的吞吐量和稳定性。
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。