如何用Java 19虚拟线程配合ScheduledExecutorService且无需指定池大小？

核心需求 #

需要调度上千个周期性IO任务（网络请求），希望利用虚拟线程的轻量性，遵循“每个任务对应一个虚拟线程”的原则，同时无需强制指定固定大小的线程池。

当前Java API的限制 #

Java标准库中，Executors.newScheduledThreadPool必须指定核心线程数，即使传入虚拟线程工厂也无法省略这个参数——这是因为ScheduledThreadPoolExecutor的设计依赖核心线程数维护调度队列的工作线程。但虚拟线程的特性决定了这个数值并不会像平台线程那样占用系统资源，因为虚拟线程由JVM托管，创建成本极低。

可行的解决方案 #

1. 适配现有ScheduledThreadPoolExecutor

直接使用Executors.newScheduledThreadPool，将核心线程数设为足够大的值（比如Integer.MAX_VALUE），配合虚拟线程工厂：

ScheduledExecutorService executor = Executors.newScheduledThreadPool(
    Integer.MAX_VALUE, 
    Thread.ofVirtual().factory()
);

这个方案完全符合需求：每次调度任务都会使用新的虚拟线程执行，核心线程数的上限在这里只是逻辑限制，不会造成资源浪费——虚拟线程在任务执行完毕后会被JVM自动回收，不会长期占用系统资源。

2. 基于虚拟线程执行器封装调度逻辑

如果不想依赖ScheduledThreadPoolExecutor的核心线程数设置，可以用Executors.newVirtualThreadPerTaskExecutor()配合手动调度逻辑：

ExecutorService virtualExecutor = Executors.newVirtualThreadPerTaskExecutor();

// 封装定时执行方法
public void scheduleAtFixedRate(Runnable task, long initialDelay, long period, TimeUnit unit) {
    Runnable scheduledTask = () -> {
        task.run();
        // 任务执行完毕后调度下一次执行
        virtualExecutor.execute(() -> {
            try {
                Thread.sleep(unit.toMillis(period));
                scheduleAtFixedRate(task, 0, period, unit);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });
    };
    // 首次延迟执行
    virtualExecutor.execute(() -> {
        try {
            Thread.sleep(unit.toMillis(initialDelay));
            scheduledTask.run();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    });
}

这种方式完全基于虚拟线程执行器，无需指定线程池大小，但需要自行处理调度的异常、中断等逻辑，适合对调度逻辑有自定义需求的场景。

总结 #

Java标准库目前（截至Java 21）并未提供直接的“无固定大小虚拟线程调度执行器”工厂方法，最简洁的方案是使用Executors.newScheduledThreadPool(Integer.MAX_VALUE, Thread.ofVirtual().factory())——虚拟线程的轻量性让这个看似极端的核心线程数设置完全可行，不会带来资源压力。

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