多线程篇(锁相关类- StampedLock(改进的读写锁)(JDK8新增))(持续更新迭代)

news2024/11/15 15:47:59

目录

一、前言

二、StampedLock提供的三种读写模式的锁分别如下

写锁writeLock

悲观读锁 readLock

乐观读锁 tryOptimisticRead

三、StampedLock支持这三种锁在一定条件下进行相互转换

四、案例介绍

五、知识小结


一、前言

StampedLock 是并发包里面 JDK8 版本新增的一个锁,该锁提供了三种模式的读写控制,当调用获取锁的系列函

数时,会返回一个 long 型的变量,我们称之为戳记(stamp),这个戳记代表了锁的状态。其中 try 系列获取锁的

函数,当获取锁失败后会返回为 0 的 stamp 值。

当调用释放锁和转换锁的方法时需要传入获取锁时返回的 stamp 值。

二、StampedLock提供的三种读写模式的锁分别如下

写锁writeLock

写锁writeLock:是一个排它锁或者独占锁,某时只有一个线程可以获取该锁,当一个线程获取该锁后,其他请求

读锁和写锁的线程必须等待,这类似于ReentrantReadWriteLock的写锁(不同的是这里的写锁是不可重入锁);当

目前没有线程持有读锁或者写锁时才可以获取到该锁。请求该锁成功后会返回一个 stamp 变量用来表示该锁的版

本,当释放该锁时需要调用 unlockWrite 方法并传递获取锁时的 stamp 参数。并且它提供了非阻塞的

tryWriteLock 方法。

悲观读锁 readLock

悲观读锁readLock:是一个共享锁,在没有线程获取独占写锁的情况下,多个线程可以同时获取该锁。如果已经

有线程持有写锁,则其他线程请求获取该读锁会被阻塞,这类似于 ReentrantReadWriteLock 的读锁(不同的是这

里的读锁是不可重入锁)。这里说的悲观是指在具体操作数据前其会悲观地认为其他线程可能要对自己操作的数据

进行修改,所以需要先对数据加锁,这是在读少写多的情况下的一种考虑。请求该锁成功后会返回一个 stamp 变

量用来表示该锁的版本,当释放该锁时需要调用 unlockRead 方法并传递 stamp 参数。并且它提供了非阻塞的

tryReadLock 方法。

乐观读锁 tryOptimisticRead

乐观读锁tryOptimisticRead:它是相对于悲观锁来说的,在操作数据前并没有通过 CAS 设置锁的状态,仅仅通

过位运算测试。

如果当前没有线程持有写锁,则简单地返回一个非 0 的 stamp 版本信息。

获取该 stamp 后在具体操作数据前还需要调用 validate 方法验证该 stamp 是否已经不可用,也就是看当调用

tryOptimisticRead 返回 stamp 后到当前时间期间是否有其他线程持有了写锁,如果有,则 validate 会返回 0,

否则就可以使用该 stamp 版本的锁对数据进行操作。由于 tryOptimisticRead 并没有使用 CAS 设置锁状态,所

以不需要显式地释放该锁。

该锁的一个特点是适用于读多写少的场景,因为获取读锁只是使用位操作进行检验,不涉及CAS操作,所以效率会

高很多,但是同时由于没有使用真正的锁,在保证数据一致性上需要复制一份要操作的变量到方法栈,并且在操作

数据时可能其他写线程已经修改了数据,而我们操作的是方法栈里面的数据,也就是一个快照,所以最多返回的不

是最新的数据,但是一致性还是得到保障的。

三、StampedLock支持这三种锁在一定条件下进行相互转换

StampedLock还支持这三种锁在一定条件下相互转换。

例如long tryConvertToWriteLock(long stamp)期望把stamp标示的锁升级为写锁,这个函数会在下面几种情况

下返回一个有效的stamp(也就是晋升写锁成功):

  • 当前锁已经时写锁模式了
  • 当前锁处于读锁模式,并且没有其他线程是读锁模式
  • 当前处于乐观读模式,并且当前写锁可用

StampedLock的读写锁都是不可重入锁,所以在获取锁后释放锁前不应该在调用会获取锁的操作,以避免造成调

用线程被阻塞。

并且该锁不是直接实现Lock或ReadWriteLock接口,而是其在 内部自己维护了一个双向阻塞队列。

四、案例介绍

public class Point {
    // 成员变量
    private double x, y;
 
    // 锁实例
    private final StampedLock sl = new StampedLock();
    // 排它锁---写锁(writeLock)
    void move(double deltaX, double deltaY) {
        long stamp = sl.writeLock();
        try {
            x += deltaX;
            y += deltaY;
        }finally {
            sl.unlockWrite(stamp);
        }
    }
 
