Java并发编程系列之LockSupport的用法

Java并发编程系列之LockSupport的用法攻略

概述

LockSupport是Java并发编程中提供的一种线程阻塞和唤醒的底层工具，它可以被用于实现高级别的同步工具（如Semaphore、ReentrantLock）等，也可以被用于线程间的通信。

在这篇文章中，我们将会详细介绍LockSupport的使用方法，包括使用park()和unpark()方法阻塞和唤醒线程、对线程中断、以及线程之间的交互等。

park()和unpark()

park()

LockSupport.park()方法可以使调用线程阻塞，相当于一种线程挂起的状态。在无参版本的park()方法中，如果调用线程因为调用park()方法而阻塞，那么它将一直阻塞直到以下四种情况之一发生：

• 调用unpark(Thread)方法且被唤醒线程的中断状态已经设置为“中断”状态。
• 调用unpark(Thread)方法且线程已经被唤醒了。
• 调用Thread.interrupt()方法且被唤醒线程的中断状态已经设置为“中断”状态。
• 调用park()方法的时候，当前线程的中断状态已经设置为“中断”状态。

unpark()

LockSupport.unpark(Thread)方法可以使调用线程恢复调用park()方法后的状态，相当于唤醒一个被挂起的线程。

在调用unpark(Thread)方法之后，如果调用park()方法的线程已经被挂起了，则该线程会被唤醒；否则下一次调用park()方法时，该线程将会立即被唤醒。

线程中断

当调用线程已经被阻塞时，调用线程的中断状态发生改变时，调用park()方法的线程将被唤醒，当线程被唤醒时，需要检查线程的中断状态并做出相应的响应。

示例一：

public class LockSupportDemo {

    public static void main(String[] args) {
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("thread park start!");
                LockSupport.park();
                System.out.println("thread park end!");
            }
        });
        thread.start();
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        thread.interrupt(); // 打断线程
    }
}

运行结果：

thread park start!
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194)
        at com.zhy.juc.c_020_LockSupport.LockSupportDemo$1.run(LockSupportDemo.java:15)
thread park end!

线程之间的交互

在多线程协作的场景下，可以通过LockSupport实现对线程的控制和同步。

示例二：

import java.util.concurrent.locks.LockSupport;

public class LockSupportDemo {

    private static Thread threadOne;
    private static Thread threadTwo;

    public static void main(String[] args) {
        threadOne = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("ThreadOne start");
                LockSupport.park(); // 挂起线程One
                System.out.println("ThreadOne end");
            }
        });
        threadTwo = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("ThreadTwo start");
                LockSupport.unpark(threadOne); // 唤醒线程One
                System.out.println("ThreadTwo end");
            }
        });
        threadOne.start();
        threadTwo.start();
    }
}

运行结果：

ThreadOne start
ThreadTwo start
ThreadTwo end
ThreadOne end

在这个示例中，线程One调用LockSupport.park()方法自我挂起，线程Two通过调用LockSupport.unpark(threadOne)来唤醒线程One，从而实现了线程之间的交互。

结论

通过本文的介绍，我们已经学习了LockSupport的基本用法，包括park()和unpark()方法的使用和线程中断、线程之间的交互等方面的知识。在实际开发中，我们可以根据自己的需求灵活使用LockSupport，从而实现多种复杂的线程同步和控制的功能。