在读《深入理解JVM虚拟机》这本书前两章的时候整理了JDK从1.0到最新版本发展史，其中记录了JDK这么多年来演进过程中的一些趣闻及引人注目的一些特性，在调研JDK19新增特性的时候了解到了虚拟线程这个概念，于是对虚拟线程进行学习整理内容如下。
虚拟线程(Virtual Threads)就犹如名字一样，并非传统意义上的JAVA线程。传统意义上的JAVA线程（以下称为平台线程）跟操作系统的内核线程是一一映射的关系（如图1所示）。而对于平台线程的创建和销毁所带来的开销是非常大的，所以JAVA采用线程池的方式来维护平台线程而避免线程的反复创建和销毁。
然而平台线程也会占用内存、CPU资源，往往在CPU和网络连接成为系统瓶颈前，平台线程首当其冲的会成为系统瓶颈。在单台服务器硬件资源确定的情况下，平台线程的数量同样也会因为硬件资源而受到限制，也成为单台服务器吞吐量提升的主要障碍。
图1 平台线程和系统线程映射关系
谈回虚拟线程，虚拟线程则是由JDK而非操作系统提供的一种线程轻量级实现，它相较于平台线程而言具有以下特性：
那么意味着若干的虚拟线程可以在同一个系统线程上运行应用程序的代码（如图2所示），只有在虚拟线程执行的时候才会消耗系统线程，在等待和休眠时不会阻塞系统线程。
图2 虚拟线程和平台线程映射关系
相较于平台线程而言，虚拟线程是一种非常廉价和丰富的线程，可以说虚拟线程的数量是一种近乎于无限多的线程，它对硬件的利用率接近于最好，在相同硬件配置服务器的情况下，虚拟线程比使用平台线程具备更高的并发性，从而提升整个应用程序的吞吐量。如果说平台线程和系统线程调度为1:1的方式，虚拟线程则采用M:N的调度方式，其中大量的虚拟线程M在较少的系统线程N上运行。
图3 JVM调度虚拟线程流程图
目标：
在 Java 中，经典线程是 java.lang.Thread 类的实例。后面我们也将它们称为平台线程。
非目标:
此方法创建一个新的虚拟线程来执行给定的 Runnable 任务。
Runnable runnable = () -> System.out.println("Virtual Thread");
Thread.startVirtualThread(runnable);
//or
Thread.startVirtualThread(() -> {
//Code to execute in virtual thread
System.out.println("Virtual Thread");
});
如果我们想在创建线程后显式启动它，我们可以使用 Thread.ofVirtual() 返回一个 VirtualThreadBuilder 实例。它的 start() 方法启动一个虚拟线程。这里的 Thread.ofVirtual().start(runnable) 等价于 Thread.startVirtualThread(runnable)。
ThreadFactory factory = Thread.ofVirtual().factory();
我们可以使用Thread.Builder引用来创建和启动多个线程。
Runnable runnable = () -> System.out.println("Virtual Thread");
Thread.Builder builder = Thread.ofVirtual().name("Virtual-Thread");
Thread t1 = builder.start(runnable);
Thread t2 = builder.start(runnable);
类似的 APIThread.ofPlatform()也可用于创建平台线程。
Thread.Builder builder = Thread.ofPlatform().name("Platform-Thread");
Thread t1 = builder.start(() -> {...});
Thread t2 = builder.start(() -> {...});
此方法为每个任务创建一个新的虚拟线程。 Executor 创建的线程数是无限的。
try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
IntStream.range(0, 10_000).forEach(i -> {
executor.submit(() -> {
Thread.sleep(Duration.ofSeconds(1));
return i;
});
});
}
图4 虚拟线程生命周期
请注意，当所有启动的非守护线程都终止时，JVM 终止。这意味着 JVM 在退出之前不会等待虚拟线程完成。
Thread virtualThread = ...; //创建虚拟线程
//virtualThread.setDaemon(true); //没有作用
Thread virtualThread = ...; //创建虚拟线程
//virtualThread.setPriority(Thread.MAX_PRIORITY); //没有作用
这些方法在虚拟线程上调用时会引发UnsupportedOperationException。
// 初始状态
private static final int NEW = 0;
// 线程启动，由于虚拟线程的run()是个空方法，此时尚未开始执行任务
// 真正的任务执行在cont.run
private static final int STARTED = 1;
// 可执行，尚未分配平台线程
private static final int RUNNABLE = 2;
// 可执行，已分配平台线程
private static final int RUNNING = 3;
// 线程尝试park
private static final int PARKING = 4;
// 从平台线程卸载
private static final int PARKED = 5;
// cont.yield失败，未从平台线程卸载
private static final int PINNED = 6;
// 尝试cont.yield
private static final int YIELDING = 7;
// 终结态
private static final int TERMINATED = 99;
任务说明：在控制台中打印一条消息之前等待1秒，现在使用Runnable创建10000个线程，用虚拟线程和平台线程执行它们，来比较两者的性能。我们将使用Duration.between()api 来测量执行所有任务的经过时间。
首先，我们使用一个包含 100 个平台线程的池。这样，Executor 一次可以运行 100 个任务，其他任务需要等待。由于我们有 10,000 个任务，因此完成执行的总时间约为 100 秒。
Instant start = Instant.now();
try (var executor = Executors.newFixedThreadPool(100)) {
for(int i = 0; i < 10_000; i++) {
executor.submit(runnable);
}
}
Instant finish = Instant.now();
long timeElapsed = Duration.between(start, finish).toMillis();
System.out.println("Total elapsed time : " + timeElapsed);
输出
Total elapsed time : 101152 //大概 101 秒
接下来，我们将Executors.newFixedThreadPool(100)替换为Executors.newVirtualThreadPerTaskExecutor()。这将在虚拟线程而不是平台线程中执行所有任务。
Instant start = Instant.now();
try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
for(int i = 0; i < 10_000; i++) {
executor.submit(runnable);
}
}
Instant finish = Instant.now();
long timeElapsed = Duration.between(start, finish).toMillis();
System.out.println("Total elapsed time : " + timeElapsed);
输出
Total elapsed time : 1589 // 大概 1.5 秒
请注意虚拟线程的超快性能将执行时间从 100 秒减少到 1.5 秒，而 Runnable 代码没有任何变化。 其他实际场景：https://zhuanlan.zhihu.com/p/604507117?utm_id=0
Java 线程池旨在避免创建新操作系统线程的开销，因为创建它们是一项昂贵的操作。但是创建虚拟线程并不昂贵，因此永远不需要将它们池化。建议每次需要时创建一个新的虚拟线程。 请注意，使用虚拟线程后，我们的应用程序可能能够处理数百万个线程，但其他系统或平台一次只能处理几个请求。例如，我们可以只有几个数据库连接或与其他服务器的网络连接。 在这些情况下，也不要使用线程池。相反，使用信号量来确保只有指定数量的线程正在访问该资源。
private static final Semaphore SEMAPHORE = new Semaphore(50);
SEMAPHORE.acquire();
try {
// 信号量被控制在 50 来访问请求
// 访问数据库或资源
} finally {
SEMAPHORE.release();
}
虚拟线程支持线程局部行为的方式与平台线程相同，但由于虚拟线程可以创建数百万个，因此只有在仔细考虑后才能使用线程局部变量。 例如，如果我们在应用程序中扩展一百万个虚拟线程，那么将有一百万个 ThreadLocal 实例以及它们所引用的数据。如此大量的实例会给内存带来很大的负担，应该避免。
有两种特定场景，虚拟线程可以阻塞平台线程（称为 OS 线程的固定）。 1、当它在同步块或同步方法内执行代码时 2、当它执行本地方法或外部函数时 这种同步块不会使应用程序出错，但它会限制应用程序的可扩展性，类似于平台线程。 如果一个方法使用非常频繁并且它使用同步块，则考虑将其替换为 ReentrantLock 机制。
public synchronized void m() {
try {
// ... 访问资源
} finally {
//
}
}
private final ReentrantLock lock = new ReentrantLock();
public void m() {
lock.lock(); // 阻塞
try {
// ... 访问资源
} finally {
lock.unlock();
}
}
长期以来，传统的 Java 线程一直很好用。随着微服务领域对可扩展性和高吞吐量的需求不断增长，虚拟线程将被证明是 Java 历史上的一个里程碑特性。使用虚拟线程，一个程序可以用少量的物理内存和计算资源处理数百万个线程，这是传统平台线程无法做到的。当与结构化并发相结合时，它还将导致编写更好的程序。
作者：京东科技 宋慧超
来源：京东云开发者社区 转载请注明来源
ThreadLocal，这个多线程场景中重要的特性，在虚拟线程领域兴风作浪，为了应付它，quarkus也是够拼，今天咱们就来聊聊这个话题，在轻松的气氛中结束《支持JDK19虚拟线程的web框架》系列
ThreadLocal，这个多线程场景中重要的特性，在虚拟线程领域兴风作浪，为了应付它，quarkus也是够拼，今天咱们就来聊聊这个话题，在轻松的气氛中结束《支持JDK19虚拟线程的web框架》系列