Java中如何通过LockSupport实现线程精确控制-java教程-PHP中文网

Java中如何通过LockSupport实现线程精确控制

P粉602998670

发布： 2025-11-15 15:20:02

原创

325人浏览过

LockSupport通过park()和unpark()实现线程精确控制，前者阻塞线程，后者唤醒指定线程，基于许可机制，允许unpark先于park调用，无需synchronized，适用于构建高级同步组件。

java中如何通过locksupport实现线程精确控制

在Java中，LockSupport 是 java.util.concurrent.locks 包下的一个工具类，用于创建锁和其他同步类的基本线程阻塞原语。它提供了比传统的 synchronized 和 Object.wait()/notify() 更底层、更灵活的线程控制方式。通过 park() 和 unpark() 方法，可以实现线程的精确唤醒与阻塞。

1. LockSupport核心方法说明

LockSupport 的核心在于两个静态方法：

LockSupport.park()：阻塞当前线程，直到其他线程调用该线程的 unpark(Thread)，或当前线程被中断。
LockSupport.unpark(Thread thread)：唤醒指定线程，使其从 park() 中返回。即使 unpark() 在 park() 之前调用，后续的 park() 也不会阻塞（类似信号量为1）。

这两个方法是“许可”机制：每个线程最多有一个“许可”，调用一次 unpark() 增加许可，调用 park() 消耗许可并阻塞，若无许可可用。

2. 实现线程精确唤醒示例

假设我们有两个线程：ThreadA 和 ThreadB，要求它们按顺序交替执行，比如 A 打印1，B 打印2，A 打印3……这种场景下，使用 wait/notify 需要加锁和条件判断，而 LockSupport 可以直接精准控制。

立即学习“Java免费学习笔记（深入）”；

代码示例如下：

public class PreciseControl {
    static Thread threadA, threadB;

    public static void main(String[] args) {
        threadA = new Thread(() -> {
            System.out.println("A");
            LockSupport.unpark(threadB); // 唤醒B
        }, "Thread-A");

        threadB = new Thread(() -> {
            LockSupport.park(); // 等待A唤醒
            System.out.println("B");
        }, "Thread-B");

        threadB.start();
        threadA.start();
    }
}

登录后复制

输出结果一定是：

AI卡通生成器

免费在线AI卡通图片生成器 | 一键将图片或文本转换成精美卡通形象

查看详情

A
B

登录后复制

因为 B 先启动并立即 park，处于等待状态；A 启动后打印并 unpark B，B 被唤醒继续执行。

3. 多线程顺序执行控制（A→B→C）

扩展到三个线程顺序执行，也可以通过 LockSupport 精确控制：

public class ABCOrder {
    public static void main(String[] args) throws InterruptedException {
        Thread threadA = new Thread(() -> {
            System.out.println("A");
            LockSupport.unpark(Thread.currentThread().getContextClassLoader().getSystemResourceAsStream("threadB")); // 示例示意，实际需引用
        });

        // 更清晰的方式是提前定义线程引用
        Thread a, b, c;
        a = new Thread(() -> {
            System.out.println("A");
            LockSupport.unpark(b);
        });
        b = new Thread(() -> {
            LockSupport.park();
            System.out.println("B");
            LockSupport.unpark(c);
        });
        c = new Thread(() -> {
            LockSupport.park();
            System.out.println("C");
        });

        c.start();
        b.start();
        a.start();

        // 等待完成
        a.join(); b.join(); c.join();
    }
}

登录后复制

关键点是：先启动后面的线程，让它们进入 park 状态，再由前序线程依次 unpark。