AQS之ReentrantLock源码

执行业务代码

addWaiter(Node.EXCLUSIVE)

waitStatus=0

 acquire(1);

setHead(node);

 if (h != null && h.waitStatus != 0)

初始=0

head

pre

刚开始tail=null

创建节点

并且再次尝试获取锁

Node p = node.predecessor();

arg=1

int ws = pred.waitStatus;

lock = new ReentrantLock(true);

thread = t1

return false

thread = null

&& tryAcquire(arg))

设置中断标志，线程仍会继续运行Park不再起作用，让线程优雅的中断

this.waitStatus=0;this.prev=null;this.next=null;this.nextWaiter = null;this.thread = t1;

p.next = null; // help GCfailed = false;return interrupted;

if span style=\"font-size: inherit;\

3.1、获取队列中当前线程的前驱节点

执行业务代码逻辑......

文本

false

Node h = head;

selfInterrupt();

3、阻塞线程之前判断是否需要再次尝试获取锁

释放锁

tail

唤醒下一个线程

自旋第一轮循环前驱节点的状态变为-1，表示下一个线程可唤醒

因为加锁成功，当前线程属性置空并且变成队头

Node pred = tail;

next

Thread.currentThread().interrupt();

return true;

lock.unlock();

设计精髓1）cas构建队列2）自旋保证入队成功

return true

false，阻塞线程

如果是true表示当前线程已中断

判断线程前驱节点的状态

阻塞线程之前，将它的前驱节点waitStatus修改为-1，表示当前线程可被唤醒

自旋

SIGNAL(-1)

true

如果队列中当前线程的前驱节点就是队头，表示当前线程排在队列第一个。

获取锁失败，阻塞线程

阻塞当前线程

获取锁成功

return node

自旋第二轮循环

LockSupport.park(this)

unparkSuccessor(h);

t1线程进入队列排队

tryAcquire(arg)

Node p = prev;

-1

加锁成功

唤醒之后，测试当前线程是否被是中断唤醒的并清除中断标记

return Thread.interrupted();

t1线程入队

 &&parkAndCheckInterrupt()）

目的就是避免不必要的线程阻塞，阻塞线程再唤醒线程涉及到用户态和内核态的切换是一个比较重的操作

return p

if (tryRelease(arg))

FairSync.lock

sync.release(1);

interrupted = true;

lock.lock();

if (p == head

加锁失败2、t1线程进入等待队列

enq(node);//入队

初始化队列

符合允许可中断特性：中断唤醒之后，去获取锁

head = node;node.thread = null;node.prev = null;

1、t1线程尝试加锁

用图演示

公平锁源码分析