Java虚拟线程与线程池：为什么重复提交同一个虚拟线程到`newVirtualThreadPerTaskExecutor()`会失效？

Java虚拟线程与线程池的巧妙合作：深入探讨newvirtualthreadPertaskexecutor()的特点

本文分析了Java虚拟线程的Executors.newVirtualThreadPerTaskExecutor()线程池中执行的特殊问题。代码示例中的methods5函数试图重复向线程池提交相同的预创虚拟线程，但未打印预期日志；methods6函数使用传统线程和executors.newFixedThreadPool()正常运行。这背后的原因是什么？

让我们来看看问题代码：

private static void methods5() {
    ThreadFactory tf = Thread.ofVirtual().factory();
    try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
        Thread vt = tf.newThread(() -> log.info("vt task executed."));
        for (int i = 0; i < 10; i++) {
            executor.submit(vt);
        }
    }
}

private static void methods6() {
    try (ExecutorService executor = Executors.newFixedThreadPool(10)) {
        for (int i = 0; i < 10; i++) {
            executor.submit(() -> log.info("thread task executed."));
        }
    }
}

methods5函数的核心问题是它将同一虚拟线程对象vt重复提交到线程池。Executors.newVirtualThreadPerTaskExecutor()设计的初衷是为每个提交任务创建一个新的虚拟线程，而代码重复使用相同的vt，导致后续提交被忽略。

立即学习“Java免费学习笔记(深入)；

解决方案如下：

方法1：为每个任务提交新的虚拟线程

private static void methods5() {
    try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
        for (int i = 0; i < 10; i++) {
            executor.submit(() -> System.out.println("vt task executed."));
        }
    }
}

方法二:利用Lambda表达式，让线程池为每项任务创建新的虚拟线程 (效果与方法一相同，但代码更简单)

需要注意的是，由于创建和销毁虚拟线程的成本很低，使用Executors.newVirtualThreadPerTaskExecutor()线程池化的必要性不高，甚至可能违背虚拟线程设计的初衷。直接使用Thread.ofVirtual().start()启动虚拟线程通常是更好的选择。 使用线程池更适合管理有限的物理线程资源，而虚拟线程本身具有很高的并发能力。

以上是Java虚拟线程和线程池：为什么要重复提交相同的虚拟线程`newVirtualThreadPerTaskExecutor()`会失败吗？详情请关注图灵教育的其他相关文章！