本文深入探讨了java虚拟线程在使用`synchronized`关键字时可能导致的载体线程“固定”（pinning）问题。当虚拟线程在`synchronized`块内阻塞时，它不会从载体线程上卸载，而是阻塞了载体线程，从而影响并发性能。文章强调了这一限制，并推荐使用`reentrantlock`等协作式同步机制作为替代方案，以确保虚拟线程能够有效卸载，优化资源利用。
Java 虚拟线程与载体线程基础
Java 19 引入的虚拟线程（Virtual Threads，Project Loom 的成果）旨在大幅提升并发能力，通过将轻量级用户模式线程映射到少量平台线程（即载体线程）上。当虚拟线程执行阻塞操作时，理论上它应该能够从其载体线程上“卸载”（unmount），从而允许该载体线程去执行其他虚拟线程，实现高效的资源复用。这种机制使得开发者可以创建数百万个虚拟线程，而无需担心传统平台线程的资源开销。
synchronized 关键字导致的载体线程“固定”
然而，并非所有阻塞操作都能让虚拟线程顺利卸载。一个重要的例外是当虚拟线程执行本地方法、外部函数或synchronized块/方法中的代码时。在这种情况下，虚拟线程会被“固定”（pinned）到其载体线程上。这意味着即使虚拟线程处于阻塞状态，它也无法从载体线程上卸载。
“固定”的影响：
当虚拟线程被固定时，其载体线程也会随之阻塞。这实际上就失去了虚拟线程的优势，因为一个被固定的虚拟线程会独占一个宝贵的平台线程，阻止该平台线程服务其他虚拟线程。如果大量虚拟线程因synchronized而阻塞，系统将无法充分利用虚拟线程带来的高并发能力，甚至可能导致性能瓶颈。
立即学习“Java免费学习笔记（深入）”；
这是一个Project Loom已知的局限性，并且在官方文档中有所提及，未来可能会有改进。
如何避免载体线程“固定”：替代方案
为了避免因synchronized关键字导致的载体线程固定问题，建议采用能够与虚拟线程机制协作的同步工具。
使用 ReentrantLock
ReentrantLock是synchronized关键字的一个强大替代品，它提供了更灵活的锁定机制，并且最重要的是，它已被设计为与虚拟线程良好协作。当虚拟线程通过ReentrantLock进入阻塞等待状态时，它能够正确地从载体线程上卸载，从而允许载体线程执行其他任务。
讯飞智作-虚拟主播
讯飞智作是一款集AI配音、虚拟人视频生成、PPT生成视频、虚拟人定制等多功能的AI音视频生产平台。已广泛应用于媒体、教育、短视频等领域。
6 查看详情
示例代码：synchronized与ReentrantLock的对比
import java.util.concurrent.locks.ReentrantLock;public class VirtualThreadPinningDemo { private static final Object SYNC_LOCK = new Object(); private static final ReentrantLock REENTRANT_LOCK = new ReentrantLock(); public static void main(String[] args) throws InterruptedException { System.out.println("--- 演示 synchronized 导致的固定 ---"); // 模拟一个使用 synchronized 的虚拟线程 Thread.ofVirtual().name("SyncVirtualThread").start(() -> { System.out.println(Thread.currentThread().getName() + " (Virtual) - 进入 synchronized 块前."); synchronized (SYNC_LOCK) { System.out.println(Thread.currentThread().getName() + " (Virtual) - 进入 synchronized 块，模拟长时间阻塞."); try { // 模拟一个阻塞操作，此时载体线程被固定 Thread.sleep(2000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } System.out.println(Thread.currentThread().getName() + " (Virtual) - 离开 synchronized 块."); } }).join(); // 等待虚拟线程执行完毕 System.out.println("n--- 演示 ReentrantLock 避免固定 ---"); // 模拟一个使用 ReentrantLock 的虚拟线程 Thread.ofVirtual().name("ReentrantLockVirtualThread").start(() -> { System.out.println(Thread.currentThread().getName() + " (Virtual) - 尝试获取 ReentrantLock."); REENTRANT_LOCK.lock(); // 获取锁 try { System.out.println(Thread.currentThread().getName() + " (Virtual) - 成功获取 ReentrantLock，模拟长时间阻塞."); try { // 模拟一个阻塞操作，此时虚拟线程可以卸载 Thread.sleep(2000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } System.out.println(Thread.currentThread().getName() + " (Virtual) - 释放 ReentrantLock 前."); } finally { REENTRANT_LOCK.unlock(); // 释放锁 System.out.println(Thread.currentThread().getName() + " (Virtual) - 释放 ReentrantLock."); } }).join(); // 等待虚拟线程执行完毕 System.out.println("n所有演示完成."); }}
在上述示例中，当SyncVirtualThread在synchronized块内执行Thread.sleep(2000)时，它会将载体线程固定住。而ReentrantLockVirtualThread在调用REENTRANT_LOCK.lock()并随后Thread.sleep(2000)时，由于ReentrantLock和Thread.sleep()都已针对虚拟线程进行了优化，虚拟线程可以从载体线程上卸载。
其他协作机制
除了ReentrantLock，许多其他Java并发库中的类也已针对虚拟线程进行了修改，以确保在它们阻塞时能够实现虚拟线程的卸载。这包括：
CountdownLatch: 在等待计数器归零时，虚拟线程可以卸载。Semaphore: 在获取许可时阻塞，虚拟线程可以卸载。CompletableFuture: 在等待结果时，虚拟线程可以卸载。Thread.sleep(): 即使是简单的sleep方法，在Java 19+中也已更新，允许虚拟线程在休眠期间卸载。Object.wait(): 同样，wait()方法也支持虚拟线程卸载。
这些类之所以能够实现虚拟线程的卸载，是因为它们内部机制已与Java运行时和虚拟线程调度器协同工作。当这些方法被调用并导致虚拟线程进入阻塞状态时，它们会向虚拟线程调度器发出信号，表明当前虚拟线程可以安全地从其载体线程上卸载，从而释放载体线程去执行其他虚拟线程。
总结与最佳实践
理解虚拟线程的载体线程“固定”现象对于充分利用Project Loom的优势至关重要。
避免在虚拟线程中使用synchronized关键字：尤其是在synchronized块内可能发生长时间阻塞操作时，应尽量避免使用它。优先使用ReentrantLock等现代并发工具：ReentrantLock提供了与虚拟线程兼容的锁定机制，能够有效避免载体线程固定。利用其他协作式同步原语：CountdownLatch、Semaphore、CompletableFuture以及Thread.sleep()和Object.wait()等都已优化，可以安全地与虚拟线程一起使用，实现高效的资源利用。
通过遵循这些最佳实践，开发者可以确保虚拟线程能够充分发挥其轻量级和高并发的优势，构建出更具伸缩性和响应性的应用程序。
以上就是Java 虚拟线程与同步机制：理解载体线程的“固定”现象的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/308486.html
微信扫一扫 
支付宝扫一扫 
