JDK中lock锁的机制，其底层是一种无锁的架构实现的，公平锁和非公平锁

简述JDK中lock锁的机制，其底层是一种无锁的架构实现的，是否知道其是如何实现的

synchronized与lock

lock是一个接口，而synchronized是在JVM层面实现的。synchronized释放锁有两种方式：

  1. 获取锁的线程执行完同步代码，释放锁 。
  2. 线程执行发生异常，jvm会让线程释放锁。

lock锁的释放，出现异常时必须在finally中释放锁，不然容易造成线程死锁。lock显式获取锁和释放锁，提供超时获取锁、可中断地获取锁。

synchronized是以隐式地获取和释放锁，synchronized无法中断一个正在等待获取锁的线程。

synchronized原始采用的是CPU悲观锁机制，即线程获得的是独占锁。独占锁意味着其他线程只能依靠阻塞来等待线程释放锁。而在CPU转换线程阻塞时会引起线程上下文切换，当有很多线程竞争锁的时候，会引起CPU频繁的上下文切换导致效率很低。

Lock用的是乐观锁方式。所谓乐观锁就是，每次不加锁而是假设没有冲突而去完成某项操作，如果因为冲突失败就重试，直到成功为止。乐观锁实现的机制就是CAS操作。

具体的悲观锁和乐观锁的详细介绍请参考这篇文章[浅谈数据库乐观锁、悲观锁]

在JDK5中增加了一个Lock接口实现类ReentrantLock.它不仅拥有和synchronized相同的并发性和内存语义,还多了锁投票,定时锁,等候和中断锁等.它们的性能在不同的情况下会有不同。

在资源竞争不是很激烈的情况下,synchronized的性能要由于ReentrantLock,但是在资源竞争很激烈的情况下,synchronized的性能会下降得非常快,而ReentrantLock的性能基本保持不变.

接下来我们会进一步研究ReentrantLock的源代码，会发现其中比较重要的获得锁的一个方法是compareAndSetState。

lock源码

在阅读源码的成长的过程中，有很多人会遇到很多困难，一个是源码太多，另一方面是源码看不懂。在阅读源码方面，我提供一些个人的建议：

  1. 第一个是抓主舍次，看源码的时候，很多人会发现源码太长太多，看不下去，这就要求我们抓住哪些是核心的方法，哪些是次要的方法。当舍去次要方法，就会发现代码精简和很多，会大大提高我们阅读源码的信心。
  2. 第二个是不要死扣，有人看源码会一行一行的死扣，当看到某一行看不懂，就一直停在那里死扣，知道看懂为止，其实很多时候，虽然看不懂代码，但是可以从变量名和方法名知道该代码的作用，java中都是见名知意的。

接下来进入阅读lock的源码部分，在lock的接口中，主要的方法如下：

public interface Lock {// 加锁void lock()；// 尝试获取锁boolean tryLock();boolean tryLock(long time, TimeUnit unit) throws InterruptedException;// 解锁void unlock();
}

在lock接口的实现类中，最主要的就是ReentrantLock，来看看ReentrantLock中lock()方法的源码：

    // 默认构造方法，非公平锁public ReentrantLock() {sync = new NonfairSync();}// 构造方法，公平锁public ReentrantLock(boolean fair) {sync = fair ? new FairSync() : new NonfairSync();}// 加锁public void lock() {sync.lock();}

在初始化lock实例对象的时候，可以提供一个boolean的参数，也可以不提供该参数。提供该参数就是公平锁，不提供该参数就是非公平锁。

什么是非公平锁和公平锁呢？

非公平锁就是不按照线程先来后到的时间顺序进行竞争锁，后到的线程也能够获取到锁，公平锁就是按照线程先来后到的顺序进行获取锁，后到的线程只能等前面的线程都获取锁完毕才执行获取锁的操作，执行有序。

我们来看看lock()这个方法，这个有区分公平锁和非公平锁，这个两者的实现不同，先来看看公平锁，源码如下：

// 直接调用 acquire(1)
final void lock() {acquire(1);}

我们来看看acquire(1)的源码如下：

    public final void acquire(int arg) {if (!tryAcquire(arg) &&acquireQueued(addWaiter(Node.EXCLUSIVE), arg))selfInterrupt();}

这里的判断条件主要做两件事：

  1. 通关过该方法tryAcquire(arg)尝试的获取锁
  2. 若是没有获取到锁，通过该方法acquireQueued(addWaiter(Node.EXCLUSIVE), arg)就将当前的线程加入到存储等待线程的队列中。

