巨蟹座适合网站建设吗,做网站的分析报告案例,深圳宝安区好不好,cj联盟wordpress1.前言
在读《深入理解JVM虚拟机》这本书前两章的时候整理了JDK从1.0到最新版本发展史#xff0c;其中记录了JDK这么多年来演进过程中的一些趣闻及引人注目的一些特性#xff0c;在调研JDK19新增特性的时候了解到了虚拟线程这个概念#xff0c;于是对虚拟线程进行学习整理内…1.前言
在读《深入理解JVM虚拟机》这本书前两章的时候整理了JDK从1.0到最新版本发展史其中记录了JDK这么多年来演进过程中的一些趣闻及引人注目的一些特性在调研JDK19新增特性的时候了解到了虚拟线程这个概念于是对虚拟线程进行学习整理内容如下。 2.虚拟线程介绍
虚拟线程(Virtual Threads)就犹如名字一样并非传统意义上的JAVA线程。传统意义上的JAVA线程以下称为平台线程跟操作系统的内核线程是一一映射的关系如图1所示。而对于平台线程的创建和销毁所带来的开销是非常大的所以JAVA采用线程池的方式来维护平台线程而避免线程的反复创建和销毁。
然而平台线程也会占用内存、CPU资源往往在CPU和网络连接成为系统瓶颈前平台线程首当其冲的会成为系统瓶颈。在单台服务器硬件资源确定的情况下平台线程的数量同样也会因为硬件资源而受到限制也成为单台服务器吞吐量提升的主要障碍。
图1 平台线程和系统线程映射关系
谈回虚拟线程虚拟线程则是由JDK而非操作系统提供的一种线程轻量级实现它相较于平台线程而言具有以下特性
不依赖于平台线程的数量不会增加额外的上下文切换开销不会在代码的整个生命周期中阻塞系统线程整个虚拟线程的维护是通过JVM进行管理作为普通的JAVA对象存放在RAM中。
那么意味着若干的虚拟线程可以在同一个系统线程上运行应用程序的代码如图2所示只有在虚拟线程执行的时候才会消耗系统线程在等待和休眠时不会阻塞系统线程。
图2 虚拟线程和平台线程映射关系
相较于平台线程而言虚拟线程是一种非常廉价和丰富的线程可以说虚拟线程的数量是一种近乎于无限多的线程它对硬件的利用率接近于最好在相同硬件配置服务器的情况下虚拟线程比使用平台线程具备更高的并发性从而提升整个应用程序的吞吐量。如果说平台线程和系统线程调度为1:1的方式虚拟线程则采用M:N的调度方式其中大量的虚拟线程M在较少的系统线程N上运行。
3.虚拟线程如何被JVM调度呢
图3 JVM调度虚拟线程流程图
先创建一个虚拟线程此时JVM会将虚拟线程装载在平台线程上平台线程则会去绑定一个系统线程。JVM会使用调度程序去使用调度线程执行虚拟线程中的任务。任务执行完成之后清空上下文变量将调度线程返还至调度程序等待处理下一个任务。
4.虚拟线程的目标、非目标
目标
为java.lang.Thread增加一种额外的实现即虚拟线程它能做到在几个G的JVM堆上创建几百万个活动的虚拟线程这在现在的JDK中几乎不可能实现并且表现出和现在的线程几乎一样的行为。对虚拟线程问题定位也可以通过已经存在的JDK工具尽可能保持和现在的线程相似的方式。 在 Java 中经典线程是 java.lang.Thread 类的实例。后面我们也将它们称为平台线程。 非目标:
虚拟线程不是为了改变现在这种操作系统级别的线程的实现。虚拟线程不是为了自动将已经存在的线程构造方法自动转为虚拟线程。虚拟线程不是为了改变JMM。虚拟线程不是为了增加一种新的内部线程通信机制。除了并行流之外虚拟线程也不是为了提供一种新的数据并行结构。
5.如何创建虚拟线程
使用Thread.startVirtualThread()
此方法创建一个新的虚拟线程来执行给定的 Runnable 任务。
Runnable runnable () - System.out.println(Virtual Thread);
Thread.startVirtualThread(runnable);//orThread.startVirtualThread(() - {//Code to execute in virtual threadSystem.out.println(Virtual Thread);
});使用Thread.Builder
如果我们想在创建线程后显式启动它我们可以使用 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(() - {...});使用Executors.newVirtualThreadPerTaskExecutor() 此方法为每个任务创建一个新的虚拟线程。 Executor 创建的线程数是无限的。 try (var executor Executors.newVirtualThreadPerTaskExecutor()) {IntStream.range(0, 10_000).forEach(i - {executor.submit(() - {Thread.sleep(Duration.ofSeconds(1));return i;});});
}6.平台线程和虚拟线程的区别
图4 虚拟线程生命周期
虚拟线程始终是守护线程。 Thread.setDaemon(false) 方法不能将虚拟线程更改为非守护线程。 请注意当所有启动的非守护线程都终止时JVM 终止。这意味着 JVM 在退出之前不会等待虚拟线程完成。 Thread virtualThread ...; //创建虚拟线程
//virtualThread.setDaemon(true); //没有作用虚拟线程始终具有正常优先级并且即使使用setPriority(n)方法也无法更改优先级。在虚拟线程上使用此方法无效。
Thread virtualThread ...; //创建虚拟线程
//virtualThread.setPriority(Thread.MAX_PRIORITY); //没有作用虚拟线程不是线程组的活动成员。在虚拟线程上调用时Thread.getThreadGroup()返回一个名为VirtualThreads的占位符线程组。虚拟线程不支持stop()、suspend()或resume()方法。 这些方法在虚拟线程上调用时会引发UnsupportedOperationException。 虚拟线程由JVM调度JVM将VT分配给平台线程的动作称为挂载mount取消分配的动作称为卸载unmount线程状态如下 // 初始状态private static final int NEW 0;// 线程启动由于虚拟线程的run()是个空方法此时尚未开始执行任务// 真正的任务执行在cont.runprivate static final int STARTED 1;// 可执行尚未分配平台线程private static final int RUNNABLE 2;// 可执行已分配平台线程private static final int RUNNING 3;// 线程尝试parkprivate static final int PARKING 4;// 从平台线程卸载private static final int PARKED 5;// cont.yield失败未从平台线程卸载private static final int PINNED 6;// 尝试cont.yieldprivate static final int YIELDING 7;// 终结态private static final int TERMINATED 99;7.实例场景分析平台线程和虚拟线程的性能 任务说明在控制台中打印一条消息之前等待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_id0 8.使用虚拟线程需要注意什么
不要建虚拟线程池
Java 线程池旨在避免创建新操作系统线程的开销因为创建它们是一项昂贵的操作。但是创建虚拟线程并不昂贵因此永远不需要将它们池化。建议每次需要时创建一个新的虚拟线程。 请注意使用虚拟线程后我们的应用程序可能能够处理数百万个线程但其他系统或平台一次只能处理几个请求。例如我们可以只有几个数据库连接或与其他服务器的网络连接。 在这些情况下也不要使用线程池。相反使用信号量来确保只有指定数量的线程正在访问该资源。
private static final Semaphore SEMAPHORE new Semaphore(50);SEMAPHORE.acquire();try {// 信号量被控制在 50 来访问请求// 访问数据库或资源
} finally {SEMAPHORE.release();
}避免使用线程局部变量 (ThreadLocal)
虚拟线程支持线程局部行为的方式与平台线程相同但由于虚拟线程可以创建数百万个因此只有在仔细考虑后才能使用线程局部变量。 例如如果我们在应用程序中扩展一百万个虚拟线程那么将有一百万个 ThreadLocal 实例以及它们所引用的数据。如此大量的实例会给内存带来很大的负担应该避免。
使用 ReentrantLock 而不是同步块
有两种特定场景虚拟线程可以阻塞平台线程称为 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();}
}9.结论
长期以来传统的 Java 线程一直很好用。随着微服务领域对可扩展性和高吞吐量的需求不断增长虚拟线程将被证明是 Java 历史上的一个里程碑特性。使用虚拟线程一个程序可以用少量的物理内存和计算资源处理数百万个线程这是传统平台线程无法做到的。当与结构化并发相结合时它还将导致编写更好的程序。 作者京东科技 宋慧超 来源京东云开发者社区 转载请注明来源
