【昕宝爸爸小模块】深入浅出之JDK21 中的虚拟线程到底是怎么回事（一）

在这里插入图片描述

➡️博客首页       https://blog.csdn.net/Java_Yangxiaoyuan

       欢迎优秀的你👍点赞、🗂️收藏、加❤️关注哦。

       本文章CSDN首发，欢迎转载，要注明出处哦！

       先感谢优秀的你能认真的看完本文，有问题欢迎评论区交流，都会认真回复！

JDK21 中的虚拟线程到底是怎么回事

一、✅典型解析
- 1.1 ✅在 JDK21 有哪些库可以用于虚拟线程支持
- 1.2 ✅虚拟线程和进程的区别是什么
- 1.3 ✅为什么虚拟线程更适合用于处理大量并发的场景
- 1.4 ✅JDK21中的其他并发编程模型
二、✅拓展知识仓
- 2.1 ✅JDK21中的其他并发编程模型是什么
- 2.2 ✅为什么虚拟线程更适合用于处理大量并发的场景呢
- 2.3 ✅虚拟线程和物理线程有什么区别
- 2.4 ✅虚拟线程和物理线程哪个更好呢
- 2.5 ✅虚拟线程的优缺点

一、✅典型解析

虚拟线程这个名字很多人可能比较懵，但是如果对像Go、Ruby、python等语言有一些了解的话，就会很快的反应过来，其实这就是协程。

在以前的JDK中，Java的线程模型其实比较简单，在大多数操作系统中，主要采用的是基于轻量级进程实现的一对一的线程模型，简单来说就是每一个Java线程对应一个操作系统中的轻量级进程，这种线程模型中的线程创建、析构及同步等动作，都需要进行系统调用。而系统调用则需要在 用户态 (UserMode) 和 内核态 (Kernel Mode) 中来回切换，所以性能开销还是很大的。

而新引入的虚拟线程，是JDK 实现的轻量级线程，他可以避免上下文切换带来的的额外耗费。他的实现原理其实是JDK不再是每一个线程都一对一的对应一个操作系统的线程了，而是会将多个虚拟线程映射到少量操作系统线程中，通过有效的调度来游免那些上下文切换。

在JDK 21，有多种方法可以创建协程，如Thread.startVirtualThread()、Executors.newVirtualThreadPerTaskExecutor() 等。

1.1 ✅在 JDK21 有哪些库可以用于虚拟线程支持

在 JDK 21 中，用于虚拟线程支持的库主要包括以下两个：

Project Loom：这是 Oracle 正在开发的一个项目，旨在为 Java 添加轻量级线程（也称为虚拟线程或纤程）。虚拟线程是一种轻量级的线程，与常规线程相比，它们具有更低的创建和销毁成本，并且可以在共享执行环境中并发运行。Project Loom 提供了一个基于虚拟线程的并发模型，以简化并发编程和提高应用程序的可伸缩性。

Quasar：另一个用于虚拟线程支持的库是 Quasar。Quasar 是一个开源项目，提供了基于 JVM 的纤程（fibre）和并行计算功能。它使用字节码转换技术来支持在 JVM 上运行轻量级线程，并提供了一套 API 和工具来简化并发编程。Quasar 支持与 Java 应用程序的集成，并且可以与现有的 Java 框架和库一起使用。

注意：JDK 21 本身并没有直接提供虚拟线程支持的库。这些库是作为单独的项目开发的，可能需要单独安装和使用。此外，这些库的具体实现和可用性可能随着时间的推移而有所变化，建议查看最新的官方文档以获取最准确的信息。

1.2 ✅虚拟线程和进程的区别是什么

虚拟线程和进程在概念、资源占用、执行效率、系统开销等方面存在明显的区别。

概念：进程是操作系统中的一个执行实例，有独立的内存空间、虚拟地址空间等资源。虚拟线程是进程中的一条执行路径，用于完成特定任务。进程是一个容器，而线程则是容器内的执行单元。

资源占用：进程拥有独立的内存空间和资源，不同的进程之间通常是相互独立的。而线程共享相同的内存空间和其他资源，线程之间的通信和协作更加方便。

执行效率：由于线程之间的切换开销比进程之间的切换开销小，因此多线程编程通常比多进程编程效率更高。

系统开销：在创建或撤消进程时，由于系统都要为之分配和回收资源，导致系统的开销明显大于创建或撤消线程时的开销。

以下是一个使用Java代码的详细解释：


