服务器之家:专注于VPS、云服务器配置技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - Java并发之ReentrantLock类源码解析

Java并发之ReentrantLock类源码解析

2021-04-15 11:44LaplaceDemon Java教程

这篇文章主要为大家详细介绍了Java并发系列之ReentrantLock源码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

reentrantlock内部由sync类实例实现。

Java并发之ReentrantLock类源码解析

sync类定义于reentrantlock内部。

Java并发之ReentrantLock类源码解析

sync继承于abstractqueuedsynchronizer。

abstractqueuedsynchronizer继承于abstractownablesynchronizer。

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

Java并发之ReentrantLock类源码解析

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

Java并发之ReentrantLock类源码解析

nonfairsync是非公平锁。fairsync 是公平锁。

reentrantlock两个构造方法如下:

Java并发之ReentrantLock类源码解析

reentrantlock的lock方法

Java并发之ReentrantLock类源码解析

非公平锁的lock方法

Java并发之ReentrantLock类源码解析

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

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

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

Java并发之ReentrantLock类源码解析

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

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

Java并发之ReentrantLock类源码解析

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

Java并发之ReentrantLock类源码解析

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

Java并发之ReentrantLock类源码解析

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

Java并发之ReentrantLock类源码解析

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

Java并发之ReentrantLock类源码解析

reentrantlock的unlock方法

Java并发之ReentrantLock类源码解析

查看release()方法。

Java并发之ReentrantLock类源码解析

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

unparksuccessor()方法如下:

Java并发之ReentrantLock类源码解析

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

原文链接:https://www.cnblogs.com/shijiaqi1066/p/5156406.html

延伸 · 阅读

精彩推荐