JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

前两节你应该掌握了ReentrantLock加锁成功和加锁失败入队的核心逻辑,是如何通过AQS中的3个组件做到的。今天来我们看下:

ReentrantLock中,当线程释放锁时的逻辑

释放锁的过程及源码剖析

释放锁的过程及源码剖析

目前经过线程1、线程2使用ReentrantLock.lock()后的结果如下:

JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

线程2入队等待,线程1持有锁,state=1,owner是线程1,队列中元素是线程2,队列是由Node节点组成的双向链表,头结点为空,队列具体情况如下:

JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

此时假设线程1调用了unlock()方法,进行释放锁,会做哪些事情呢?

首先我们来看一下释放的代码:

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

非常简单,还是使用Sync组件(AQS)来释放锁。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;
}

核心分为了2步:

1) tryRelease方法,释放state和owner变量

2) unparkSuccessor方法,唤醒队列元素

分别来看一下,首先释放变量tryRelease方法:

 protected final boolean tryRelease(int releases) {
  int c = getState() - releases;
  if (Thread.currentThread() != getExclusiveOwnerThread())
    throw new IllegalMonitorStateException();
  boolean free = false;
  if (c == 0) {
    free = true;
    setExclusiveOwnerThread(null);
  }
  setState(c);
  return free;
}

这个方法逻辑很清晰,当前线程是线程1,state=1,入参releases是1,表示释放一次锁。很明显,state减1后变为0,会将owner也置为空,表示当前没有线程持有锁了,之后设置state为0结束。

整个过程如下图所示:

JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

修改了owner和state两个组件的值后,第二步就是唤醒队列等待的线程了。

public final boolean release(int arg) {
  if (tryRelease(arg)) {
    Node h = head;
    if (h != null && h.waitStatus != 0)
      unparkSuccessor(h);
    return true;
  }
  return false;
}

首先释放成功锁后,使用了h指针指向了当前队列的头部,判断一下队列中是否有等待的元素,注意对头元素waitStatus不能是0,如果是0,说明队列只有一个空节点,队列中没有等待元素。因为入队元素后会将头结点的waitStatus改成-1,SIGNAL。

接着进入了unpartSuccessor方法。从名字看就是恢复在h节点之后挂起的线程。(PS:JDK源码里面总会出现一些语义相近的词语,比如first-last,head-tail,successor- predecessor,prev-next,其实都是表示前后的意思,是等价的,这点大家要清楚。)

private void unparkSuccessor(Node node) {
  int ws = node.waitStatus;
  if (ws < 0)
    compareAndSetWaitStatus(node, ws, 0);

  Node s = node.next;
  if (s == null || s.waitStatus > 0) {
    s = null;
    for (Node t = tail; t != null && t != node; t = t.prev)
      if (t.waitStatus

node就是入参h,head节点,首先把head节点waitStatus从-1改为0。

接着s=node.next表示的就是线程2排队的Node,s不为空,执行了LockSupport.unpark(s.thread); 将线程2进行了唤醒。

最后整个方法返回,release返回true表示释放锁成功。如下图所示:

JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

此时之前被挂起的线程2,还记得吗?就是线程2曾经执行了LockSupport.park(t)的操作,线程被挂起,代码会hang在那一行等待。

private final boolean parkAndCheckInterrupt() {
  LockSupport.park(this);
  return Thread.interrupted();
}

线程2就会接着执行,只要线程2没被打断过,返回的肯定是false,以下的if条件不会成立。

 if (shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt())

接着回到for循环,重新进行tryAcquire操作,线程2再次尝试获取锁,此时假设没有别的线程过来加锁。线程2自然就会获取锁,设置state=1,owner=线程2了。

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 GC
        failed = false;
        return interrupted;
      }
      if (shouldParkAfterFailedAcquire(p, node) &&
        parkAndCheckInterrupt())
        interrupted = true;
    }
  } finally {
    if (failed)
      cancelAcquire(node);
  }
}

上面整个释放锁的过程可以总结如下图:

JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

思考&长图总结ReentrantLock

思考&长图总结ReentrantLock

我们分析ReentrantLock的加锁和释放锁,今天最后小结的一个思想其实就是:由脉络到细节,再从细节脉络。

另外 为了让大家更好的掌握ReentrantLock的AQS原理。这里给大家总结了一下。,

首先可以把原理用一句话简单的讲:假设有两个线程同时进行获取锁的操作,只能有一个获取成功,另一个会进入一个队列等待。底层是结合了state、owner,Node队列AQS的3个组件配合起来做到的。

ReentrantLock核心加锁和释放流程可以总结为如下一张长图:

JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

本文由博客群发一文多发等运营工具平台 OpenWrite 发布

