Java内置锁:深度解析StampedLock并发类

Java内置锁:深度解析StampedLock并发类 - 程序员古德

内容摘要

StampedLock类是一种高性能的读写锁,它通过引入乐观读和写锁的优化机制,提高了多线程环境下的并发性能,他支持三种访问模式:悲观读、写和乐观读,可以根据不同的业务场景选择适合的锁策略,相比传统的读写锁,StampedLock能够更好地利用多核处理器的优势,减少线程间的竞争和阻塞,从而提升系统的吞吐量和响应速度。

官方文档地址:https://docx.iamqiang.com/jdk11/api/java.base/java/util/concurrent/locks/StampedLock.html

Java内置锁:深度解析StampedLock并发类

使用场景

Java内置锁:深度解析StampedLock并发类 - 程序员古德

StampedLock是一个优化的读写锁,它在多核处理器上提供了比ReentrantReadWriteLock更高的性能,与传统的读写锁不同,StampedLock支持三种访问模式:读、写和乐观读,并且这三种模式都可以相互转换。

假设有一个在线书店系统,其中一个关键功能是书籍的库存更新,每当用户购买书籍时,系统需要从库存中减去相应的数量,同时,为了提供良好的用户体验,系统还需要实时显示每本书的当前库存量,以供其他用户参考。在这个场景中,库存更新操作(写操作)和库存查询操作(读操作)是频繁发生的,而且,多个用户可能同时查询同一本书的库存,但同一时间只有一个用户能够更新库存。

可以使用StampedLock解决这个问题,如下操作:

  1. 写操作(库存更新):当一个用户下单购买书籍时,系统会获取一个写锁,确保在更新库存的过程中,其他用户不能同时进行读或写操作,这就像是在书店里,当售货员正在为一位顾客取书并更新库存时,其他顾客需要稍等片刻,直到售货员完成操作。
  2. 读操作(库存查询):多个用户可以同时查询同一本书的库存,而不会相互干扰,这时,系统会为每个查询请求获取一个读锁,这就像是在书店里,多位顾客可以同时查看书架上的书籍,了解库存情况。
  3. 乐观读:StampedLock还提供了一种乐观读的模式,它允许在不阻塞其他写操作的情况下进行读操作,如果读操作期间发生了写操作,乐观读可以通过检查一个“戳记”(stamp)来发现数据的不一致性,并重新执行读操作,这就像是一位顾客在查看库存时,突然意识到售货员正在为另一位顾客取书并更新库存,这时他可以稍等片刻,然后再次查看最新的库存信息。

代码案例

Java内置锁:深度解析StampedLock并发类 - 程序员古德

StampedLock 类中的 asReadLock() 方法用于获取一个 Lock 视图,该视图具有与 StampedLock 的读锁相同的锁定含义,可以使用返回的 Lock 对象进行读锁定,就像使用 ReentrantReadWriteLock 的读锁一样,但是,通常建议使用 StampedLock 的其他方法来获取读锁,因为它们可以提供更精细的控制和更高的性能。

下面是一个简单的例子,演示了使用 StampedLock 类的基本使用方法,这个例子创建了一个简单的计数器类,该类使用 StampedLock 来同步对内部计数器的访问,如下代码:

import java.util.concurrent.locks.Lock;  
import java.util.concurrent.locks.StampedLock;  /*** @创建人 程序员古德 <br>* @创建时间 2024/1/18 12:00 <br>* @修改人 暂无 <br>* @修改时间 暂无 <br>* @版本历史 暂无 <br>*/public class Counter {  private int count;  private final StampedLock stampedLock = new StampedLock();  // 使用 StampedLock 的 asReadLock() 方法获取读锁  public void readCountWithLock() {  Lock readLock = stampedLock.asReadLock();  readLock.lock(); // 获取读锁  try {  System.out.println("Current count: " + count);  } finally {  readLock.unlock(); // 释放读锁  }  }  // 使用 StampedLock 的普通读方法  public int readCountWithStamp() {  long stamp = stampedLock.tryOptimisticRead(); // 尝试乐观读  int currentCount = count;  // 检查乐观读后数据是否被修改  if (!stampedLock.validate(stamp)) {  // 如果数据被修改,获取读锁重新读取  stamp = stampedLock.readLock();  try {  currentCount = count;  } finally {  stampedLock.unlockRead(stamp);  }  }  return currentCount;  }  // 增加计数器的值  public void incrementCount() {  long stamp = stampedLock.writeLock(); // 获取写锁  try {  count++;  } finally {  stampedLock.unlockWrite(stamp); // 释放写锁  }  }  public static void main(String[] args) throws InterruptedException {  Counter counter = new Counter();  // 启动一个线程来增加计数器的值  Thread incrementThread = new Thread(() -> {  for (int i = 0; i < 5; i++) {  counter.incrementCount();  try {  Thread.sleep(100); // 休眠以模拟工作负载  } catch (InterruptedException e) {  e.printStackTrace();  }  }  });  // 启动一个线程来读取计数器的值(使用 Lock)  Thread readThreadWithLock = new Thread(() -> {  for (int i = 0; i < 5; i++) {  counter.readCountWithLock();  try {  Thread.sleep(100); // 休眠以模拟工作负载  } catch (InterruptedException e) {  e.printStackTrace();  }  }  });  // 启动一个线程来读取计数器的值(使用 stamp)  Thread readThreadWithStamp = new Thread(() -> {  for (int i = 0; i < 5; i++) {  System.out.println("Current count (stamp): " + counter.readCountWithStamp());  try {  Thread.sleep(100); // 休眠以模拟工作负载  } catch (InterruptedException e) {  e.printStackTrace();  }  }  });  // 启动所有线程  incrementThread.start();  readThreadWithLock.start();  readThreadWithStamp.start();  // 等待所有线程完成  incrementThread.join();  readThreadWithLock.join();  readThreadWithStamp.join();  }  
}

