17370845950

Java虚拟线程是JDK21正式引入的轻量级线程，通过Thread.ofVirtual()或Executors.newVirtualThreadPerTaskExecutor()创建，适用于高并发场景，但需避免阻塞操作和CPU密集计算。

Java 虚拟线程（Virtual Thread）是 JDK 21 正式引入的轻量级线程实现，基于 Project Loom，用于大幅提升高并发场景下的吞吐能力。它不是通过 new Thread() 创建的传统平台线程，而是由 JVM 管理、在用户态调度的“纤程”，开销极小，可轻松创建百万级实例。

使用 Thread.ofVirtual() 创建并启动

这是最推荐、最直观的方式，返回一个 Thread.Builder，支持链式配置和立即启动：

• 调用 Thread.ofVirtual().unstarted(Runnable) 获取未启动的虚拟线程对象，再手动调用 start()
• 或直接用 Thread.ofVirtual().start(Runnable) 一步创建并启动

示例：

Thread vt = Thread.ofVirtual().name("my-vt").start(() -> {
    System.out.println("运行在虚拟线程: " + Thread.currentThread());
});

使用 Executors.newVirtualThreadPerTaskExecutor()

适合任务驱动型场景（如 Web 请求、异步 I/O），每次提交任务都自动分配一个新虚拟线程，无需手动管理生命周期：

• 返回的 ExecutorService 是“按需创建 + 自动回收”的，任务结束即释放资源
• 不适用于需要复用线程或控制线程命名/上下文的场景

示例：

try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
    executor.submit(() -> System.out.println("任务执行中"));
}

注意事项与常见误区

虚拟线程不是“万能替代品”，使用时需注意：

• 不能调用 Thread.sleep()、Object.wait()、阻塞 I/O（如 FileInputStream.read()）等会挂起平台线程的操作——应改用 java.util.concurrent.StructuredTaskScope 或非阻塞 API（如 NIO、HttpClient 异步模式）
• 避免在虚拟线程中长时间 CPU 密集运算，否则会阻塞底层平台线程，影响其他虚拟线程调度
• 调试时注意：IDE 和 JFR 默认可能不显示虚拟线程细节，需开启 -XX:+UnlockDiagnosticVMOptions -XX:+DebugNonSafepoints 等参数辅助观测

兼容性与启用条件

虚拟线程是 JDK 21+ 的标准特性，但需满足：

• JDK 版本 ≥ 21（JDK 21 为正式 GA；JDK 19/20 为预览版，需加 --enable-preview）
• 代码编译和运行均需指定目标版本（如 --source 21 --target 21）
• 无需额外依赖或 JVM 参数（JDK 21 默认启用）