ReetrantLock源码剖析_03公平锁、非公平锁

news2024/10/3 4:29:38

一直努力就会有offer,一直努力就会有offer,一直努力就会有offer!

文章目录

    • ReetrantLock公平锁代码解析
    • ReetrantLock公平锁执行流程
    • ReetrantLock非公平锁代码解析
    • ReetrantLock非公平锁执行流程
    • 公平锁与非公平锁的比较

ReetrantLock公平锁代码解析

ReetrantLock的加锁是通过lock()方法实现的

public void lock() {
        sync.lock();
    }

ReetrantLock的构造器传入参数为true时,ReetrantLock就以公平锁的方式进行工作,因此当ReetrantLock以公平锁方式进行加锁时,调用的时FairSynclock()方法

final void lock() {
            acquire(1);
        }

FairSynclock()方法调用AQS acquire()方法实现对资源的加锁,参数1表示ReetrantLock加锁的重进入次数为1

ReetrantLock公平锁执行流程

在这里插入图片描述
释放锁:

 public void unlock() {
        sync.release(1);
    }
 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()方法由其子类实现(已经解读过)

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;
        }

ReetrantLock非公平锁代码解析

与公平锁不同的是,非公平锁的加锁是通过调用NonFairSynclock()方法来实现的

/**
         * Performs lock.  Try immediate barge, backing up to normal
         * acquire on failure.
         */
        final void lock() {
        //CAS操作
            if (compareAndSetState(0, 1))
            //把锁的持有者设置为当前线程
                setExclusiveOwnerThread(Thread.currentThread());
            else
                acquire(1);
        }

与公平锁FairSync中的lock方法不同的是,NonFairSynclock()方法会直接进行CAS操作,如果CAS成功,就直接将锁的持有者设置为当前线程,体现了非公平锁的非公平性。如果NonFairSynclock()方法执行CAS失败了,就说明,当前环境中有其他线程正在争夺锁,并且当前线程加锁失败。接下来,它会调用CAS中的acquire方法:

