如何为@Retryable注解配置最大线程数？

你当前的问题核心在于：@Async默认使用的SimpleAsyncTaskExecutor会为每个请求新建线程，没有并发数限制；而@Retryable本身不负责线程池管理，线程池的控制完全由@Async的执行器决定。要实现和原任务调度一样的并发限制，只需要为@Async配置自定义线程池即可。

解决方案步骤： #

1. 定义自定义线程池

创建一个配置类，声明带有并发限制的线程池Bean：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@Configuration
public class RetryAsyncPoolConfig {

    @Bean(name = "retryTaskExecutor")
    public Executor retryTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置核心线程数（保持和原任务调度一致的5）
        executor.setCorePoolSize(5);
        // 设置最大线程数（限制同时运行的线程上限）
        executor.setMaxPoolSize(5);
        // 任务队列容量，超出核心线程数的请求会进入队列等待
        executor.setQueueCapacity(100);
        // 线程名称前缀，方便日志排查
        executor.setThreadNamePrefix("Retry-Async-");
        executor.initialize();
        return executor;
    }
}

2. 指定@Async使用自定义线程池

修改你的重试方法，让@Async指定使用上面定义的线程池：

@Async("retryTaskExecutor")
@Retryable(maxAttempts = 3, backoff = @Backoff(1000))
public void retryExecution(){
    // 业务逻辑实现
}

3. 可选：用配置文件配置默认线程池（Spring Boot场景）

如果你的项目是Spring Boot，也可以通过配置文件直接设置默认的异步线程池，无需自定义Bean：

# 核心线程数
spring.task.execution.pool.core-size=5
# 最大线程数
spring.task.execution.pool.max-size=5
# 队列容量
spring.task.execution.pool.queue-capacity=100
# 线程名称前缀
spring.task.execution.thread-name-prefix=Retry-Async-

此时@Async无需指定Bean名称，直接使用默认配置即可。

关键说明 #

• 原任务调度的线程池限制是由调度器本身管理的，而@Async的线程池负责所有异步方法（包括重试的每一次尝试）的并发控制，配置后就能实现和原逻辑一致的“最多5个线程同时运行”的效果。
• 当调用retryExecution()的次数超过线程池最大容量时，超出的请求会进入队列等待，直到有空闲线程可用，不会无限制创建线程。

内容的提问来源于stack exchange，提问作者user1234SI.