其中tryAcquire(arg）是尝试获取锁，这个方法是公平锁的核心之一，它的源码如下：

protected final boolean tryAcquire(int acquires) {// 获取当前线程 final Thread current = Thread.currentThread();// 获取当前线程拥有着的状态int c = getState();// 若为0，说明当前线程拥有着已经释放锁if (c == 0) {// 判断线程队列中是否有，排在前面的线程等待着锁，若是没有设置线程的状态为1。if (!hasQueuedPredecessors() &&compareAndSetState(0, acquires)) {// 设置线程的拥有着为当前线程setExclusiveOwnerThread(current);return true;}// 若是当前的线程的锁的拥有者就是当前线程，可重入锁} else if (current == getExclusiveOwnerThread()) {// 执行状态值+1int nextc = c + acquires;if (nextc < 0)throw new Error("Maximum lock count exceeded");// 设置status的值为nextcsetState(nextc);return true;}return false;}

在tryAcquire()方法中，主要是做了以下几件事：

  1. 判断当前线程的锁的拥有者的状态值是否为0，若为0，通过该方法hasQueuedPredecessors()再判断等待线程队列中，是否存在排在前面的线程。
  2. 若是没有通过该方法 compareAndSetState(0, acquires)设置当前的线程状态为1。
  3. 将线程拥有者设为当前线程setExclusiveOwnerThread(current)
  4. 若是当前线程的锁的拥有者的状态值不为0，说明当前的锁已经被占用，通过current == getExclusiveOwnerThread()判断锁的拥有者的线程，是否为当前线程，实现锁的可重入。
  5. 若是当前线程将线程的状态值+1，并更新状态值。

公平锁的tryAcquire()，实现的原理图如下：

在这里插入图片描述

我们来看看acquireQueued()方法，该方法是将线程加入等待的线程队列中，源码如下：

final boolean acquireQueued(final Node node, int arg) {boolean failed = true;try {boolean interrupted = false;// 死循环处理for (;;) {// 获取前置线程节点final Node p = node.predecessor();// 这里又尝试的去获取锁if (p == head && tryAcquire(arg)) {setHead(node);p.next = null; // help GCfailed = false;// 直接return  interruptedreturn interrupted;}// 在获取锁失败后，应该将线程Park(暂停)if (shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt())interrupted = true;}} finally {if (failed)cancelAcquire(node);}}

acquireQueued()方法主要执行以下几件事：

  1. 死循环处理等待线程中的前置节点，并尝试获取锁，若是p == head && tryAcquire(arg)，则跳出循环，即获取锁成功。
  2. 若是获取锁不成功shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt()就会将线程暂停。

在acquire(int arg)方法中，最后若是条件成立，执行下面的源码：

selfInterrupt();
// 实际执行的代码为
Thread.currentThread().interrupt();

即尝试获取锁失败，就会将锁加入等待的线程队列中，并让线程处于中断等待。公平锁lock()方法执行的原理图如下：

在这里插入图片描述

之所以画这些原理的的原因，是为后面写一个自己的锁做铺垫，因为你要实现和前人差不多的东西，你必须了解该东西执行的步骤，最后得出的结果，执行的过程是怎么样的。

有了流程图，在后面的实现自己的东西才能一步一步的进行。这也是阅读源码的必要之一。

在lock()方法，其实在lock()方法中，已经包含了两方面：

  1. 锁方法lock()。
  2. 尝试获取锁方法tryAquire()。

接下来，我们来看一下unlock()方法的源码。

  public void unlock() {sync.release(1);}

直接调用release(1)方法，来看release方法源码如下:

    public final boolean release(int arg) {// 尝试释放当前节点if (tryRelease(arg)) {// 取出头节点Node h = head;if (h != null && h.waitStatus != 0)// 释放锁后要即使唤醒等待的线程来获取锁unparkSuccessor(h);return true;}return false;}

通过调用tryRelease(arg)，尝试释放当前节点，若是释放锁成功，就会获取的等待队列中的头节点，就会即使唤醒等待队列中的等待线程来获取锁。接下来看看tryRelease(arg)的源码如下：

// 尝试释放锁protected final boolean tryRelease(int releases) {// 将当前状态值-1int c = getState() - releases;// 判断当前线程是否是锁的拥有者，若不是直接抛出异常，非法操作，直接一点的解释就是，你都没有拥有锁，还来释放锁，这不是骗人的嘛if (Thread.currentThread() != getExclusiveOwnerThread())throw new IllegalMonitorStateException();boolean free = false;//执行释放锁操作 1.若状态值=0   2.将当前的锁的拥有者设为nullif (c == 0) {free = true;setExclusiveOwnerThread(null);}// 重新更新status的状态值setState(c);return free;}

总结上面的几个方法，unlock释放锁方法的执行原理图如下：

在这里插入图片描述

对于非公平锁与公平锁的区别，在非公平锁尝试获取锁中不会执行hasQueuedPredecessors()去判断是否队列中还有等待的前置节点线程。

如下面的非公平锁，尝试获取锁nonfairTryAcquire()源码如下：

final boolean nonfairTryAcquire(int acquires) {final Thread current = Thread.currentThread();int c = getState();if (c == 0) {// 直接就将status-1，并不会判断是否还有前置线程在等待if (compareAndSetState(0, acquires)) {setExclusiveOwnerThread(current);return true;}}else if (current == getExclusiveOwnerThread()) {int nextc = c + acquires;if (nextc < 0) // overflowthrow new Error("Maximum lock count exceeded");setState(nextc);return true;}return false;}

以上就是公平锁和非公平锁的主要的核心方法的源码，接下来我们实现自己的一个锁，首先依据前面的分析中，要实现自己的锁，拥有的锁的核心属性如下：

  1. 状态值status，0为未占用锁，1未占用锁，并且是线程安全的。
  2. 等待线程队列，用于存放获取锁的等待线程。
  3. 当前线程的拥有者。

lock锁的核心的Api如下：

  1. lock方法
  2. trylock方法
  3. unlock方法

依据以上的核心思想来实现自己的锁，首先定义状态值status，使用的是AtomicInteger原子变量来存放状态值，实现该状态值的并发安全和可见性。定义如下：

// 线程的状态 0表示当前没有线程占用   1表示有线程占用AtomicInteger status =new AtomicInteger();

接下来定义等待线程队列，使用LinkedBlockingQueue队列来装线程，定义如下：

// 等待的线程
LinkedBlockingQueue<Thread> waiters = new LinkedBlockingQueue<Thread>();

最后的属性为当前锁的拥有者，直接就用Thread来封装，定义如下：

// 当前线程拥有者
Thread ownerThread =null;

接下来定义lock()方法，依据上面的源码分析，在lock方法中主要执行的几件事如下：

  1. 死循环的处理等待线程队列中的线程，知道获取锁成功，将该线程从队列中删除，跳出循环。
  2. 获取锁不成功，线程处于暂停等待。
    @Overridepublic void lock() {// TODO Auto-generated method stub// 尝试获取锁if (!tryLock()) {// 获取锁失败，将锁加入等待的队列中waitersQueue.add(Thread.currentThread());// 死循环处理队列中的锁，不断的获取锁for (;;) {if (tryLock()) {// 直到获取锁成功，将该线程从等待队列中删除waitersQueue.poll();// 直接返回return;} else {// 获取锁不成功，就直接暂停等待。LockSupport.park();}}}}

然后是trylock方法，依据上面的源码分析，在trylock中主要执行的以下几件事：

  1. 判断当前拥有锁的线程的状态是否为0，为0，执行状态值+1，并将当前线程设置为锁拥有者。
  2. 实现锁可重入
    @Overridepublic boolean tryLock() {// 判断是否有现成占用if (status.get()==0) {// 执行状态值加1if (status.compareAndSet(0, 1)) {// 将当前线程设置为锁拥有者ownerThread = Thread.currentThread();return true;} else if(ownerThread==Thread.currentThread())  {// 实现锁可重入status.set(status.get()+1);}}return false;}

最后就是unlock方法，依据上面的源码分析，在unlock中主要执行的事情如下：

  1. 判断当前线程是否是锁拥有者，若不是直接抛出异常。
  2. 判断状态值是否为0，并将锁拥有者清空，唤醒等待的线程。
    @Overridepublic void unlock() {// TODO Auto-generated method stub// 判断当前线程是否是锁拥有者if (ownerThread!=Thread.currentThread()) {throw new RuntimeException("非法操作");}// 判断状态值是否为0if (status.decrementAndGet()==0) {// 清空锁拥有着ownerThread = null;// 从等待队列中获取前置线程Thread t = waitersQueue.peek();if (t!=null) {// 并立即唤醒该线程LockSupport.unpark(t);}}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/213642.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

androidstudio设置内存

androidstudio设置内存

androidstudio一直 scanning files to index&#xff0c;需要去设置内存&#xff1a; 操作如下&#xff1a;
阅读更多...
在Mac上安装Windows应用程序的简便方法：CrossOver for Mac

在Mac上安装Windows应用程序的简便方法：CrossOver for Mac

对于许多Mac用户来说&#xff0c;有时候他们可能需要使用一些只有在Windows上才能找到的应用程序。以前&#xff0c;解决这个问题的方法是通过安装Windows虚拟机或使用双系统来在Mac上运行Windows应用程序。但这些方法需要额外的硬件资源和时间来配置&#xff0c;并且可能会导致…
阅读更多...
MEME成风，为何比特币生态无法复刻以太坊生态的多样玩法？

MEME成风，为何比特币生态无法复刻以太坊生态的多样玩法？

铭文市场火了之后&#xff0c;很多人对 BTC L2 投入了过多的期许&#xff0c;认为 BTC 2 层会像以太坊 layer2 一样辉煌&#xff1f; 然而事实是&#xff0c;比特币生态的「成功」可能很长时间会停滞在「资产发行」叙事阶段&#xff0c;要复刻以太坊的生态多样玩法&#xff0c…
阅读更多...
栈和队列OJ题

栈和队列OJ题

有效的括号 OJ链接 思路 要注意进行顺序匹配的时候&#xff0c;要让右括号和栈顶元素匹配&#xff0c;匹配了一个以后就要让栈顶元素出栈&#xff01;&#xff01; 在顺序匹配时&#xff0c;要用 *s ] && top ! [ 像这样的不等号&#xff0c;而不能用&#xff0c;因为…
阅读更多...
12.4_黑马MybatisPlus笔记（下）

12.4_黑马MybatisPlus笔记（下）

目录 11 12 thinking&#xff1a;关于Mybatis Plus中BaseMapper和IService&#xff1f; 13 ​编辑 thinking&#xff1a;CollUtil.isNotEmpty? 14 thinking&#xff1a;Collection、Collections、Collector、Collectors&#xff1f; thinking&#xff1a;groupBy&#…
阅读更多...
前端打包环境配置步骤

前端打包环境配置步骤

获取node安装包并解压 获取node安装包 wget https://npmmirror.com/mirrors/node/v16.14.0/node-v16.14.0-linux-x64.tar.xz 解压 tar -xvf node-v16.14.0-linux-x64.tar.xz 创建软链接 sudo ln -s 此文件夹的绝对路径/bin/node /usr/local/bin/node&#xff0c;具体执行如下…
阅读更多...
彻底搞懂零拷贝技术( DMA、PageCache)

彻底搞懂零拷贝技术( DMA、PageCache)

DMA 直接内存访问&#xff08;Direct Memory Access&#xff09; 什么是DMA&#xff1f; 在进行数据传输的时候&#xff0c;数据搬运的工作全部交给 DMA 控制器&#xff0c;而 CPU 不再参与&#xff0c;可以去干别的事情。 传统I/O 在没有 DMA 技术前&#xff0c;全程数据…
阅读更多...
AIGC之Image2Video（一）| Animate Anyone：从静态图像生成动态视频，可将任意图像角色动画化

AIGC之Image2Video（一）| Animate Anyone：从静态图像生成动态视频，可将任意图像角色动画化

近日&#xff0c;阿里发布了Animate Anyone&#xff0c;只需一张人物照片&#xff0c;结合骨骼动画&#xff0c;就能生成人体动画视频。 项目地址&#xff1a;https://humanaigc.github.io/animate-anyone/ 论文地址&#xff1a;https://arxiv.org/pdf/2311.17117.pdf Github…
阅读更多...
YOLOv8 YoLov8l 模型输出及水果识别

YOLOv8 YoLov8l 模型输出及水果识别

&#x1f368; 本文为[&#x1f517;365天深度学习训练营学习记录博客 &#x1f366; 参考文章&#xff1a;365天深度学习训练营 &#x1f356; 原作者&#xff1a;[K同学啊 | 接辅导、项目定制] &#x1f680; 文章来源&#xff1a;[K同学的学习圈子](https://www.yuque.com/m…
阅读更多...
Android app性能优化指南

Android app性能优化指南

Android应用性能优化指南 提高应用程序的性能以实现更流畅的用户体验和更高的可见度。 性能在任何应用程序的成功中发挥着重要的作用。为用户提供流畅无缝的体验应该是开发人员的重点。 应用程序大小 在用户开始使用我们的应用程序之前&#xff0c;他们需要下载应用程序并将…
阅读更多...
TypeScript入门实战笔记 -- 开篇 为什么要选择 TypeScript ？

TypeScript入门实战笔记 -- 开篇 为什么要选择 TypeScript ？

typescript 在线编辑器http://typescript.p2hp.com/play?#code/JYOwLgpgTgZghgYwgAgJIFUDO1Uhge2QG8AoZc5YAEwC5kQBXAWwCNoBuMikOJiOzGCigA5pwrI4ANzhg4UAPwChozgF8SmmAxAIwwfCGRYcefAAoADlHyXMdDNii4CASmJdyCQ5nwAbCAA6P3wRKxs7ABpkAHJrW0wY1xINEhNnM3MiSlpkAEZonj46GIBrROQ1…
阅读更多...
C/C++之输入输出

C/C++之输入输出

文章目录 一.C语言的输入输出1.printfi. 输出整数ii. 浮点数iii.字符 & 字符串 2.scanfi.整数ii.浮点数iii. 字符 & 字符串 3.特殊用法i. * 的应用ii. %n 的应用iii. %[] 的应用 二.C中的输入输出1.couti. 缓冲区&#xff08;buffer&#xff09;ii. cout之格式化输出 2…
阅读更多...
区块链optimism主网节点搭建

区块链optimism主网节点搭建

文章目录 官方参考资料编译环境搭建编译Optimism Monorepo编译op-geth 执行下载数据快照生成op-geth和op-node通信密钥op-geth执行脚本 op-node执行脚本 启动日志op-gethop-node 本文是按照官方参考资料基于源码的方式成功搭建optimism主网节点。 官方参考资料 源码&#xff1…
阅读更多...
【设计模式-4.4】行为型——模板方法模式

【设计模式-4.4】行为型——模板方法模式

说明&#xff1a;本文介绍设计模式中行为型设计模式中的&#xff0c;模板方法模式&#xff1b; 生存 模版方法模式是行为型设计模式&#xff0c;关注于对象的行为。在《秒懂设计模式》&#xff08;刘韬 著&#xff09;中举了一个例子&#xff0c;例如哺乳动物的生存技能&…
阅读更多...
1688API接口系列，商品详情数据丨搜索商品列表丨商家订单类丨1688开放平台接口使用方案

1688API接口系列，商品详情数据丨搜索商品列表丨商家订单类丨1688开放平台接口使用方案

1688商品详情接口是指1688平台提供的API接口&#xff0c;用于获取商品详情信息。通过该接口&#xff0c;您可以获取到商品的详细信息&#xff0c;包括商品标题、价格、库存、描述、图片等。 要使用1688商品详情接口&#xff0c;您需要先申请1688的API权限&#xff0c;并获取ac…
阅读更多...
【开源】基于Vue+SpringBoot的河南软件客服系统

【开源】基于Vue+SpringBoot的河南软件客服系统

文末获取源码&#xff0c;项目编号&#xff1a; S 067 。 \color{red}{文末获取源码&#xff0c;项目编号&#xff1a;S067。} 文末获取源码&#xff0c;项目编号&#xff1a;S067。 目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 系统管理人员2.2 业务操作人员 三、…
阅读更多...
uniapp 云打包 生成安卓证书文件

uniapp 云打包 生成安卓证书文件

现在使用uniapp来开发小程序&#xff0c;H5&#xff0c;APP越来越多了&#xff0c;目前开发了一款APP&#xff0c;使用的也是uniapp。在此记录下用uniapp开发app云打包时约到的一些问题吧。 前因是我司安卓同学休产假&#xff0c;像云打包时需要的证书文件只能自己动手来搞。看…
阅读更多...
Avaya Aura Device Services 任意文件上传漏洞复现

Avaya Aura Device Services 任意文件上传漏洞复现

0x01 产品简介 Avaya Aura Device Services是美国Avaya公司的一个应用软件。提供一个管理 Avaya 端点功能。 0x02 漏洞概述 Avaya Aura Device Services 系统PhoneBackup接口处存在任意文件上传漏洞&#xff0c;攻击者可绕过验证上传任意文件获取服务器权限。 0x03 影响范围…
阅读更多...
使用Jmeter进行http接口测试

使用Jmeter进行http接口测试

前言&#xff1a; 本文主要针对http接口进行测试&#xff0c;使用Jmeter工具实现。 Jmter工具设计之初是用于做性能测试的&#xff0c;它在实现对各种接口的调用方面已经做的比较成熟&#xff0c;因此&#xff0c;本次直接使用Jmeter工具来完成对Http接口的测试。 一、开发接口…
阅读更多...
Mac电脑vm虚拟机 VMware Fusion Pro中文 for mac

Mac电脑vm虚拟机 VMware Fusion Pro中文 for mac

VMware Fusion Pro是一款功能强大的虚拟机软件&#xff0c;适用于需要在Mac电脑上运行其他操作系统的用户。它具有广泛的支持、快速稳定的特点以及多种高级功能&#xff0c;可以满足用户的各种需求和场景。 多操作系统支持&#xff1a;VMware Fusion Pro允许在Mac电脑上运行多…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023