图解ReentrantLock底层公平锁和非公平锁实现原理

article/2025/9/27 6:29:05

💻在面试或者日常开发当中,经常会遇到公平锁和非公平锁的概念。

两者最大的区别如下👇

1️⃣ 公平锁:N个线程去申请锁时,会按照先后顺序进入一个队列当中去排队,依次按照先后顺序获取锁。就像下图描述的上厕所的场景一样,先来的先占用厕所,后来的只能老老实实排队。

2️⃣ 非公平锁:N个线程去申请锁,会直接去竞争锁,若能获取锁就直接占有,获取不到锁,再进入队列排队顺序等待获取锁。同样以排队上厕所打比分,这时候,后来的线程会先尝试插队看看能否抢占到厕所,若能插队抢占成功,就能使用厕所,若失败就得老老实实去队伍后面排队。

针对这两个概念,我们通过ReentrantLock底层源码来分析下💁 :公平锁和非公平锁在ReentrantLock类当中锁怎样实现的。

🌈ReentrantLock内部实现的公平锁类是FairSync,非公平锁类是NonfairSync。

当ReentrantLock以无参构造器创建对象时,默认生成的是非公平锁对象NonfairSync,只有带参且参数为true的情况下FairSync,才会生成公平锁,若传参为false时,生成的依然是非公平锁,两者构造器源码结果如下👇

​ 图1

在实际开发当中,关于ReentrantLock的使用案例,一般是这个格式👇

 class X {    private final ReentrantLock lock = new ReentrantLock();    // ...      public void m() {      lock.lock();  // block until condition holds      try {        // ... method body      } finally {        lock.unlock()      }    }  }
复制代码

这时的lock指向的其实是NonfairSync对象,即非公平锁。

当使用lock.lock()对临界区进行占锁操作时,最终会调用到NonfairSync对象的lock()方法。根据图1可知,NonfairSync和FairSync两者的lock方法实现逻辑是不一样的,而体现其锁是否符合公平与否的地方,就是在两者的lock方法里。

可以看到,在非公平锁NonfairSync的上锁lock方法当中,若if(compareAndSetState(0,1))判断不满足,就会执行acquire(1)方法,该方法跟公平锁FairSync的lock方法里调用的acquire(1)其实是同一个,但方法里的tryAcquire具体实现又存在略微不同,这里后面会讨论。

这里就呼应前文提到的非公平锁的概念——当N个线程去申请非公平锁,它们会直接去竞争锁,若能获取锁就直接占有,获取不到锁,再进入队列排队顺序等待获取锁。这里的“获取不到锁,再进入队列排队顺序等待获取锁”可以理解成⏩——当线程过来直接竞争锁失败后,就会变成公平锁的形式,进入到一个队列当中,按照先后顺序排队去获取锁。

而if(compareAndSetState(0,1))语句块的逻辑,恰好就体现了“当N个线程去申请非公平锁,它们会直接去竞争锁,若能获取锁就直接占有”这句话的意思。

🌈首先,先来分析NonfairSync的lock()方法原理,源码如下👇

final void lock() {//先竞争锁,若能竞争成功,则占有锁资源if (compareAndSetState(0, 1))//将独占线程成员变量设置为当前线程,表示占有锁资源的线程setExclusiveOwnerThread(Thread.currentThread());elseacquire(1);
}
复制代码

compareAndSetState(0, 1)就是一个当前线程与其他线程抢占锁的过程,这里面涉及到AQS的知识点,因此,阅读本文时,需具备一定的AQS基础。

JUC的锁实现是基于AQS实现的,可以简单理解成,AQS里定义了一个private volatile int state变量,若state值为0,说明无线程占有,其他线程可以进行抢占锁资源;若state值为1,说明已有线程占有锁资源,其他线程需要等待该占有锁的线程释放锁资源后,方能进行抢占锁的动作。

线程在抢占锁时,是通过CAS对state变量进行置换操作的,期望值expect是0,更新值update为1,若期望值expect能与内存地址里的state值一致,就可以通过原子操作将内存地址里state值置换成更新值update,返回true,反之,就置换失败返回false。

protected final boolean compareAndSetState(int expect, int update) {// See below for intrinsics setup to support thisreturn unsafe.compareAndSwapInt(this, stateOffset, expect, update);
}
复制代码

可见,这里的if (compareAndSetState(0, 1))就体现了非公平锁的机制,当前线程会先去竞争锁,若能竞争成功,就占有锁资源。

若竞争锁失败话,就会执行acquire(1)方法,其原理就相当走跟公平锁类似的逻辑。

acquire(1);
复制代码

进入acquire方法,该方法是位于AbstractQueuedSynchronizer里,就是前文提到的AQS,即抽象同步队列器,它相当提供一套用户态层面的锁框架,基于它可以实现用户态层面的锁机制。

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

注意一点,NonfairSync和FairSync调用的acquire(int arg)方法中的tryAcquire方法,其实现是不同的。NonfairSync调用的acquire方法,其底层tryAcquire调用的是NonfairSync重写的tryAcquire方法;FairSync调用的acquire方法,其底层tryAcquire调用的是FairSync重写的tryAcquire方法。

NonfairSync类的acquire方法的流程图如下👇

先分析非公平锁的!tryAcquire(arg)底层源码实现,该方法的整体逻辑是,通过getState()获取state状态值,判断是否已为0。若state等于0了,说明此时锁资源处于无锁状态,那么,当前线程就可以直接再执行一遍CAS原子抢锁操作,若CAS成功,说明已成功抢占锁。若state不为0,再判断当前线程是否与占有资源的锁为同一个线程,若同一个线程,那么就进行重入锁操作,即ReentrantLock支持同一个线程对资源的重复加锁,每次加锁,就对state值加1,解锁时,就对state解锁,直至减到0最后释放锁。

🌈最后,若在该方法里,通过CAS抢占锁成功或者重入锁成功,那么就会返回true,若失败,就会返回false。

final boolean nonfairTryAcquire(int acquires) {//获取当前线程引用final Thread current = Thread.currentThread();//获取AQS的state状态值int c = getState();//若state等于0了,说明锁处于无被占用状态,可被当前线程抢占if (c == 0) {//再次尝试通过CAS抢锁if (compareAndSetState(0, acquires)) {//将独占线程成员变量设置为当前线程,表示占有锁资源的线程setExclusiveOwnerThread(current);return true;}}//判断当前线程是否与占有锁资源的线程为同一个线程else if (current == getExclusiveOwnerThread()) {//每次重入锁,state就会加1  int nextc = c + acquires;if (nextc < 0) // overflowthrow new Error("Maximum lock count exceeded");setState(nextc);return true;}return false;
}
复制代码

在 if (!tryAcquire(arg) && acquireQueued(addWaiter(Node.EXCLUSIVE), arg))代码当中,根据 &&短路机制,若!tryAcquire(arg)为false,就不会再执行后面代码。反之,若!tryAcquire(arg)为true,说明抢占锁失败了或者不属于重入锁,那么就会继续后续acquireQueued(addWaiter(Node.EXCLUSIVE), arg))代码的执行。acquireQueued里面的逻辑,就可以理解成“获取不到锁,再进入队列排队顺序等待获取锁”。这块内容涉及比较复杂的双向链表逻辑,我后面会另外写一篇文章深入分析,本文主要是讲解公平锁和非公平锁的区别科普。

