本文共 2587 字,大约阅读时间需要 8 分钟。
可重入锁又名递归锁。
是指在同一个线程在外层方法获取锁的时候,再进入该线程的内层方法会自动获取锁(前提,锁对象得是同一个对象),不会因为之前已经获取过还没释放而阻塞。
Java中ReentrantLock和synchronized都是可重入锁,可重入锁的一个优点是可一定程度避免死锁。
可: 可以。重: 再次。入: 进入。锁: 同步锁。
LockSupport是用来创建锁和其他同步类的基本线程阻塞原语。
LockSupport中的park()
和unpark()
的作用分别是阻塞线程和解除阻塞线程。 是一个线程等待唤醒机制的加强版。 三种让线程等待和唤醒的方法:
Object
中的wait()
方法让线程等待, 使用Object
中的notify()
方法唤醒线程。JUC
包中Condition
的await()
方法让线程等待,使用signal()
方法唤醒线程。LockSupport
类可以阻塞当前线程以及唤醒指定被阻塞的线程。传统的 synchronized 和 Lock 实现等待唤醒通知的约束:
LockSupport 案例:
import java.util.concurrent.locks.LockSupport;/** * LockSupport不用持有锁块,不用加锁,程序性能好 * 先后顺序,不容易导致卡死 */public class LockSupportDemo { public static void main(String[] args) throws Exception { Thread t1 = new Thread(() -> { System.out.println(Thread.currentThread().getName() + "\t wait park"); // 阻塞当前线程 LockSupport.park(); System.out.println(Thread.currentThread().getName() + "\t park end"); }, "Thread-1"); t1.start(); TimeUnit.SECONDS.sleep(2); LockSupport.unpark(t1); }}
先唤醒后等待,LockSupport也支持:
public class LockSupportDemo { public static void main(String[] args) throws Exception { Thread t1 = new Thread(() -> { try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "\t wait park " + System.currentTimeMillis()); // 阻塞当前线程 LockSupport.park(); System.out.println(Thread.currentThread().getName() + "\t park end" + System.currentTimeMillis()); }, "Thread-1"); t1.start(); LockSupport.unpark(t1); }}
LockSupport
是一个线程阻塞工具类,所有的方法都是静态方法,可以让线程在任意位置阻塞,阻塞之后也有对应的唤醒方法。 归根结底,LockSupport
调用的Unsafe
中的native
代码。 LockSupport
和每个使用它的线程都有一个许可(permit)
关联。permit
相当于1,0的开关,默认是0,调用一次unpark
就加1变成1,调用一次park
会消费permit
,也就是将1变成o,同时park
立即返回。
如再次调用park
会变成阻塞(因为permit
为零了会阻塞在这里,一直到permit
变为1),这时调用unpark
会把permit
置为1。
每个线程都有一个相关的permit
, permit
最多只有一个,重复调用unpark
也不会积累凭证。
形象的理解
线程阻塞需要消耗凭证(permit
),这个凭证最多只有1个。 当调用park
方法时: 而unpark
则相反,它会增加一个凭证,但凭证最多只能有1个,累加无效。
面试题:
为什么可以先唤醒线程后阻塞线程? 因为unpark
获得了一个凭证,之后再调用park
方法,就可以名正言顺的凭证消费,故不会阻塞。 为什么唤醒两次后阻塞两次,但最终结果还会阻塞线程?
因为凭证的数量最多为1,连续调用两次unpark
和调用一次unpark
效果一样,只会增加一个凭证; 而调用两次park
却需要消费两个凭证,证不够,不能放行。 AbstractQueuedSynchronizer
简称为AQS。
转载地址:http://mfchb.baihongyu.com/