public final void acquire(int arg) {
        if (!tryAcquire(arg) &&
            acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
            selfInterrupt();
    }
protected final boolean tryAcquire(int acquires) {
            return nonfairTryAcquire(acquires);
        }
final boolean nonfairTryAcquire(int acquires) {
            final Thread current = Thread.currentThread();
            int c = getState();
            if (c == 0) {
            //没有调用hasQueuedPredecessors方法
                if (compareAndSetState(0, acquires)) {
                    setExclusiveOwnerThread(current);
                    return true;
                }
            }
            else if (current == getExclusiveOwnerThread()) {
                int nextc = c + acquires;
                if (nextc < 0) // overflow
                    throw new Error("Maximum lock count exceeded");
                setState(nextc);
                return true;
            }
            return false;
        }
protected final boolean tryAcquire(int acquires) {
            final Thread current = Thread.currentThread();
            int c = getState();
            if (c == 0) {
            //多调用了一个hasQueuedPredecessors方法
                if (!hasQueuedPredecessors() &&
                    compareAndSetState(0, acquires)) {
                    setExclusiveOwnerThread(current);
                    return true;
                }
            }
            else if (current == getExclusiveOwnerThread()) {
                int nextc = c + acquires;
                if (nextc < 0)
                    throw new Error("Maximum lock count exceeded");
                setState(nextc);
                return true;
            }
            return false;
        }

nonfairTryAcquiretryAcquire方法不同的是,tryAcquire方法多调用了一个hasQueuedPredecessors方法,这个方法就是用来判断同步队列中是否存在比当前线程先入队的线程,公平锁需要遵循一个先来后到,而非公平锁不会遵守秩序,直接加锁。如果非公平锁加锁失败,程序就和公平锁的执行顺序类似了。

ReetrantLock非公平锁执行流程

在这里插入图片描述

公平锁与非公平锁的比较

公平锁侧重的是公平性,非公平锁侧重的是并发性
非公平锁对锁的竞争是抢占式的,而且可以两次获取锁,这就提高了获取锁的可能性。好处有两点:

  • 线程不用加入同步队列就可以进行加锁操作,可以免去构造Node节点并加入阻塞队列的操作,还能减少线程阻塞与唤醒的开销。在高并发的情况下,如果线程持有锁的时间短于线程入队及阻塞的时间开销,那么这种抢占式的特性对并发性能的提升会更加明显。
  • 减少CAS竞争,如果必须要加入阻塞队列才能获取锁,那么入队时CAS竞争会很激烈,CAS操作失败虽然不会导致线程挂起,但是重试操作也会给CPU带来非常大的开销。

在这里插入图片描述
参考书籍:Java面试一站到底

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

前端部署发布项目后,如何通知用户刷新页面、清除缓存

以下只是一些思路&#xff0c;有更好的实现方式可以留言一起交流学习 方式一&#xff1a;纯前端 在每次发布前端时&#xff0c;使用webpack构建命令生成一个json文件&#xff0c;json中写个随机生成的一个字符串&#xff08;比如时间戳&#xff09;&#xff0c;每次打包程序都…

【Python入门第五十天】Python丨NumPy 数组搜索

搜索数组 可以在数组中搜索&#xff08;检索&#xff09;某个值&#xff0c;然后返回获得匹配的索引。 要搜索数组&#xff0c;请使用 where() 方法。 实例 查找值为 4 的索引&#xff1a; import numpy as nparr np.array([1, 2, 3, 4, 5, 4, 4])x np.where(arr 4)pri…

node可以用nvm快速切换版本,golang如何快速切换版本?用gvm就行。

使用 gvm 可以带来以下好处&#xff1a; 快速切换 Golang 版本&#xff0c;方便进行版本测试和开发&#xff1b;可以在多个项目中同时使用不同版本的 Golang 包和工具&#xff0c;避免冲突&#xff1b;可以通过 gvm 管理不同版本的 Golang&#xff0c;方便安装、卸载和更新&am…

STL--vector

一、vector介绍 vector是表示大小可以更改的数组的序列容器 就像数组一样&#xff0c;vector也采用的连续存储空间来存储元素。也就是意味着可以采用下标对vector的元素进行访问&#xff0c;和数组一样高效。但是又不像数组&#xff0c;它的大小是可以动态改变的&#xff0c;而…

移动端屏幕适配

文章目录 移动端屏幕适配移动端屏幕适配和响应式布局区别基本知识简单屏幕适配 移动端屏幕适配 移动端屏幕适配和响应式布局区别 移动端适配响应式布局终端移动端PC端和移动端常用单位宽高&#xff1a;rem 或 %字体&#xff1a;px宽&#xff1a;%高、字体&#xff1a;px宽高宽…

Docker网络模式与cgroups资源控制

目录 1.docker网络模式原理 2.端口映射 3.Docker网络模式&#xff08;41种&#xff09; 1.查看docker网络列表 2.网络模式详解 4.Docker cgroups资源控制 1.CPU资源控制 2.对内存使用的限制 3.对磁盘IO的配置控制&#xff08;blkio&#xff09;的限制 4.清除docker占用…

Vue3教程

文章目录 参考资料1 setup语法糖1.1 vue2中的写法1.2 setup语法糖在vue3中使用 2 ref reactive 事件2.1 ref2.2 reactive2.3 事件&#xff1a;在setup script中&#xff0c;直接定义事件&#xff0c;不需要像vue2那样在method中定义 3 computed & watch & watchEffect3…

详解DHCP和DNS实验汇总

文章目录 1.实验说明2.实验步骤2.1&#xff08;linux的CentOS 7-2&#xff09;命令配置2.2 &#xff08;linux的CentOS 7-3&#xff09;命令配置2.3 客户端(WIN10)命令配置2.4 客户端(CentOS 7-1)命令配置 1.实验说明 实验要求&#xff1a;要求在一台主机中同时配置DNS服务器和…

【SpringCloud】1、Nacos注册中心、配置中心搭建

1、Nacos 简介 Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service的首字母简称&#xff0c;一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。 Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集&#xff0c;帮助…

PartiQL 对 SQL 的扩展,可以查询非结构化的数据

目录 开始 先决条件 下载 PartiQL CLI 运行 PartiQL CLI 窗户 macOS &#xff08;Mac&#xff09; 和 Unix 命令行教程 介绍 PartiQL 查询与 SQL 兼容 PartiQL 数据模型&#xff1a;许多底层数据存储格式的抽象 了解更多信息 查询嵌套数据 嵌套集合 取消嵌套嵌套…

Hbase数据库完全分布式搭建以及java中操作Hbase

文章目录 1.基础的环境准备2.完全分布式 Fully-distributed2.1 配置文件hase-env.sh2.2 hbase-site.xml2.3 配置regionservers2.4 配置备用的master2.5 HDFS客户端配置2.6 启动2.7 通过页面查看节点信息 3. java中客户端操作Hbase3.1 引入依赖3.2 初始化创建连接3.3 操作Hbase数…

Qt/QML编程学习之心得:D-BUS进程间通信(四)

Qt/QML应用编程最适合于一些触摸的嵌入式界面设计&#xff0c;那么GUI界面怎么与底层的设备通信&#xff0c;怎么与一个系统内其他模块通信的呢&#xff1f;这就不得不说一个很重要的设计模式&#xff1a;d-bus。 D-BUS是一个系统中消息总线&#xff0c;用于IPC/RPC。消息系统…

vi编辑器的使用介绍

vi编辑器的使用 vi的特点与运用场景vi的使用简易执行一个案例按键说明第一部分&#xff1a;命令模式的按键说明(光标移动、复制粘贴、查找替换)移动光标的方法查找与替换删除、复制与粘贴 第二部分&#xff1a;命令模式切换到输入模式的可以按键进入插入或替换的编辑模式 第三部…

A100 Jeston TX1/TX2使用教程-介绍

大家好&#xff0c;我是虎哥&#xff0c;经过一段时间的整理&#xff0c;终于完成了我自己算力盒子&#xff0c;A100系统的设计和研发&#xff0c;今天就来和大家聊聊这款针对TX1和TX2的入门级计算盒子的一些特性和功能。 一、EdgeBox_Umate_A100 算力盒子 A100 算力盒子是“玩…

系统集成项目管理工程师 笔记(第五章:项目立项管理)

文章目录 5.1 项目建议 2225.2 项目可行性分析 224项目可行性研究内容&#xff1a;5.2.2 项目可行性研究阶段 227 5.4 项目招投标 229《中华人民共和国招标投标法实施条例》5.4.1 项目招标 2295.4.2 项目投标 2305.4.3 开标与评标 2345.4.4 选定项目承建方 235 5.5 项目合同谈判…

实模式下内存访问

虽然有了寄存器&#xff0c;但是数据和指令还是需要存储到内存中。通常情况下需要把数据从内存中放到寄存器中才能使用&#xff0c;同样的指令需要放到寄存器中才能被CPU执行。 所有的内存访问都需要段寄存器左移四位加上其他寄存器的值才能得到真正地址值。这是由于以前运行实…

Unity使用ShaderGragh制作透明指针

Unity使用ShaderGragh制作透明指针 1 概述2 使用环境3 制作流程3.1 创建一个ShaderGragh3.2 打开ShaderGraph编辑器3.3 编辑器界面介绍3.4 Shader节点和部分信息如下3.5 常用节点介绍3.6 使用Shader3.7 贴图规范 4 控制Shader旋转4.1 API介绍4.2 示例代码&#xff1a;3.9 Shade…

Redis 6.0+ 的 ACL 机制

目录 前言一、安装 Redis 服务二、创建 ACL 用户三、用户密码管理3.1 删除密码3.2 重置用户和密码 四、权限管理4.1 key 管理4.2 权限管理 五、ACL 用户存储5.1 配置文件实现5.2 外部 ACL 文件实现 前言 Redis 6.0 引入了 ACL 机制&#xff0c;类似 MySQL 一样全部权限管理&am…

表单验证:自定义校验规则

Element UI 为我们提供了表单校验规则&#xff0c;但业务需要&#xff0c;我们常常要自定义校验规则 需求 实现表单中一个输入框&#xff0c;不能输入大于30的数字 思路 hrml&#xff1a; 自定义校验规则&#xff1a; 约定的校验规则&#xff1a; 代码 <template&g…

集群聊天服务器项目(一)——模块分层设计

本项目对程序不同功能进行分层设计&#xff0c;分为网络层、业务层、和数据层。 C面向接口编程也就是面向抽象类&#xff0c;网络模块和业务模块尽量解耦。 网络层 网络层主要封装的是网络连接方面的一些功能&#xff0c;即socket相关操作,这里该项目采用的是muduo网络库作为…