FairSync公平锁lock方法里acquire(1)的逻辑与非公平锁NonfairSync的acquire(1)很类似,其底层实现同样是这样👇

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

我们来看下FairSync类里重实现的tryAcquire与NonfairSync最终执行的tryAcquire区别👇

可以看到,公平锁FairSync的tryAcquire方法比NonfairSync的nonfairTryAcquire方法多了一行!hasQueuedPredecessors()代码。

在FairSync公平锁里,若hasQueuedPredecessors()返回false,那么!hasQueuedPredecessors()就会为true,在执行以下判断时,就会通过compareAndSetState(0, acquires)即CAS原子抢占锁。

if (!hasQueuedPredecessors() &&compareAndSetState(0, acquires)) {setExclusiveOwnerThread(current);return true;
}
复制代码

那么,什么情况下,hasQueuedPredecessors() 能得到false值呢?

public final boolean hasQueuedPredecessors() {// The correctness of this depends on head being initialized// before tail and on head.next being accurate if the current// thread is first in queue.Node t = tail; // Read fields in reverse initialization orderNode h = head;Node s;return h != t &&((s = h.next) == null || s.thread != Thread.currentThread());
}
复制代码

❗存在两种情况:

1️⃣ 第一种情况,h != t为false,说明head和tail节点都为null或者h和t都指向一个假节点head,这两种情况都说明了,此时的同步队列还没有初始化,简单点理解,就是在当前线程之前,还没有出现线程去抢占锁,因此,此时,锁是空闲的, 同时当前线程算上最早到来的线程之一(高并发场景下同一时刻可能存在N个线程同时到来),就可以通过CAS竞争锁。

