Spring Boot Async配置异常：max-size未按预期生效问题排查

你遇到的问题核心是没用到Spring配置的异步线程池，而是用了CompletableFuture.runAsync()默认的ForkJoinPool.commonPool()——这个线程池的默认并行度等于CPU核心数（比如8核机器就是8），所以最多同时执行8个任务，这就是你只看到8次日志的原因。

另外，Spring的@EnableAsync注解是配合@Async注解生效的，直接调用CompletableFuture.runAsync()并不会触发Spring的异步配置逻辑。

方法1：改用Spring官方推荐的@Async注解 #

1. 在Service的异步方法上添加@Async注解：

@Service
public class AsyncTaskService {
    @Async
    public CompletableFuture<Void> executeLongTask() {
        try {
            System.out.println("任务启动：" + Thread.currentThread().getName());
            Thread.sleep(5000); // 模拟耗时任务
            System.out.println("任务结束：" + Thread.currentThread().getName());
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        return CompletableFuture.completedFuture(null);
    }
}

2. 在调用处循环收集所有任务的Future，等待全部完成：

@Autowired
private AsyncTaskService asyncTaskService;

public void startBatchTasks() {
    List<CompletableFuture<Void>> taskFutures = new ArrayList<>();
    for (int i = 0; i < 40; i++) {
        taskFutures.add(asyncTaskService.executeLongTask());
    }
    // 阻塞主线程，等待所有异步任务执行完毕
    CompletableFuture.allOf(taskFutures.toArray(new CompletableFuture[0])).join();
}

方法2：手动指定Spring线程池给CompletableFuture #

如果坚持用CompletableFuture.runAsync()，需要把Spring配置好的线程池注入进来，作为参数传给runAsync()：

@Autowired
private ThreadPoolTaskExecutor taskExecutor;

public void startBatchTasks() {
    for (int i = 0; i < 40; i++) {
        CompletableFuture.runAsync(() -> {
            try {
                System.out.println("任务启动：" + Thread.currentThread().getName());
                Thread.sleep(5000);
                System.out.println("任务结束：" + Thread.currentThread().getName());
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }, taskExecutor);
    }
    // 注意：如果是Web环境，需确保主线程不提前退出，可通过CountDownLatch等工具等待任务完成
}

可以在启动时打印线程池参数，确认配置是否正确加载：

@Autowired
private ThreadPoolTaskExecutor taskExecutor;

@PostConstruct
public void logThreadPoolConfig() {
    System.out.println("核心线程数：" + taskExecutor.getCorePoolSize());
    System.out.println("最大线程数：" + taskExecutor.getMaxPoolSize());
    System.out.println("队列容量：" + taskExecutor.getQueueCapacity());
}

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