在上面代码中,Counter 类有一个 count 变量,它可以通过 incrementCount 方法来增加,读取计数器值的方法有两种:readCountWithLock 使用 asReadLock() 方法返回的 Lock 对象进行同步,而 readCountWithStamp 则使用 StampedLock 的乐观读和读锁功能。在 main 方法中,启动了三个线程,一个用于增加计数器的值,另外两个用于读取计数器的值(一个使用 Lock,另一个使用 stamp)。

asReadLock() 方法提供了普通 Lock 的方式,但通常建议直接使用 StampedLock 的其他方法(如 tryOptimisticRead、readLock、unlockRead 等),因为它们提供了更高级别的并发控制和性能优化。

核心总结

Java内置锁:深度解析StampedLock并发类 - 程序员古德

StampedLock类总结

StampedLock提供了一种高效的线程同步方式,与传统的读写锁相比,如:ReentrantReadWriteLock,StampedLock则在某些方面展现出了其独特的优势,如下分析:

优点

  1. 高效的读性能:StampedLock在读操作上的性能尤为出色,它允许多个线程同时读取共享资源,而无需像ReentrantReadWriteLock那样在读线程之间保持互斥,这在读操作远多于写操作的场景中,能够显著提升系统的整体吞吐量。
  2. 乐观读策略:StampedLock引入了乐观读的概念,在进行读取操作前,线程可以尝试不获取锁直接读取数据,然后通过验证一个“戳记”(stamp)来确认数据在读取过程中是否被修改,这种策略在数据冲突较少的场景下能够减少不必要的锁竞争,从而提高性能。
  3. 轻量级设计:与ReentrantReadWriteLock相比,StampedLock的设计更为轻量级,没有与Condition相关的复杂机制,这使得它在简单的同步场景中更为高效。

缺点

  1. 不支持重入性:StampedLock不是重入锁,这意味着同一个线程不能重复获取同一个锁,在处理递归逻辑或需要在持有锁的情况下,可能会带来额外的复杂性。
  2. 缺乏条件变量:与ReentrantLock和ReentrantReadWriteLock不同,StampedLock没有提供与条件变量(Condition)相关的功能,使得它在需要等待/通知机制的复杂同步场景中不够灵活。

使用建议

  • 如果读操作远多于写操作,且不需要重入锁或条件变量支持,那么StampedLock可能是一个不错的选择。
  • 要特别注意正确地管理锁的生命周期和戳记的验证过程,以避免死锁和其他同步问题。
  • 对于复杂的同步场景或需要等待/通知机制的情况,ReentrantLock或ReentrantReadWriteLock会具有一定的优势。

StampedLock和ReentrantReadWriteLock有什么区别?

StampedLock和ReentrantReadWriteLock都是Java中用于同步的机制,它们允许多个线程同时读取共享资源,但在写入时要求独占访问,尽管它们的目的相似,但在设计、性能和适用场景上存在一些关键区别:

在设计上:

  1. StampedLock: 是一个非重入锁,意味着同一个线程不能重复获取同一个锁,无论是读锁还是写锁,StampedLock提供了三种访问模式:读锁、写锁和乐观读,乐观读是一种非阻塞的读取策略,它允许线程在不阻塞的情况下尝试读取数据,然后通过验证一个“戳记”(stamp)来确认数据在读取过程中没有被修改。
  2. ReentrantReadWriteLock: 是一个重入锁,允许同一个线程多次获取同一个锁,这在递归算法或需要锁跨越多个方法调用时非常有用,它只提供两种访问模式:读锁和写锁。