2️⃣ 第二种情况,h != t为true但(s = h.next) == null || s.thread != Thread.currentThread()为false,当头节点head和尾节点都不为空且指向不是同一节点,就说明同步队列已经初始化,此时至少存在两个以上节点,那么head.next节点必定不为空,即(s = h.next) == null会为false,若s.thread != Thread.currentThread()为false,说明假节点head的next节点刚好与当前线程为同一节点,也就意味着,当前线程排在队列最前面,排在前面的可以在锁空闲时获取锁资源,就可以执行compareAndSetState(0, acquires)去抢占锁资源。

若同步队列已经初始化,且当前线程又不是在假节点head的next节点,就只能老老实实去后面排队等待获取锁了。


http://chatgpt.dhexx.cn/article/au9lkuoK.shtml

相关文章

ReentrantLock之公平锁和非公平锁详解

ReentrantLock是一个互斥锁&#xff0c;它具有synchronized相同的能力&#xff1b;但相比之下&#xff0c;ReentrantLock扩展性更强&#xff0c;比如实现了公平锁。 下面详细拆解下ReentrantLock的公平锁和非公平锁的实现。 JDK版本&#xff1a;1.8.0_40 公平锁 先看Reentr…

ReentrantLock中公平锁和非公平锁的区别

目录 背景知识 ReentrantLock的组成 概述 公平锁示意图 非公平锁示意图 源码解读 非公平锁 公平锁 代码对比 问题 知识扩展 tryLock方法 参考资料 背景知识 ReentrantLock的组成 首先看下ReentrantLock的组成结构。 公平锁和非公平锁主要是通过内部类FairSync和…

公平锁和非公平锁

Reentrant Re entrant&#xff0c;Re是重复、又、再的意思&#xff0c;entrant是enter的名词或者形容词形式&#xff0c;翻译为进入者或者可进入的&#xff0c;所以Reentrant翻译为可重复进入的、可再次进入的&#xff0c;因此ReentrantLock翻译为重入锁或者再入锁。 公平锁…

阿里面试官:说一下公平锁和非公平锁的区别?

点赞再看&#xff0c;养成习惯&#xff0c;微信搜索【三太子敖丙】关注这个互联网苟且偷生的工具人。 本文 GitHub https://github.com/JavaFamily 已收录&#xff0c;有一线大厂面试完整考点、资料以及我的系列文章。 前言 上次我们提到了乐观锁和悲观锁&#xff0c;那我们知道…

Ubuntu 手动安装 JDK8

文章目录 1. 下载2. 解压安装3. 配置环境变量 1. 下载 先去官网下载合适的版本&#xff0c;官网&#xff1a;https://www.oracle.com/java/technologies/downloads/archive/ 通过下载页面获取到下载链接后&#xff0c;可以直接在Ubuntu上使用wget下载&#xff0c;也可以先下载…

centos8安装jdk教程

文章目录 一、安装二、配置环境变量三.验证 一、安装 1、查看JDK软件包列表 yum search java | grep -i --color jdk2、选择版本安装 yum install -y java-1.8.0-openjdk java-1.8.0-openjdk-devel或者如下命令安装jdk8所有文件 yum install -y java-1.8.0-openjdk*二、配置…

Java - JDK8安装及配置环境变量教程

Java - JDK8安装及配置环境变量教程 一、安装JDK教程 甲骨文官网下载JDK版本&#xff1a;windows64下载地址 下载完成后开始安装JDK&#xff1a;双击打开 点击下一步&#xff1a; 若不需要自定义路径&#xff0c;则安装到默认路径即可&#xff08;安装的路径需记住&#xff0…

JDK8安装和环境配置

JDK8的安装和环境配置 一、JDK8下载二、安装三、环境配置 一、JDK8下载 官网下载&#xff1a; https://www.oracle.com/java/technologies/downloads/#java8-windows 二、安装 打开安装&#xff0c;一直下一步即可&#xff0c;可以在安装过程中更改安装地址&#xff0c;我放…

Java JDK 8的安装与配置

