当前位置：首页 > news >正文

Java 21 中虚拟线程的 M:N 调度模型解析

news 2026/5/1 7:23:27

Java 21 中虚拟线程的 M:N 调度模型解析

引言

在 Java 21 的众多特性中，虚拟线程的引入为并发编程带来了新的思路和解决方案。其中，虚拟线程所采用的 M:N 调度模型是其核心特性之一，对理解虚拟线程的工作原理和优势具有重要意义。

传统线程模型回顾

在传统的 Java 线程模型中，通常采用的是 1:1 调度模型。这意味着每个 Java 线程都直接映射到一个操作系统线程。操作系统负责这些线程的创建、销毁和调度。这种模型虽然简单直接，但在处理大量并发任务时存在一些局限性。例如，操作系统线程的创建和销毁开销较大，而且操作系统对线程数量的限制可能会成为应用程序并发性能的瓶颈。当需要处理成千上万个并发请求时，1:1 模型可能会导致资源耗尽和性能下降。

虚拟线程与 M:N 调度模型概述

Java 21 中的虚拟线程采用了 M:N 调度模型。在这个模型中，M 代表虚拟线程的数量，N 代表操作系统线程的数量。与 1:1 模型不同，多个虚拟线程可以映射到较少数量的操作系统线程上。虚拟线程是由 Java 虚拟机（JVM）管理的轻量级线程，它们的创建和销毁成本远低于操作系统线程。

M:N 调度模型的工作原理

虚拟线程的创建

在 Java 21 中，创建虚拟线程非常简单。可以使用Thread.startVirtualThread()方法来启动一个虚拟线程。当创建虚拟线程时，JVM 会在内部为其分配资源，但不会立即创建对应的操作系统线程。虚拟线程处于就绪状态，等待被调度执行。

调度器的作用

M:N 调度模型的核心是调度器。调度器负责将虚拟线程分配到可用的操作系统线程上执行。当有操作系统线程空闲时，调度器会从就绪的虚拟线程队列中选择一个合适的虚拟线程，并将其映射到该操作系统线程上开始执行。这种动态调度机制使得多个虚拟线程可以高效地共享有限的操作系统线程资源。

虚拟线程的执行与阻塞

当虚拟线程开始执行时，它会使用所映射的操作系统线程的资源来运行代码。如果在执行过程中虚拟线程遇到阻塞操作，例如等待 I/O 完成或锁的获取，调度器会将该虚拟线程从当前操作系统线程上卸载，并将操作系统线程释放出来，用于执行其他就绪的虚拟线程。而阻塞的虚拟线程则会被放入等待队列中，当阻塞条件解除后，它会被重新放回就绪队列，等待再次被调度执行。

虚拟线程的销毁

当虚拟线程执行完毕或遇到异常终止时，JVM 会回收其占用的资源。与操作系统线程不同，虚拟线程的销毁不会涉及操作系统的资源释放操作，因此开销非常小。

M:N 调度模型的优势

高并发处理能力

由于多个虚拟线程可以共享少量的操作系统线程，M:N 调度模型使得应用程序能够轻松处理大量的并发任务。例如，在一个 Web 服务器应用中，可以创建大量的虚拟线程来处理客户端请求，而不需要担心操作系统线程数量的限制。

资源利用效率高

通过动态调度虚拟线程，M:N 模型能够更充分地利用操作系统线程的资源。当有虚拟线程阻塞时，操作系统线程可以立即被用于执行其他就绪的虚拟线程，避免了操作系统线程的空闲等待，提高了系统整体的资源利用效率。

快速创建和销毁

虚拟线程的创建和销毁成本低，这使得应用程序可以根据实际需求快速创建和释放虚拟线程，而不会对系统性能产生显著影响。这对于需要频繁创建和销毁线程的场景，如高并发的短任务处理，非常有利。

代码示例

以下是一个简单的 Java 21 代码示例，展示了如何使用虚拟线程和 M:N 调度模型：

importjava.util.concurrent.Executors;publicclassVirtualThreadExample{publicstaticvoidmain(String[]args){// 创建虚拟线程执行器varexecutor=Executors.newVirtualThreadPerTaskExecutor();// 提交多个任务到虚拟线程执行器for(inti=0;i<1000;i++){finalinttaskId=i;executor.submit(()->{System.out.println("Task "+taskId+" is running on virtual thread "+Thread.currentThread());try{// 模拟任务执行时间Thread.sleep(100);}catch(InterruptedExceptione){Thread.currentThread().interrupt();}System.out.println("Task "+taskId+" is completed");});}// 关闭执行器executor.close();}}