本文深入探讨了java虚拟线程在使用`synchronized`关键字时可能导致的载体线程“固定”（pinning）问题。当虚拟线程在`synchronized`块内阻塞时，它不会从载体线程上卸载，而是阻塞了载体线程，从而影响并发性能。文章强调了这一限制，并推荐使用`reentrantlock`等协作式同步机制作为替代方案，以确保虚拟线程能够有效卸载，优化资源利用。
Java 虚拟线程与载体线程基础
Java 19 引入的虚拟线程（Virtual Threads，Project Loom 的成果）旨在大幅提升并发能力，通过将轻量级用户模式线程映射到少量平台线程（即载体线程）上。当虚拟线程执行阻塞操作时，理论上它应该能够从其载体线程上“卸载”（unmount），从而允许该载体线程去执行其他虚拟线程，实现高效的资源复用。这种机制使得开发者可以创建数百万个虚拟线程，而无需担心传统平台线程的资源开销。
synchronized 关键字导致的载体线程“固定”
然而，并非所有阻塞操作都能让虚拟线程顺利卸载。一个重要的例外是当虚拟线程执行本地方法、外部函数或synchronized块/方法中的代码时。在这种情况下，虚拟线程会被“固定”（pinned）到其载体线程上。这意味着即使虚拟线程处于阻塞状态，它也无法从载体线程上卸载。
“固定”的影响：
当虚拟线程被固定时，其载体线程也会随之阻塞。这实际上就失去了虚拟线程的优势，因为一个被固定的虚拟线程会独占一个宝贵的平台线程，阻止该平台线程服务其他虚拟线程。如果大量虚拟线程因synchronized而阻塞，系统将无法充分利用虚拟线程带来的高并发能力，甚至可能导致性能瓶颈。
这是一个Project Loom已知的局限性，并且在官方文档中有所提及，未来可能会有改进。
如何避免载体线程“固定”：替代方案
为了避免因synchronized关键字导致的载体线程固定问题，建议采用能够与虚拟线程机制协作的同步工具。
使用 ReentrantLock
ReentrantLock是synchronized关键字的一个强大替代品，它提供了更灵活的锁定机制，并且最重要的是，它已被设计为与虚拟线程良好协作。当虚拟线程通过ReentrantLock进入阻塞等待状态时，它能够正确地从载体线程上卸载，从而允许载体线程执行其他任务。
示例代码：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免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