文章目录 前言1. 安装JDK 8Step1&#xff1a;选择JDK的版本Step2&#xff1a;选择系统平台Step3&#xff1a;下载安装包Step4&#xff1a;开始安装 2. 配置JDK 8Step1&#xff1a;配置“环境变量path” 前言 本教程是在Windows 64位平台上安装JDK 8版本。 1. 安装JDK 8 官网…

JDK8安装与环境配置

前言&#xff1a;在网上看了下JDK的安装与环境配置&#xff0c;发现很多视频以及博客的讲的都很复杂&#xff0c;对初学者很不友好。很多小白看到这些配置步骤都一脸懵&#xff0c;即使一步一步看着操作还是配置失败。这主要是因为很多博主配置了不需要的配置环境&#xff0c;让…

Linux安装JDK8详细图文教程

第一步、获取JDK文件 JDK下载包&#xff1a;直接进入 如果跳转登录页面&#xff0c;注册一个账号登录即可 登录过后文件就下载完成 第二步、上传JDK到服务器 1、创建JDK目录 mkdir -p /developer/env/jdk进入目录 cd /developer/env/jdk2、安装lrzsz&#xff08;用于远程传…

JDK8安装教程(Windows、Ubuntu)

文章目录 下载JDK8在Windows上安装设置环境变量 在Ubuntu上安装 下载JDK8 Linux版&#xff0c;CSDN下载地址 推荐官网下载&#xff08;需要注册&#xff09;&#xff0c;能下到Windows和Ubuntu的最新版 在Windows上安装 双击打开下载好的安装包&#xff0c;点击下一步 点击左…

linux系统安装jdk8详细教程

文章目录 前言一、下载jdk8的安装包二、压缩包上传解压1.将下载好的压缩包使用ftp工具上传到服务器2.将压缩包解压到指定目录 三、配置jdk的环境变量四、测试是否安装成功 前言 虚拟机版本&#xff1a;centos7 jdk版本&#xff1a;1.8 一、下载jdk8的安装包 方法1&#xff1a…

jdk8安装教程及环境变量配置

目录 一、JDK下载 二、安装JDK 三、环境变量配置 四、测试环境变量 一、JDK下载 1、JDK下载地址&#xff1a;Java Downloads | Oraclehttps://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html 2、选这个位置 3、向下滑动鼠标&#xff0c…

WIN10javaJDK8安装教程

一、下载jdk8文件 下载地址: http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html 下载步骤&#xff1a; 1、进入网站后往下拉&#xff0c;找到下载界面&#xff0c;选择自己合适的下载。 二、安装 双击运行刚下载好的exe文件…

JDK8安装教程-极其详细

下载安装JDK 前往oracle官网下载JDK 链接&#xff1a;https://www.oracle.com/java/technologies/downloads/#java8-windows下载完成后 打开下载的程序进行安装JDK 这里可以选择你要存放的位置 选择jre安装的路径 继续下一步&#xff0c;等待安装完成 配置环境变量 此电脑…

jdk8安装教程及环境变量部署

一、jdk下载 下载方式&#xff1a; 官网下载 地址&#xff1a;Java Downloads | Oracle网盘下载&#xff1a;链接&#xff1a;https://pan.baidu.com/s/1jjcOsdyaLfAy2N5zp64sew 提取码&#xff1a;tzsj 官网下载&#xff1a; 这是最新版本的可以根据自己的需要选择 选择W…

win10系统安装jdk8全过程

一 下载安装文件 jdk的安装与配置是Java学习的第一步&#xff0c;下面记录一下具体过程。首先根据自己系统下载对应版本。下载地址http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html 二 安装 双击exe文件&#xff0c;按照默认设置一步一步…

JDK8下载安装及配置环境教程,一看就会

目录 一.下载安装包 二.安装步骤 三.配置环境 一.下载安装包 百度网盘链接:百度网盘 请输入提取码 提取码:QI20 也可以选择自己到ORACLE官网下载:www.oracle.com. 1.点击链接进入官网 可以看到上方有个"Products"&#xff0c;点击它 2.然后可以看到下滑的菜单…

JDK8详细图文安装教程

1、双击软件 2、点击下一步 3、选择jdk的安装目录 4、安装jre环境&#xff0c;选择jre安装目录 5、配置环境变量&#xff1a;选中计算机→右键→属性→高级系统设置→高级→环境变量 6、系统变量→新建JAVA_HOME变量 7、系统变量→寻找Path变量→编辑 8、新增jdk、jre的bin位置…