Original: https://www.cnblogs.com/fanmao/p/15483546.html
Author: _繁茂
Title: JDK成长记20: ReenranctLock(3)释放锁的AQS底层原理

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/572592/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

  • 【Java并发编程】24、Synchronized实现原理解析

    我们知道在JDK1.5之前synchronized是一个重量级锁,相对于j.u.c.Lock,它会显得那么笨重,以至于我们认为它不是那么的高效而慢慢摒弃它。 1、底层原理 sync…

    Java 2023年5月29日
    0115
  • 【力扣】872. 叶子相似的树

    请考虑一棵二叉树上所有的叶子,这些叶子的值按从左到右的顺序排列形成一个 叶值序列 。 举个例子,如上图所示,给定一棵叶值序列为 (6, 7, 4, 9, 8) 的树。 如果有两棵二…

    Java 2023年6月8日
    095
  • Java 基础 (Java 反射机制)

    Reflection(反射)是被视为动态语言的关键,反射机制允许程序在执行期借助于Reflection API 取得任何类的内部信息,并能直接操作任意对象的内部属性及方法。 加载完…

    Java 2023年5月29日
    087
  • 05-LoadBalancer负载均衡

    目前主流的负载方案分为以下两种: 集中式负载均衡,在消费者和服务提供方中间使用独立的代理方式进行负载,有硬件的(比如 F5),也有软件的(比如 Nginx)。 客户端根据自己的请求…

    Java 2023年6月7日
    073
  • tomcat部署war包 首页面默认展示自己定义的页面

    将项目war包部署到tomcat的webapps后,http://localhost:8080 展示tomcat页面,http://localhost:8080/appName展示…

    Java 2023年6月9日
    074
  • ELK 架构之 Logstash 和 Filebeat 配置使用(采集过滤)

    相关文章: ELK 架构之 Elasticsearch 和 Kibana 安装配置 ELK 架构之 Logstash 和 Filebeat 安装配置 ELK 使用步骤:Spring…

    Java 2023年5月29日
    089
  • 深入理解this关键字

    404. 抱歉,您访问的资源不存在。 可能是网址有误,或者对应的内容被删除,或者处于私有状态。 代码改变世界,联系邮箱 contact@cnblogs.com 园子的商业化努力-困…

    Java 2023年6月7日
    074
  • SpringCloud里面切换数据源无效的问题

    问题描述: 调用链:controller1的接口A->service1的方法A->service2的方法B 方法A开启了事务,且指定了数据库A的数据源 方法B也开启了事…

    Java 2023年6月5日
    0109
  • Mybatis-plus动态排序${}防注入(驼峰转下划线)

    Mybatis-plus动态排序${}防注入(驼峰转下划线) public static void verifyAndSetColumn(BasePageQuery req, Cl…

    Java 2023年5月30日
    045
  • AC自动机:Tire树+KMP

    简介 AC自动机是一个多模式匹配算法,在模式匹配领域被广泛应用,举一个经典的例子,违禁词查找并替换为***。AC自动机其实是Trie树和KMP 算法的结合,首先将多模式串建立一个T…

    Java 2023年6月9日
    086
  • springboot读取resources下文件方式

    之前使用读取resources下的json文件,后来发现不通用,在这里做一些记录。 打成jar包之后,没有办法读取里面的路径。使用流的方式进行 一:实践 1.说明 使用了org.s…

    Java 2023年5月30日
    064
  • CORS与CSRF在Spring Security中的使用

    背景 在项目使用了Spring Security之后,很多接口无法访问了,从浏览器的网络调试窗看到的是CORS的报错和403的报错 分析 我们先来看一下CORS是什么,和它很相似的…

    Java 2023年6月5日
    089
  • vscode运行C/C++及基础设置(超简单详细)

    vscode运行C/C++及基础设置(超简单详细) 文章目录 vscode运行C/C++及基础设置(超简单详细) * 链接 – 教程链接 vscode下载官网 ming…

    Java 2023年6月5日
    0132
  • NFS介绍与搭建

    1.1 什么是NFS NFS 是Network File System的缩写,即网络文件系统。一种使用于分散式文件系统的协定,由Sun公司开发,于1984年向外公布。 NFS在文件…

    Java 2023年6月8日
    0115
  • 【原创】K8S环境下研发如何本地调试?kt-connect使用详解

    K8S环境下研发如何本地调试?kt-connect使用详解 背景 注:背景有点啰嗦,讲讲一路走来研发本地调试的变化,嫌烦的可以直接跳过,不影响阅读。 2019年 我在的公司当时是个…

    Java 2023年6月13日
    097
  • 【实战】利用多线程优化查询百万级数据

    前言 日常开发中,难免会遇到需要查询到数据库所有记录的业务场景,在索引完善的情况下,当数据量达到百万级别或者以上的时候,全表查询就需要耗费不少的时间,这时候我们可以从以下几个方向着…

    Java 2023年6月5日
    088
亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球