Java并发之ReentrantLock类源码解析

reentrantlock内部由Sync类实例实现。

Sync类定义reentrantlock内部。

Sync继承于AbstractQueuedSynchronizer。

AbstractQueuedSynchronizer继承于AbstractOwnableSynchronizer。

AbstractOwnableSynchronizer类中只定义了一个exclusiveOwnerThread变量,表示当前拥有的线程。

除了Sync类,reentrantlock内部还定义了两个实现类。

Nonfairsync是非公平锁。Fairsync 是公平锁。

reentrantlock两个构造方法如下:

reentrantlock的lock方法

非公平锁的lock方法

compareAndSetState方法一个CAS方法。该方法尝试去更新对象内的一个变量。变量期望是0,更新为1。

若更新成功,则将exclusiveOwnerThread变量设置为当前线程。然后lock方法会立刻返回。

若更新不成功,则调用acquire(1)。

acquire方法中首先调用tryAcquire()再次尝试更新。

非公平锁的tryAcquire()方法如下:

非公平锁的tryAcquire()方法内部调用nonfairTryAcquire方法如下:

若tryAcquire()方法再次尝试不成功。则首先会调用addWaiter()方法,将当前线程加入等待队列。addWaiter方法返回一个Node节点。

返回节点后,acquireQueued(node,1)会再次尝试去做更新。

若还是无法更新,则通过parkAndCheckInterrupt将线程挂起。

reentrantlock的unlock方法

查看release()方法

若队列的head不为空,且head的等待状态不为0,则调用unparkSuccessor()方法

unparkSuccessor()方法如下:

使node的next从后向前遍历,获取到队列中最前面的一个waitStatus小于0的线程。然后将节点上的线程继续执行。

相关文章

HashMap是Java中最常用的集合类框架,也是Java语言中非常典型...
在EffectiveJava中的第 36条中建议 用 EnumSet 替代位字段,...
介绍 注解是JDK1.5版本开始引入的一个特性,用于对代码进行说...
介绍 LinkedList同时实现了List接口和Deque接口,也就是说它...
介绍 TreeSet和TreeMap在Java里有着相同的实现,前者仅仅是对...
HashMap为什么线程不安全 put的不安全 由于多线程对HashMap进...