Java 多线程并发LockSupport

什么是LockSupport

LockSupport是一个Java类，它提供了线程阻塞和唤醒的能力，可以被认为是更加高级的信号量，它可以使线程在任何地方阻塞，由于是以线程为单位进行阻塞和唤醒操作，LockSupport也被称作线程阴影悬挂。

LockSupport的使用

阻塞当前线程

阻塞当前线程的方式有两种，分别为park()和park(Object blocker)方法，park()方法会阻塞当前线程直到被唤醒，而park(Object blocker)方法则会将当前线程加入到blocker对象的等待队列中，线程阻塞后只有等待队列中的其他线程调用unpark(Thread thread)方法才能唤醒。

以下代码展示了如何使用park()方法来阻塞当前线程：

public class LockSupportDemo {
    public static void main(String[] args) {
        System.out.println("before park");
        // 阻塞当前线程
        LockSupport.park();
        System.out.println("after park");
    }
}

唤醒指定线程

唤醒指定线程的方式有两种，分别为unpark(Thread thread)和unpark(Object blocker)方法，unpark(Thread thread)方法会唤醒指定的线程，而unpark(Object blocker)方法则会唤醒阻塞在blocker对象等待队列中的所有线程。

以下代码展示了如何使用unpark(Thread thread)方法来唤醒指定线程：

public class LockSupportDemo {
    public static void main(String[] args) throws InterruptedException {
        Thread thread = new Thread(() -> {
            System.out.println("before park");
            // 阻塞当前线程
            LockSupport.park();
            System.out.println("after park");
        });
        thread.start();

        Thread.sleep(1000);

        System.out.println("before unpark");
        // 唤醒指定线程
        LockSupport.unpark(thread);
        System.out.println("after unpark");
    }
}

阻塞和唤醒线程示例

以下示例展示了如何使用LockSupport阻塞和唤醒线程：

public class LockSupportDemo {
    public static void main(String[] args) throws InterruptedException {
        Thread thread1 = new Thread(() -> {
            System.out.println("before park1");
            // 阻塞当前线程
            LockSupport.park();
            System.out.println("after park1");
        });
        thread1.start();

        Thread thread2 = new Thread(() -> {
            System.out.println("before park2");
            // 阻塞当前线程
            LockSupport.park();
            System.out.println("after park2");
        });
        thread2.start();

        Thread.sleep(1000);

        System.out.println("before unpark thread1");
        // 唤醒线程1
        LockSupport.unpark(thread1);
        System.out.println("after unpark thread1");

        Thread.sleep(1000);

        System.out.println("before unpark thread2");
        // 唤醒线程2
        LockSupport.unpark(thread2);
        System.out.println("after unpark thread2");
    }
}

注意事项

当使用LockSupport时，需要注意以下几点：

• unpark方法可以先于park方法调用，因为unpark方法可以在park方法之前调用，而线程调用park方法后才会阻塞。
• 如果线程在调用park方法之前已经被中断过，那么线程在调用park方法时会立即返回。
• LockSupport的park方法和unpark方法是不可重入的，如果同一个线程调用了多次park方法，那么后续的park方法只会将线程阻塞，而不会有任何效果。

总结

LockSupport是Java多线程并发编程中非常有用的工具类，可以有效的阻塞和唤醒线程。在使用LockSupport时需要注意线程的中断以及方法的不可重入问题。