启用虚拟线程后如何限制Spring @Async任务的并发数？

1. 配置带并发限制的虚拟线程池（最推荐） #

通过Spring配置限制异步任务的最大并发数，使其匹配数据库连接池的容量（比如你的连接池大小是100，就设为100或略小），从根源上避免连接耗尽。

方式一：配置文件全局设置 #

在application.properties或application.yml中添加：

# 启用虚拟线程
spring.threads.virtual.enabled=true
# 限制异步任务最大并发数，与连接池大小匹配
spring.task.execution.pool.max-size=100
# 队列容量设为0，避免任务积压（虚拟线程适合短任务场景）
spring.task.execution.pool.queue-capacity=0

方式二：自定义TaskExecutor Bean #

如果需要给不同异步任务分组管理，可以创建自定义线程池：

@Configuration
public class AsyncThreadPoolConfig {

    @Bean("databaseAsyncExecutor")
    public TaskExecutor databaseAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 启用虚拟线程模式
        executor.setVirtualThreads(true);
        // 最大并发数，匹配连接池容量
        executor.setMaxPoolSize(100);
        // 核心线程数与最大数保持一致
        executor.setCorePoolSize(100);
        // 禁用队列，任务直接提交
        executor.setQueueCapacity(0);
        executor.initialize();
        return executor;
    }
}

然后在异步方法上指定使用该线程池：

@Async("databaseAsyncExecutor")
public void execute() {
    myRepository.doSomething();
}

2. 使用信号量（Semaphore）手动限制并发 #

在任务类中加入信号量，直接控制同时执行数据库操作的任务数量：

@Component
@RequiredArgsConstructor
public class TestTask {

    private final MyRepository myRepository;
    // 许可数与数据库连接池大小一致
    private final Semaphore dbConnSemaphore = new Semaphore(100);

    @Async
    public void execute() {
        try {
            dbConnSemaphore.acquire();
            myRepository.doSomething();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            dbConnSemaphore.release();
        }
    }
}

这种方式适合临时快速修复，但缺乏Spring线程池自带的监控、管理能力，不如线程池配置优雅。

3. 调整数据库连接池大小（不推荐） #

虽然可以增大连接池max-active值（比如从100调到200），但不建议这么做：数据库能承载的并发连接数有限，过多连接会导致数据库上下文切换频繁，性能骤降甚至崩溃。优先限制任务并发数而非扩容连接池。

启用虚拟线程后，Spring默认的VirtualThreadTaskExecutor不会限制虚拟线程的创建数量（虚拟线程本身轻量，但每个任务都会占用一个数据库连接）。当大量任务同时执行时，短时间内就会耗尽所有连接，触发PoolExhaustedException。通过限制异步任务并发数，确保同时执行的任务数不超过连接池容量，就能解决问题。

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