在 Spring 中为 @Async 自定义线程池需定义 ThreadPoolTaskExecutor 类型的 @Bean，设置核心/最大线程数、队列容量、线程名前缀等，并调用 initialize()；可通过 @Primary 全局生效或 @Async("beanName") 显式指定；注意方法需 public、由代理调用，返回值限 void/Future，异常需手动捕获。
在 Spring 中为 @Async 自定义线程池，核心是提供一个类型为 TaskExecutor 的 @Bean，并确保它被 Spring 识别为异步执行器。默认情况下 Spring 会使用简单的 SimpleAsyncTaskExecutor（非线程池，每次新建线程），不推荐用于生产环境。
定义一个 ThreadPoolTaskExecutor Bean
这是最常用且推荐的方式。创建一个配置类，声明一个返回 ThreadPoolTaskExecutor 的 @Bean 方法，并标注 @Primary（避免与其他执行器冲突）或通过 @Async("beanName") 显式指定：
- 设置核心线程数（
corePoolSize）、最大线程数（maxPoolSize）、队列容量（queueCapacity）和空闲线程存活时间（keepAliveSeconds） - 建议设置
threadNamePrefix，便于日志追踪异步任务线程来源 - 可选：配置拒绝策略（
setRejectedExecutionHandler），如CallerRunsPolicy防止任务丢失
@Configuration
@EnableAsync
public class AsyncConfig {
@Bean("customAsyncExecutor")
public TaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(20);
executor.setQueueCapacity(100);
executor.setKeepAliveSeconds(60);
executor.setThreadNamePrefix("async-task-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.initialize(); // 必须调用，否则启动时报错
return executor;
}
}
在 @Async 中指定线程池
有两种方式绑定自定义线程池：
- 全局默认：不加参数的
@Async会自动匹配容器中唯一的TaskExecutorBean；若存在多个，需用@Primary标记首选 Bean - 显式指定：在注解中传入 Bean 名称，例如
@Async("customAsyncExecutor")，适合多线程池场景（如 I/O 密集型 vs CPU 密集型任务分离）
注意事项与常见问题
使用过程中容易忽略的关键点：
立即学习“Java免费学习笔记（深入）”；
- 方法必须是 public 且由 Spring 代理调用：直接 this.method() 不会触发异步，必须通过注入的 Service 实例调用
- 返回值只能是 void 或 Future 及其子类（如 CompletableFuture）：否则 Spring 无法处理异步结果
-
异常不会自动抛给调用方：void 方法中的异常会被吞掉；使用
Future.get()或CompletableFuture.exceptionally()手动捕获 - 不要在同一个类内调用本类的 @Async 方法：因代理失效，会同步执行
进阶：配合配置文件动态调参
可通过 @Value 注入配置，实现线程池参数外部化：
@Value("${async.core-pool-size:5}")
private int corePoolSize;
@Value("${async.max-pool-size:20}")
private int maxPoolSize;
// ... 在 Bean 创建时使用这些变量
再配合 application.yml：
async: core-pool-size: 8 max-pool-size: 32 queue-capacity: 200
这样便于不同环境灵活调整，无需改代码。
