Java 的虚拟线程提供了传统操作系统线程的轻量级替代方案,从而实现了高效的并发管理。但了解他们的行为对于获得最佳表现至关重要。这篇博文深入探讨了固定(一种可能影响虚拟线程执行的场景),并探讨了监控和解决该问题的技术。
Java 的虚拟线程是运行在底层操作系统线程(载体线程)之上的托管实体。与创建大量操作系统线程相比,它们提供了一种更有效的处理并发的方法,因为它们产生的开销较低。 JVM动态地将虚拟线程映射到承载线程,从而更好地利用资源。
由 JVM 管理:与操作系统直接管理的 OS 线程不同,虚拟线程由 Java 虚拟机 (JVM) 创建和调度。这允许在 JVM 环境中进行更细粒度的控制和优化。
减少开销:与操作系统线程相比,创建和管理虚拟线程所产生的开销显着降低。这是因为 JVM 可以利用较少数量的底层操作系统线程来有效管理更大的虚拟线程池。
与现有代码的兼容性:虚拟线程被设计为与现有Java代码无缝集成。它们可以与传统操作系统线程一起使用,并在 Executor 和 ExecutorService 等熟悉的结构中工作,用于管理并发。
下图展示了虚拟线程和平台线程的关系:
当虚拟线程与其承载线程绑定时,就会发生固定。这本质上意味着虚拟线程在处于固定状态时不能被抢占(切换到另一个承载线程)。以下是触发固定的常见场景:
代码示例:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Main { public static void main(String[] args) throws InterruptedException { final Counter counter = new Counter(); Runnable task = () -> { for (int i = 0; i在此示例中,当虚拟线程进入同步块时,它会固定到其承载线程,但这并不总是正确的。仅Java的synchronized关键字不足以导致虚拟线程中的线程固定。为了发生线程固定,同步块内必须有一个阻塞点,该阻塞点会导致虚拟线程触发暂停,并最终不允许从其承载线程卸载。线程固定可能会导致性能下降,因为它会抵消使用轻量级/虚拟线程的好处。
每当虚拟线程遇到阻塞点时,其状态就会转换为 PARKING。这种状态转换是通过调用 VirtualThread.park() 方法来指示的:
// JDK core code void park() { assert Thread.currentThread() == this; // complete immediately if parking permit available or interrupted if (getAndSetParkPermit(false) || interrupted) return; // park the thread setState(PARKING); try { if (!yieldContinuation()) { // park on the carrier thread when pinned parkOnCarrierThread(false, 0); } } finally { assert (Thread.currentThread() == this) && (state() == RUNNING); } }让我们看一个代码示例来说明这个概念:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Main { public static void main(String[] args) { Counter counter = new Counter(); Runnable task = () -> { for (int i = 0; i
-Djdk.tracePinnedThreads=full 标志是一个 JVM 启动参数,它提供有关虚拟线程固定的详细跟踪信息。启用后,它会记录以下事件:
仅在调试会话期间明智地使用此标志,因为它会带来性能开销。
编译我们的演示代码:
javac Main.java
使用 -Djdk.tracePinnedThreads=full 标志启动编译的代码:
java -Djdk.tracePinnedThreads=full Main
观察控制台中的输出,其中显示了有关虚拟线程固定的详细信息:
Thread[#29,ForkJoinPool-1-worker-1,5,CarrierThreads] java.base/java.lang.VirtualThread$VThreadContinuation.onPinned(VirtualThread.java:183) java.base/jdk.internal.vm.Continuation.onPinned0(Continuation.java:393) java.base/java.lang.VirtualThread.parkNanos(VirtualThread.java:621) java.base/java.lang.VirtualThread.sleepNanos(VirtualThread.java:791) java.base/java.lang.Thread.sleep(Thread.java:507) Counter.increment(Main.java:38)
固定是一种不良情况,它会影响虚拟线程的性能。可重入锁是抵消固定的有效工具。以下是如何使用可重入锁来缓解锁定情况:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.locks.ReentrantLock; public class Main { public static void main(String[] args) { Counter counter = new Counter(); Runnable task = () -> { for (int i = 0; i在更新的示例中,我们使用 ReentrantLock 而不是同步块。线程可以获取锁并在完成操作后立即释放它,与可能持有锁较长时间的同步块相比,可能会减少锁定的持续时间。
综上所述
Java 的虚拟线程证明了该语言的发展和功能。它们为传统操作系统线程提供了一种全新的、轻量级的替代方案,为高效的并发管理提供了一座桥梁。花时间深入挖掘并理解线程固定等关键概念可以让开发人员掌握充分利用这些轻量级线程潜力的专业知识。这些知识不仅帮助开发人员为利用即将推出的功能做好准备,还使他们能够在当前项目中更有效地解决复杂的并发控制问题。
免责声明: 提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发到邮箱:[email protected] 我们会第一时间内为您处理。
Copyright© 2022 湘ICP备2022001581号-3