Java并发之ReentrantLock类的示例分析

发布时间:2021-08-13 09:01:53 作者:小新
来源:亿速云 阅读:94

这篇文章将为大家详细讲解有关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的线程。然后将节点上的线程继续执行。

关于“Java并发之ReentrantLock类的示例分析”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。

推荐阅读:
  1. java并发工具类之Semaphore,Exchanger的示例分析
  2. 详解java并发之重入锁-ReentrantLock

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

java reentrantlock

上一篇:jquery中如何实现无new构建

下一篇:Angular项目如何实现新建

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》