在性能上:

  1. StampedLock: 通常在读操作远多于写操作的场景中提供更好的性能,由于StampedLock支持乐观读,这可以避免不必要的上下文切换和线程阻塞,从而提高吞吐量,此外,StampedLock在读锁之间没有互斥,允许多个线程同时持有读锁。
  2. ReentrantReadWriteLock: 在读锁和写锁之间的切换上可能不如StampedLock高效,尤其是在高并发环境下,然而,在需要重入锁的场景中,它是更具有优势。

在适用场景上:

  1. StampedLock: 适用于读多写少的高并发场景,且当线程不需要在持有锁的情况下调用其他可能也需要该锁的方法时,由于它的非重入性,使用StampedLock需要更仔细地管理锁的生命周期,以避免死锁。
  2. ReentrantReadWriteLock: 更适用于需要锁的可重入性的场景,如递归算法或需要在持有锁的情况下调用其他可能也需要该锁的方法的情况,此外,在写操作相对频繁或读/写操作分布更均匀的场景中,ReentrantReadWriteLock更具有优势。

其他对比:

  1. 公平性: ReentrantReadWriteLock允许在构造函数中指定公平性策略(即线程获取锁的顺序),而StampedLock不支持公平性设置。
  2. 条件变量: ReentrantReadWriteLock与ReentrantLock类似,可以与Condition对象一起使用,以支持等待/通知机制,而StampedLock不提供条件变量,因此不适用于需要等待某个条件的场景。

关注我,每天学习互联网编程技术 - 程序员古德

END!

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

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

相关文章

Qt/QML编程之路:OpenGL的示例(39)

Qt编程之后,会发现有版本问题,有时候一个示例不同的版本下可能会跑不同,有些Qt5跑不同Qt6已经完善,可以跑通。 我就看到有个关于OpenGL的示例: 这个示例是演示怎么基于OpenGL编程的,但是调试时却发现glViewXXX等gl打头的函数说找不到reference,或者什么link不上之类的错…

FindMy技术与游戏手柄结合

游戏手柄作为游戏的重要配件&#xff0c;它极大地提升了玩家的游戏体验&#xff0c;推动了游戏市场的不断扩大。游戏手柄的触摸感应技术为游戏开发者提供了更多的创意空间&#xff0c;也为硬件制造商带来了新的商机。游戏手柄的个性化定制也为玩家社区的发展提供了动力&#xf…

红队打靶练习:BOB: 1.0.1

目录 信息收集 1、netdiscover 2、nmap 3、nikto 4、whatweb 目录探测 1、dirb 2、gobuster 3、dirsearch WEB 主页&#xff1a; robots.txt 其他页面 反弹shell 提权 系统信息收集 jc账户 本地提权 信息收集 1、netdiscover ┌──(root㉿ru)-[~/kali] └…

命令执行拼接符实例图解

命令执行常用到的5个拼接符&#xff0c;分别是逻辑与&#xff08;&&&#xff09;、逻辑或&#xff08;||&#xff09;、按位与&#xff08;&&#xff09;、按位或&#xff08;|&#xff09;和linux系统特有的分号&#xff08;;&#xff09; 1、&&&#xf…

运维平台介绍:视频智能运维平台的视频质量诊断分析和告警中心

目 录 一、视频智能运维平台介绍 &#xff08;一&#xff09;平台概述 &#xff08;二&#xff09;结构图 &#xff08;三&#xff09;功能介绍 1、运维监控 2、视频诊断 3、巡检管理 4、告警管理 5、资产管理 6、工单管理 7、运维…

【C++干货铺】C++11常用新特性 | 列表初始化 | STL中的变化

个人主页点击直达&#xff1a;小白不是程序媛 C系列专栏&#xff1a;C干货铺 代码仓库&#xff1a;Gitee 目录 C11简介 列表初始化 std::initializer_list std::initializer_list使用场景 decltype关键字 STL中的一些变化 新容器 array forward_list 容器中的一些新…

chrony介绍和安装

chrony介绍和安装 1.chrony&#xff08;时间同步服务&#xff09; 1.1 chrony介绍 Chrony 是一个用于时间同步的软件&#xff0c;它旨在提供高精度的系统时钟同步。Chrony 软件包括一个 NTP&#xff08;Network Time Protocol&#xff0c;网络时间协议&#xff09;服务器和客…

Python基础第二篇(Python基础语法)

文章目录 一、字面量二、注释三、变量四、数据类型五、数据类型转换六、标识符七、运算符八、字符串扩展内容&#xff08;1&#xff09;字符串定义&#xff08;2&#xff09;字符串拼接、&#xff08;3&#xff09;字符串格式化&#xff08;4&#xff09;字符串格式化的精度控制…

【算法与数据结构】Java实现查找与排序

