③. ReentrantLock开始解读AQS
写在最前面:
(1). 本次讲解我们走最常用的,lock/unlock作为案例突破口
(2). 我相信你应该看过源码了,那么AQS里面有个变量叫State,它的值有几种？3个状态:没占用是0,占用了是1,大于1是可重入锁
(3). 如果AB两个线程进来了以后,请问这个总共有多少个Node节点？答案是3个,其中队列的第一个是傀儡节点(哨兵节点)
业务图:
①. 代码展示
public class AQSDemo { public static void main(String[] args) { ReentrantLock lock = new ReentrantLock(); //带入一个银行办理业务的案例来模拟我们的AQS如何进行线程的管理和通知唤醒机制 //3个线程模拟3个来银行网点,受理窗口办理业务的顾客 //A顾客就是第一个顾客,此时受理窗口没有任何人,A可以直接去办理 new Thread(() -> { lock.lock(); try{ System.out.println("-----A thread come in"); try { TimeUnit.MINUTES.sleep(20); }catch (Exception e) {e.printStackTrace();} }finally { lock.unlock(); } },"A").start(); //第二个顾客,第二个线程---》由于受理业务的窗口只有一个(只能一个线程持有锁),此时B只能等待, //进入候客区 new Thread(() -> { lock.lock(); try{ System.out.println("-----B thread come in"); }finally { lock.unlock(); } },"B").start(); //第三个顾客,第三个线程---》由于受理业务的窗口只有一个(只能一个线程持有锁),此时C只能等待, //进入候客区 new Thread(() -> { lock.lock(); try{ System.out.println("-----C thread come in"); }finally { lock.unlock(); } },"C").start(); } }
②. 从最简单的lock方法开始看看公平和非公平
- ①. 通过ReentrantLock的源码来讲解公平锁和非公平锁
②. 可以明显看出公平锁与非公平锁的lock()方法唯一的区别就在于公平锁在获取同步状态时多了一个限制条件:hasQueuedPredecessors()
hasQueuedPredecessors是公平锁加锁时判断等待队列中是否存在有效节点的方法