/**
* @author xinbaobaba
* 展示了虚拟线程和进程的区别
*/
public class ProcessAndThreadComparison {public static void main(String[] args) {// 创建一个进程Process process = new Process();// 创建一个线程Thread thread = new Thread(() -> {// 线程执行的代码逻辑});// 启动进程process.start();// 启动线程thread.start();}
}

示例中：创建了一个进程和一个线程，并分别启动它们。下面我们分别解释进程和线程的不同点：

进程：

进程是一个独立的执行环境，拥有自己的内存空间、系统资源等。
进程之间的资源是相互隔离的，一个进程的崩溃不会影响其他进程的执行。
进程的创建和销毁需要较高的系统开销，因为需要分配和回收资源。
进程之间通信需要通过特定的机制，如管道、消息队列等。

线程：

线程是进程中的一个执行路径，共享进程的内存空间和其他资源。
线程之间的切换开销较小，因为它们共享相同的资源。
线程的创建和销毁相对较快，系统开销较小。
线程之间可以通过共享内存进行通信，协作更加方便。

通过以上代码和解释，我们可以看出虚拟线程和进程的区别主要在于资源占用、执行效率、系统开销等方面。在实际应用中，根据需求选择合适的方式来实现并发编程，以提高应用程序的性能和可伸缩性。

1.3 ✅为什么虚拟线程更适合用于处理大量并发的场景

虚拟线程更适合用于处理大量并发的场景，主要原因如下：

1. 更高的并发能力：虚拟线程由于其轻量级的特性，能够支持更高的并发能力。相比传统线程，虚拟线程的创建和销毁成本更低，使得能够同时处理更多的任务，更好地应对高并发场景。

2. 更好的资源利用：由于虚拟线程共享进程资源，可以更好地利用系统资源，避免资源的浪费。多个虚拟线程可以共享相同的内存空间和其他资源，使得资源利用率更高。

3. 更低的系统开销：与进程相比，虚拟线程的切换开销更小。在进行线程切换时，虚拟线程的上下文切换更加快速和高效，降低了系统开销，提高了处理大量并发任务的效率。

4. 更方便的编程模型：虚拟线程可以与现有的Java框架和库集成，提供更方便的并发编程模型。开发人员可以使用熟悉的Java语言和API进行编程，同时享受到虚拟线程带来的高并发优势。

总之，虚拟线程适合处理大量并发的场景，主要是因为它们能够提供更高的并发能力、更好的资源利用、更低的系统开销以及更方便的编程模型。这些优势使得虚拟线程成为处理高并发场景的理想选择。

1.4 ✅JDK21中的其他并发编程模型

JDK 21中的其他并发编程模型包括：

Reactor模式：用于构建响应式应用程序，可以更好地处理大量并发请求。
Actor模型：一种并发计算模型，通过消息传递的方式实现不同进程或线程之间的通信。
Dataflow模型：一种基于数据流的编程模型，可以自动处理并行和并发问题。
Promises和Futures模型：用于异步编程，可以避免回调地狱，使代码更加简洁易读。
Phaser模型：用于协调多个并行任务，确保它们按顺序执行。
Multicore并发模型：利用多核CPU的优势，通过并行处理提高程序性能。

这些模型在JDK 21中都有相应的实现和工具支持，可以帮助开发人员更好地处理并发问题，提高应用程序的性能和可伸缩性。选择合适的并发模型取决于具体的应用场景和需求。

二、✅拓展知识仓

2.1 ✅JDK21中的其他并发编程模型是什么

除了虚拟线程，JDK 21还提供了其他一些并发编程模型。以下是一些可能的例子：

CompletableFuture：这是JDK 8中引入的一个类，用于处理异步编程和并发编程。它提供了一种简单的方式来编写非阻塞的代码，并且可以链式调用。
Phaser：这是一个同步类，用于协调并行任务。它可以帮助你同步一组线程，以便它们可以一起完成某个任务。
ForkJoinPool：这是JDK 7中引入的一个类，用于实现Fork/Join并发模式。这种模式可以将一个大任务分解成多个小任务，然后使用工作窃取算法将小任务分配给不同的线程，最后再将结果合并。

Demo：

import java.util.concurrent.*;/**
* 
* 虚拟线程、CompletableFuture和Phaser
*/
public class ConcurrencyModelsComparison {public static void main(String[] args) {// 虚拟线程示例VirtualThread virtualThread = new VirtualThread();virtualThread.start();// CompletableFuture示例CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {// 异步执行的代码逻辑System.out.println("CompletableFuture task executed");});future.join(); // 等待异步任务完成// Phaser示例Phaser phaser = new Phaser(2); // 创建Phaser，初始阶段数为2phaser.register(); // 注册当前线程phaser.arriveAndAwaitAdvance(); // 等待所有线程到达并同步System.out.println("Phaser task executed");}
}

上面的代码，我们分别演示了 虚拟线程 、` CompletableFuture和Phaser的使用。以下是它们各自的特点：

虚拟线程：

虚拟线程是一种轻量级的线程，与常规线程相比具有更低的创建和销毁成本。
虚拟线程可以在共享执行环境中并发运行，提供更好的并发能力。
虚拟线程的切换开销较小，可以快速地在不同任务之间切换。
虚拟线程可以与其他Java框架和库集成，提供更方便的并发编程模型。

CompletableFuture：

CompletableFuture是Java 8引入的一个类，用于处理异步编程和并发编程。
它提供了一种简单的方式来编写非阻塞的代码，通过链式调用来处理异步操作的结果。
CompletableFuture可以与其他并发模型（如虚拟线程）结合使用，以实现更复杂的并发逻辑。
它提供了丰富的方法来处理异步任务的完成、异常处理等，使得代码更加简洁易读。

Phaser：

Phaser是一个同步类，用于协调并行任务。
它可以帮助你同步一组线程，以便它们可以一起完成某个任务。
Phaser通过阶段(phase)和参与者(participants)的概念来进行线程同步，能够处理更复杂的同步场景。
它通常用于解决需要等待一组线程都完成才能继续执行的问题。

2.2 ✅为什么虚拟线程更适合用于处理大量并发的场景呢

虚拟线程更适合用于处理大量并发的场景，主要是因为它们具有以下优势：

轻量级：虚拟线程比传统线程更加轻量级，因此它们的启动和销毁的开销更小。在应用程序需要创建大量线程时，这种轻量级特性使得虚拟线程的性能更优。
高并发能力：由于虚拟线程的轻量级特性，它们能够支持更高的并发能力。这意味着应用程序能够更好地处理高并发场景，而不会因为过多的线程而消耗过多的系统资源。
低内存消耗：虚拟线程相比传统线程具有更低的内存消耗，这使得它们能够更好地支持大规模的并发编程。在处理大量并发任务时，低内存消耗有助于防止因资源不足而导致的性能瓶颈。
简化并发编程：虚拟线程的设计初衷是为了简化并发编程。通过提供更高级别的抽象，虚拟线程使得编写、维护和观察高吞吐量并发应用程序的工作量大大减少。这有助于提高开发人员的工作效率，并减少因并发编程复杂性而导致的错误。
高吞吐量：虽然虚拟线程不能提供比平台线程更快的代码执行速度，但它们能够通过数量优势实现更高的吞吐量。在并发任务数量较高（超过几千个），并且工作负载不绑定CPU的情况下，虚拟线程有助于提高典型服务器应用程序的吞吐量。这是因为这类应用程序由大量并发任务组成，这些任务通常花费大量时间等待。
与现有框架集成：许多服务器框架选择使用虚拟线程来自动处理请求，为每个传入请求创建一个新的虚拟线程，并在其中运行应用程序的业务逻辑。这种集成方式使得处理请求的现有Java代码可以轻松地在虚拟线程中运行，进一步简化了并发编程。

总结：注意：虚拟线程通过其轻量级、高并发能力、低内存消耗等特性，以及与现有框架的集成和简化并发编程的优势，使其成为处理大量并发的场景的理想选择。

2.3 ✅虚拟线程和物理线程有什么区别

虚拟线程和物理线程是计算机领域中的两个重要概念，它们在定义、资源占用、调度和并发性等方面存在明显的区别。

定义：物理线程是指实际的硬件执行线程，通常一个核心对应一个物理线程。虚拟线程则是在操作系统上创建的逻辑执行单元，它不直接对应特定的CPU核心或处理器。
资源占用：物理线程需要实际的处理器、内存和其他硬件资源来执行任务。虚拟线程则只需要一部分CPU时间片和内存资源，因为它并不直接对应一个硬件执行线程。
调度：物理线程由操作系统的调度器来分配处理器时间。虚拟线程则是由线程库或操作系统的用户级线程管理器来调度，这使得虚拟线程可以在不涉及内核切换的情况下进行线程切换。
并发性：物理线程是真正的并发执行，可以在多个处理器核心上同时执行不同的任务。虚拟线程在同一时间只能有一个线程在执行，它们的并发性是通过线程切换来实现的。
亲和性：物理线程可以绑定到特定的CPU核心或处理器，以提高性能。虚拟线程通常不与特定的CPU核心或处理器相关联。

物理线程是直接由硬件执行的线程，而虚拟线程是由操作系统上的线程库或用户级线程管理器创建的线程。虚拟线程提供了一种更高级别的抽象，使得并发编程更加简化，特别适合处理大量并发的场景。

好的，以下是一个使用Java代码的详细介绍，包括虚拟线程和物理线程的区别：

public class ThreadComparison {public static void main(String[] args) {// 创建物理线程Thread physicalThread = new Thread(() -> {// 物理线程执行的代码逻辑System.out.println("Physical thread task executed");});physicalThread.start();// 创建虚拟线程VirtualThread virtualThread = new VirtualThread();virtualThread.start();}
}