    // 乐观锁(tryOptimisticRead)
    double distanceFromOrigin() {
        // 尝试获取乐观读锁
        long stamp = sl.tryOptimisticRead();
        // 将全部方法复制到方法体栈内
        double currentX = x, currentY = y;
        // 检查读锁戳记,锁有没有被其他写线程排他性抢占
        if (!sl.validate(stamp)) {
            // 如果抢占则获取一个共享读锁
            stamp = sl.readLock();
            try {
                // 将全部变量复制到方法体栈内
                currentX = x;
                currentY = y;
            }finally {
                // 释放共享锁
                sl.unlockRead(stamp);
            }
        }
        // 返回计算结果
        return Math.sqrt(currentX * currentX + currentY * currentY);
    }
 
    // 使用悲观锁获取锁,并尝试转换为写锁
    void moveIfAtOrigin(double newX, double newY) {
        // 这里可以使用乐观读锁替换
        long stamp = sl.readLock();
 
        try {
            // 如果当前点在原点则移动
            while (x == 0.0 && y == 0.0) {
                // 尝试将获取的读锁升级为写锁
                long ws = sl.tryConvertToWriteLock(stamp);
                // 升级成功,则更新戳记,并设置坐标值,然后退出循环
                if (ws != 0L) {
                    stamp  = ws;
                    x = newX;
                    y = newY;
                    break;
                }else {
                    // 读锁升级写锁失败,释放读锁,显示获取独占写锁,然后循环重试
                    sl.unlockRead(stamp);
                    stamp = sl.writeLock();
                }
            }
        }finally {
            // 释放锁
            sl.unlock(stamp);
        }
    }
}

如上代码,Point类里面有两个成员变量(x,y)用来表示一个点的二维坐标,和三个操作坐标变量的方法。

另外实例化了一个StampedLock对象用来保证操作的原子性。

五、知识小结

StampedLock 提供的读写锁与 ReentrantReadWriteLock 类似,只是前者提供的是不可重入锁。

但是前者通过提供乐观读锁在多线程多读的情况下提供了更好的性能,这是因为获取乐观读锁时不需要进行 CAS

操作设置锁的状态,而只是简单地测试状态。

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

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

相关文章

线性代数 第二讲 矩阵_逆矩阵_伴随矩阵_分块矩阵_初等矩阵_矩阵的秩

