Java 虚拟线程与同步机制：理解载体线程的“固定”现象

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所有演示完成.");
    }
}