文章目录 第一部分&#xff1a;查找算法二分查找插值查找分块查找哈希查找树表查找 第二部分&#xff1a;排序算法冒泡排序选择排序插入排序快速排序 总结 第一部分&#xff1a;查找算法 二分查找 也叫做折半查找&#xff0c;属于有序查找算法。 前提条件&#xff1a;数组数据…

TestNG注释

目录 TestNG注释列表 BeforeXXX和AfterXXX注释放在超类上时如何工作&#xff1f; 使用BeforeXXX和AfterXXX TestNG注释 TestNG是一个测试框架&#xff0c;旨在简化广泛的测试需求&#xff0c;从单元测试&#xff08;隔离测试一个类&#xff09;到集成测试&#xff08;测试由…

某马头条——day05

文章定时发布 实现方案对比 实现方案 延迟队列服务实现 按照文档进行项目的导入并准备数据库表导入对应实体类和nacos配置中心 乐观锁集成 redis集成和测试 成功集成通过测试 添加任务 ①&#xff1a;拷贝mybatis-plus生成的文件&#xff0c;mapper ②&#xff1a;创建task类…

ConcurrentHashMap 原理

ConcurrentHashMap ConcurrentHashMap的整体架构ConcurrentHashMap的基本功能ConcurrentHashMap在性能方面的优化 concurrentHashMap&#xff1a; ConcurrentHashMap的整体架构 concurrentHashMap是由数组链表红黑树组成 当我们初始化一个ConcurrentHashMap实例时&#xff0c…

基于74LS191+74LS160的8位二进制转BCD码应用电路设计

一、74LS191简介: 74LS191为可预置的四位二进制加/减法计数器,RCO进位/借位输出端,MAX/MIN进位/借位输出端,CTEN计数控制端,QA-QD计数输出端,U/D计数控制端,CLK时钟输入端,LOAD异步并行置入端(低电平有效)。 二、74LS191功能表: 三、74LS191逻辑框图: 四、74LS160…

2024美赛数学建模思路 - 案例:异常检测

文章目录 赛题思路一、简介 -- 关于异常检测异常检测监督学习 二、异常检测算法2. 箱线图分析3. 基于距离/密度4. 基于划分思想 建模资料 赛题思路 &#xff08;赛题出来以后第一时间在CSDN分享&#xff09; https://blog.csdn.net/dc_sinor?typeblog 一、简介 – 关于异常…

2024年【裂解(裂化)工艺】考试题及裂解(裂化)工艺免费试题

题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 裂解&#xff08;裂化&#xff09;工艺考试题参考答案及裂解&#xff08;裂化&#xff09;工艺考试试题解析是安全生产模拟考试一点通题库老师及裂解&#xff08;裂化&#xff09;工艺操作证已考过的学员汇总&#xf…

CentOS7 配置静态IP

目录 在解决了刚安装不能联网后配置静态IP1.查看配置好网卡后&#xff0c;DHCP动态分配的IP地址2. 查看网关3. 更改IP地址文件4. 重启网络服务5. 检查配置6. 更新路由&#xff08;如果需要&#xff09; 在解决了刚安装不能联网后 解决centos 7刚安装不能联网 配置静态IP 在 C…

阿里云容器服务助力万兴科技 AIGC 应用加速

作者&#xff1a;子白&#xff08;顾静&#xff09; 2023 年堪称是 AIGC 元年&#xff0c;文生图领域诞生了 Stable Diffusion 项目&#xff0c;文生文领域诞生了 GPT 家族。一时间风起云涌&#xff0c;国内外许多企业投身 AIGC 创新浪潮&#xff0c;各大云厂商紧随其后纷纷推…

MySQL---经典SQL练习题

MySQL---经典50道练习题 素材:练习题目&#xff1a;解题&#xff1a; 素材: 1.学生表 Student(SId,Sname,Sage,Ssex) SId 学生编号,Sname 学生姓名,Sage 出生年月,Ssex 学生性别 2.课程表 Course(CId,Cname,TId) CId 课程编号,Cname 课程名称,TId 教师编号 3.教师表 Teacher(T…

C++初阶类与对象(二):详解构造函数和析构函数

上次为类与对象开了一个头&#xff1a;C初阶类与对象&#xff08;一&#xff09;&#xff1a;学习类与对象、访问限定符、封装、this指针 今天就来更进一步 文章目录 1.类的6个默认成员函数2.构造函数2.1引入和概念2.2构造函数特性2.2.1特性1~42.2.2注意2.2.3特性5~72.2.4注意 …

Linux网络--- SSH服务

一、ssh服务简介 1、什么是ssh SSH&#xff08;Secure Shell&#xff09;是一种安全通道协议&#xff0c;主要用来实现字符界面的远程登录、远程复制等功能。SSH 协议对通信双方的数据传输进行了加密处理&#xff0c;其中包括用户登录时输入的用户口令&#xff0c;SSH 为建立在…