矩阵 文章目录 矩阵1.矩阵的定义2.矩阵的运算法则3.特殊矩阵3.1 伴随矩阵3.2 可逆矩阵3.2.1 定义3.2.2 可逆矩阵的一些定理3.2.3 可逆矩阵公式与转置矩阵公式3.2.4 求逆矩阵 3.3 分块矩阵3.3.1 分块矩阵的运算3.3.2 分块矩阵的初等行变换(超纲内容但要了解&#xff…

YOLOv9输出模型每一层的耗时和GFLOPs

在做一些比较实验中,如何更精确的查看和对比我们的改进模块时候有效,是否有提升,特别是在模型轻量化时,这时候我们就可以打印改进模型每一层的耗时和GFLOPS来比较不同模块的占用量。在YOLOv9中,打印模型每一层的耗时和…

食堂线上预约点餐系统小程序的设计

管理员账户功能包括:系统首页,个人中心,学生管理,菜品分类管理,菜品管理,关于我们管理,意见反馈,系统管理 微信端账号功能包括:系统首页,菜品,购…

TPH-YOLOv5:基于Transformer预测头的改进YOLOv5,用于无人机捕获场景的目标检测

摘要 提出了TPH-YOLOv5。在YOLOv5的基础上,增加了一个预测头来检测不同尺度的目标。然后用Transformer Prediction Heads(TPH)代替原有的预测头,探索自注意机制的预测潜力。还集成了卷积块注意力模型(CBAM)…

2D 智慧水务厂:引领水资源数字化管理

图扑 2D 智慧水务厂通过数字监控和数据分析,实现高效水资源管理与优化,显著提升运营效率。

【开发心得】筑梦上海:项目风云录(2)

特别声明 这个长篇终于开了头,工作的节奏也不能耽搁,暂时也不知道何时才能收尾。人生漫漫,即使没有雷军们的成功,但是也有自己的一些小确幸。 特别声明一下,虽然这个长篇是基于真实经历,但其中有些内容纯…

Python优化算法22——自适应变异麻雀搜索优化算法(AMSSA)

科研里面优化算法都用的多,尤其是各种动物园里面的智能仿生优化算法,但是目前都是MATLAB的代码多,python几乎没有什么包,这次把优化算法系列的代码都从底层手写开始。 需要看以前的优化算法文章可以参考:Python优化算…

四、Selenium操作指南(一)

文章目录 一、基本用法(一)初始化浏览器对象(二)访问页面(三)设置浏览器大小(四)刷新页面(五)前进后退 二、获取页面基础属性三、定位页面元素(一…

30Kg载重1小时长续航油电混动无人机技术详解

关于30Kg载重、1小时长续航的油电混动无人机技术,我们可以从以下几个方面进行详细解析: 一、动力系统 1. 油电混合技术 油电混合优势:油电混合无人机结合了燃油发动机的高能量密度和电动机的稳定性和精确控制性,能够在长时间飞…

力扣452-用最少数量的箭引爆气球(Java详细题解)

题目链接:452. 用最少数量的箭引爆气球 - 力扣(LeetCode) 前情提要: 因为本人最近都来刷贪心类的题目所以该题就默认用贪心方法来做。 贪心方法:局部最优推出全局最优。 如果一个题你觉得可以用局部最优推出全局最…

PCL-直通滤波

本篇内容: 讲解直通滤波的作用通过pcl实现直通滤波 效果: 1 主要原理 点云数据通常包含x、y、z三个维度的数据,用户指定维度、范围后,直通滤波过滤或保留该范围内的所有点云 假设我指定维度’y’,范围(…

华为OD机试真题 - 字符串加解密(Java/Python/JS/C/C++ 2024 D卷 100分)

华为OD机试 2024E卷题库疯狂收录中,刷题点这里 专栏导读 本专栏收录于《华为OD机试真题(Java/Python/JS/C/C++)》。 刷的越多,抽中的概率越大,私信哪吒,备注华为OD,加入华为OD刷题交流群,每一题都有详细的答题思路、详细的代码注释、3个测试用例、为什么这道题采用XX…

如何让“相信相信的力量”帮你多赚100万

公门洞开纳百川 众心逐梦越千山 号召引领潜力绽 心觉潜意识无间 我们经常听到这句话:相信相信的力量 为什么要相信相信的力量 相信是什么意思 相信的力量又是什么意思 我估计99%的人不知道这句话的底层逻辑是什么 如果你悟透了,你的并且践行了&…

数据结构之稀疏数组

稀疏数组 特殊的数据结构,其特点是大部分元素为同一值。 适用场景 处理方式 以二维数组为例: ● 遍历原始二维数组,查询出不同的值 ● 稀疏数组列数固定为3 ● 第一行记录原始二维数组的行数、列数、不同值的个数 ● 第二行开始记录不同值的…

Python优化算法21——混沌反馈共享和群体协同效应的蝴蝶优化算法(CFSBOA)

科研里面优化算法都用的多,尤其是各种动物园里面的智能仿生优化算法,但是目前都是MATLAB的代码多,python几乎没有什么包,这次把优化算法系列的代码都从底层手写开始。 需要看以前的优化算法文章可以参考:Python优化算…

C++八股文之语言基础篇

🤖个人主页:晚风相伴-CSDN博客 思维导图链接:C语言基础 持续更新中…… 💖如果觉得内容对你有帮助的话,还请给博主一键三连(点赞💜、收藏🧡、关注💚)吧 &…

Java中post请求外部接口。其中有应对form-data参数方式处理

一、正常json参数的请求方式 代码片段如下: String result HttpUtil.post(URL_DEFAULT"d38e4357cb96dce5", JSONUtil.parseObj(Dict.create().set("fileName", cityTransitMapParams.getFileName()).set("appKey",cityTransitMapPa…

华为OD机试真题 - 荒岛求生 - 栈Stack(Java/Python/JS/C/C++ 2024 E卷 100分)

华为OD机试 2024E卷题库疯狂收录中,刷题点这里 专栏导读 本专栏收录于《华为OD机试真题(Java/Python/JS/C/C++)》。 刷的越多,抽中的概率越大,私信哪吒,备注华为OD,加入华为OD刷题交流群,每一题都有详细的答题思路、详细的代码注释、3个测试用例、为什么这道题采用XX…

使用JaCoCo 生成单测覆盖率报告

引入插件 <!-- surefire plugin with spock and junit --> <plugin><groupId>org.codehaus.gmavenplus</groupId><artifactId>gmavenplus-plugin</artifactId><version>1.9.0</version><executions><execution>&l…

使用ROCm和AMD GPU进行机器学习基准测试:复现我们的MLPerf推理提交

Benchmarking Machine Learning using ROCm and AMD GPUs: Reproducing Our MLPerf Inference Submission — ROCm Blogs 简介 衡量新技术的性能是自古以来的一种实验&#xff0c;常常引人入胜&#xff08;例如&#xff0c;我们仍然用马力来比较新电动汽车电机的性能&#xf…