JUC并发编程第十四篇，StampedLock（邮戳锁）为什么比ReentrantReadWriteLock（读写锁）更快！

news2025/1/17 23:07:14

JUC并发编程第十四篇，StampedLock（邮戳锁）为什么比ReentrantReadWriteLock（读写锁）更快！

    • 一、ReentrantReadWriteLock（读写锁）
      • 1、读写锁存在的意义？
      • 2、读写锁代码示例
      • 3、读写锁的特点（可重入，读写分离）与锁降级
      • 4、锁降级官方示例
      • 5、ReentrantReadWriteLock存在问题（锁饥饿）？
    • 二、StampedLock（邮戳锁）
      • 1、StampedLock是什么？
      • 2、演示StampedLock的特点
        • 悲观读演示
        • 乐观读演示，成功，中途无修改
        • 乐观读演示，失败，中途被修改
      • 3、StampedLock存在的问题？

一、ReentrantReadWriteLock（读写锁）

1、读写锁存在的意义？

  • 读写锁：一个资源能够被多个读线程访问，或者被一个写线程访问，但是不能同时存在读写线程。
  • 它并不是真正意义上的读写分离，它只允许读读共存，而读写和写写依然是互斥的。
  • 在大多数场景下，读线程和读线程之间并不存在互斥关系，只有读写、写写之间才需要操作互斥，这就是ReentrantReadWriteLock存在的意义，一个ReentrantReadWriteLock同时只能存在一个写锁，但是可以存在多个读锁，并且不能同时存在写锁和读锁，也即一个资源可以被多个读操作访问或一个写操作访问，但两者不能同时进行。
  • 只有在读多写少情境之下，读写锁才具有较高的性能体现。

2、读写锁代码示例

class MyResource {

    Map<String,String> map = new HashMap<>();
    ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();

    //写
    public void write(String key,String value) {
        rwLock.writeLock().lock();
        try {
            System.out.println(Thread.currentThread().getName()+"\t"+"---正在写入");
            map.put(key,value);
            //模拟业务
            try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); }

            System.out.println(Thread.currentThread().getName()+"\t"+"---完成写入");
        }finally {
            rwLock.writeLock().unlock();
        }
    }
    //读
    public void read(String key) {
        rwLock.readLock().lock();
        try {
            System.out.println(Thread.currentThread().getName()+"\t"+"---正在读取");
            String result = map.get(key);

            //暂停几秒钟线程
            try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); }

            System.out.println(Thread.currentThread().getName()+"\t"+"---完成读取result： "+result);
        }finally {
            rwLock.readLock().unlock();
        }
    }

}

public class ReentrantReadWriteLockDemo {
    public static void main(String[] args) {

        MyResource myResource = new MyResource();
        //十个写线程
        for (int i = 1; i <=10; i++) {
            //Java 8 之后，在匿名类或 Lambda 表达式中访问的局部变量，如果不是 final 类型的话，编译器自动加上 final 修饰符
            int finalI = i;
            new Thread(() -> {
                myResource.write(finalI +"", finalI +"");
            },String.valueOf(i)).start();
        }
        //十个读线程
        for (int i = 1; i <=10; i++) {
            int finalI = i;
            new Thread(() -> {
                myResource.read(finalI +"");
            },String.valueOf(i)).start();
        }

        //测试：再5个写线程
        for (int i = 1; i <=5; i++) {
            int finalI = i;
            new Thread(() -> {
                myResource.write(finalI +"", finalI +"");
            },"测试"+String.valueOf(i)).start();
        }

    }
}

输出结果分析
在这里插入图片描述

3、读写锁的特点（可重入，读写分离）与锁降级

  • 锁降级：官方解释为遵循获取写锁、获取读锁、再释放写锁的次序，写锁能够降级成为读锁，但是读锁是不能直接升级为写入锁的。
  • 在ReentrantReadWriteLock中，如果一个线程占有了写锁，在不释放写锁的情况下，它还能占有读锁，即写锁降级为读锁；但是，当读锁被使用时，如果有线程尝试获取写锁，该写线程会被阻塞，需要释放所有读锁，才可获取写锁。

写锁到读锁流程：
在这里插入图片描述
读锁到写锁流程：
在这里插入图片描述

  • 写锁和读锁是线程间互斥的（当前线程可以获取到写锁又获取到读锁，但是获取到了读锁不能继续获取写锁），因为读写锁要保持写操作的可见性。如果允许读锁在被获取的情况下对写锁的获取，那么正在运行的其他读线程无法感知到当前写线程的操作。

4、锁降级官方示例

在这里插入图片描述

  • 代码中声明了一个volatile类型的cacheValid变量，保证其可见性。

  • 首先获取读锁，如果cache不可用，则释放读锁，获取写锁，在更改数据之前，再检查一次cacheValid的值，然后修改数据，将cacheValid置为true，然后在释放写锁前获取读锁；此时，cache中数据可用，处理cache中数据，最后释放读锁。这个过程就是一个完整的锁降级的过程，目的是保证数据可见性。

  • 违背锁降级的步骤

    • 如果当前的线程C在修改完cache中的数据后，没有获取读锁而是直接释放了写锁，那么假设此时另一个线程D获取了写锁并修改了数据，那么C线程无法感知到数据已被修改，则数据出现错误。

  • 遵循锁降级的步骤

    • 线程C在释放写锁之前获取读锁，那么线程D在获取写锁时将被阻塞，直到线程C完成数据处理过程，释放读锁。这样可以保证返回的数据是这次更新的数据，该机制是专门为了缓存设计的。

5、ReentrantReadWriteLock存在问题（锁饥饿）？

  • 分析读写锁，发现它存在一个潜在的问题：如果有线程正在读，写线程需要等待读线程释放锁后才能获取写锁。
  • 也就是说，读写锁读的过程中不允许写，只有等待线程都释放了读锁，当前线程才能获取写锁，也就是写入必须等待，这是一种悲观的读锁。
  • 假如当前有1000个线程，999个读，1个写，有可能999个读取线程长时间抢到了锁，那1个写线程迟迟不能获取锁，造成锁饥饿问题。

改进：StampedLock读的过程中也允许获取写锁介入，但是需要额外的方法来判断读的过程中是否有写入，这是一种乐观的读锁。

二、StampedLock（邮戳锁）

1、StampedLock是什么？

  • StampedLock是JDK1.8中新增的一个读写锁，是对ReentrantReadWriteLock的进一步优化。
  • ReentrantReadWriteLock的读锁被占用的时候，其他线程尝试获取写锁的时候会被阻塞。
  • StampedLock采取乐观获取锁后，其他线程尝试获取写锁时不会被阻塞，在获取乐观读锁后，还需要对结果进行校验。
  • 它里边有一个Long类型的stamp戳记，代表了锁的状态。当stamp返回零时，表示线程获取锁失败，并且，当释放锁或者转换锁的时候，都要传入最初获取的stamp值。

2、演示StampedLock的特点

悲观读演示

public class StampedLockDemo {

    static int number = 37;
    static StampedLock stampedLock = new StampedLock();

    public void write() {
        long stamp = stampedLock.writeLock();
        System.out.println(Thread.currentThread().getName()+"\t"+"=====写线程准备修改");

        try {
            number = number + 13;
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            stampedLock.unlockWrite(stamp);
        }

        System.out.println(Thread.currentThread().getName()+"\t"+"=====写线程结束修改");
    }

    //悲观读
    public void read() {
        long stamp = stampedLock.readLock();
        System.out.println(Thread.currentThread().getName()+"\t come in readlock block,4 seconds continue...");
        //暂停4秒钟线程
        for (int i = 0; i <4 ; i++) {
            try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
            System.out.println(Thread.currentThread().getName()+"\t 正在读取中......");
        }

        try {
            int result = number;
            System.out.println(Thread.currentThread().getName()+"\t"+" 获得成员变量值result：" + result);
            System.out.println("写线程没有修改值，因为 stampedLock.readLock()读的时候，不可以写，读写互斥");
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            stampedLock.unlockRead(stamp);
        }
    }

    public static void main(String[] args) {
        StampedLockDemo resource = new StampedLockDemo();

        //1 悲观读,和ReentrantReadWriteLock一样
        new Thread(() -> {
            //悲观读
            resource.read();
        },"readThread").start();

        new Thread(() -> {
            resource.write();
        },"writeThread").start();
    }
}

在这里插入图片描述

乐观读演示，成功，中途无修改

public class StampedLockDemo {

    static int number = 37;
    static StampedLock stampedLock = new StampedLock();

    public void write() {
        long stamp = stampedLock.writeLock();
        System.out.println(Thread.currentThread().getName()+"\t"+"=====写线程准备修改");

        try {
            number = number + 13;
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            stampedLock.unlockWrite(stamp);
        }

        System.out.println(Thread.currentThread().getName()+"\t"+"=====写线程结束修改");
    }

    //乐观读
    public void tryOptimisticRead() {
        long stamp = stampedLock.tryOptimisticRead();
        //先把数据取得一次
        int result = number;

        //间隔4秒钟，我们很乐观的认为没有其他线程修改过number值，实际情况靠判断。
        System.out.println("4秒前stampedLock.validate值(true无修改，false有修改)"+"\t"+stampedLock.validate(stamp));

        for (int i = 1; i <=4 ; i++) {

            try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }

            System.out.println(Thread.currentThread().getName()+"\t 正在读取中......"+i+
                    "秒后stampedLock.validate值(true无修改，false有修改)"+"\t"
                    +stampedLock.validate(stamp));
        }

        if(!stampedLock.validate(stamp)) {
            System.out.println("--------存在写操作！----------");
            //有人动过了，需要从乐观读切换到普通读的模式。
            stamp = stampedLock.readLock();
            try {
                System.out.println("从乐观读 升级为 悲观读并重新获取数据");
                //重新获取数据
                result = number;
                System.out.println("重新悲观读锁通过获取到的成员变量值result：" + result);
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                stampedLock.unlockRead(stamp);
            }
        }
        System.out.println(Thread.currentThread().getName()+"\t finally value: "+result);
    }

    public static void main(String[] args) {
        StampedLockDemo resource = new StampedLockDemo();

        //2 乐观读，成功
        new Thread(() -> {
            //乐观读
            resource.tryOptimisticRead();
        },"readThread").start();

        //6秒钟乐观读取resource.tryOptimisticRead()成功
        try { TimeUnit.SECONDS.sleep(6); } catch (InterruptedException e) { e.printStackTrace(); }

        new Thread(() -> {
            resource.write();
        },"writeThread").start();
    }
}

在这里插入图片描述

乐观读演示，失败，中途被修改

public class StampedLockDemo {

    static int number = 37;
    static StampedLock stampedLock = new StampedLock();

    public void write() {
        long stamp = stampedLock.writeLock();
        System.out.println(Thread.currentThread().getName()+"\t"+"=====写线程准备修改");

        try {
            number = number + 13;
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            stampedLock.unlockWrite(stamp);
        }

        System.out.println(Thread.currentThread().getName()+"\t"+"=====写线程结束修改");
    }

    //乐观读
    public void tryOptimisticRead() {
        long stamp = stampedLock.tryOptimisticRead();
        //先把数据取得一次
        int result = number;

        //间隔4秒钟，我们很乐观的认为没有其他线程修改过number值，实际情况靠判断。
        System.out.println("4秒前stampedLock.validate值(true无修改，false有修改)"+"\t"+stampedLock.validate(stamp));

        for (int i = 1; i <=4 ; i++) {

            try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }

            System.out.println(Thread.currentThread().getName()+"\t 正在读取中......"+i+
                    "秒后stampedLock.validate值(true无修改，false有修改)"+"\t"
                    +stampedLock.validate(stamp));
        }

        if(!stampedLock.validate(stamp)) {
            System.out.println("--------存在写操作！----------");
            //有人动过了，需要从乐观读切换到普通读的模式。
            stamp = stampedLock.readLock();
            try {
                System.out.println("从乐观读 升级为 悲观读并重新获取数据");
                //重新获取数据
                result = number;
                System.out.println("重新悲观读锁通过获取到的成员变量值result：" + result);
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                stampedLock.unlockRead(stamp);
            }
        }
        System.out.println(Thread.currentThread().getName()+"\t finally value: "+result);
    }

    public static void main(String[] args) {
        StampedLockDemo resource = new StampedLockDemo();

        //3 乐观读，失败，重新转为悲观读，重读数据一次
        new Thread(() -> {
            //乐观读
            resource.tryOptimisticRead();
        },"readThread").start();

        //2秒钟乐观读取resource.tryOptimisticRead()失败
        try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); }

        new Thread(() -> {
            resource.write();
        },"writeThread").start();
    }
}

在这里插入图片描述

3、StampedLock存在的问题？

  • StampedLock不支持重入
  • StampedLock悲观读锁和写锁都不支持condition（条件变量）
  • StampedLock使用中一定不能调用中断操作（interrupt方法）

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

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

相关文章

orCAD Capture DRC规则设置及检查和报错修改

orCAD Capture DRC规则设置及检查和报错修改

1.进入DRC设置界面： 如下图，依次选中“dsn→Tools→Design Rules Check” 或者 然后会跳出来一个提示框，点击Yes即可 2.进行DRC规则设置： 上面第二步结束之后，就进入到了DRC规则设置界面，主要有四个类别进行设置。如下图，分别是Design Rules Options、Electrriacl Rule…
阅读更多...
致初学者：如何学好Python这门编程语言？

致初学者：如何学好Python这门编程语言？

前言 对于很多Python这门编程语言的初学者&#xff0c;往往会面临以下问题&#xff1a; Python2和Python3我该学习哪一个&#xff1f; 是否要安装Linux系统学习Python&#xff1f; Python3有各种版本我该安装哪一个&#xff1f; 那么多的图书、视频和电子教程我该选择哪一个&a…
阅读更多...
MySQL --- 函数大全 7

MySQL --- 函数大全 7

目录 1.从地理哈希值返回纬度 ST_LatFromGeoHash() 2.点的返回纬度 ST_Latitude() 3.返回线字符串的长度 ST_Length() 4.从 WKT 构造线字符串 ST_LineFromText&#xff08;&#xff09;/ ST_LineStringFromText&#xff08;&#xff09; 5.从…
阅读更多...
excel行列互换方法

excel行列互换方法

excel行列互换的两种方法&#xff1a;使用转置功能和使用函数公式完成行列互换。excel行列互换多用在打印的时候&#xff0c;根据不同的页面设置&#xff0c;有时页面不够用&#xff0c;这个情况就需要用到excel行列互换。 下图是一个简单的excel行列互换的实例应用。4行三列的…
阅读更多...
设备备件管理怎么做？

设备备件管理怎么做？

本篇文章将介绍&#xff1a;1、设备备件管理中存在的问题&#xff1b;2、设备备件管理具体怎么做&#xff1f; 设备备件管理&#xff0c;是为了能够按计划进行设备检修&#xff0c;尽量缩短故障停机时间&#xff0c;减少维修费用&#xff0c;在保证备件品种的质量和数量、供应及…
阅读更多...
SpringBoot【配置文件】

SpringBoot【配置文件】

SpringBoot【配置文件】&#x1f34e;一.配置文件&#x1f352;1.1 配置文件作用&#x1f352;1.2 配置⽂件的格式&#x1f34e;二.properties 配置文件&#x1f352;2.1 properties 基本语法&#x1f352;2.2 properties快捷生成插件(spring tools)&#x1f352;2.3 读取prope…
阅读更多...
用好 TypeScript，请再深入一些

用好 TypeScript，请再深入一些

TypeScript 已经成为前端编程语言的事实标准。但我从大量的 Code Review 和面试经历中发现&#xff0c;真正能深入使用 TypeScript 的开发其实并不多。如果你不知道 ReturnType<T> 的作用和实现&#xff0c;或许这篇文章也适合你。 当然&#xff0c;我们花大量时间去学习…
阅读更多...
tinode客户端安卓版编译手账

tinode客户端安卓版编译手账

前一阵子我自己架设了一个tinode的IM服务器, web直接可以运行 但是安卓版本的一直报错&#xff0c; 具体信息为&#xff1a; No subjectAltNames on the certificate match 问了作者&#xff0c;作者竟然把我的问题直接删除了&#xff0c;还是自己调试代码吧。毕竟源码面前…
阅读更多...
两年CRUD，没料到我这渣二本，备战两个月面试阿里，居然侥幸拿下P6的offer

两年CRUD，没料到我这渣二本，备战两个月面试阿里，居然侥幸拿下P6的offer

对于很多没有学历优势的人来说&#xff0c;面试大厂是非常困难的&#xff0c;这对我而言&#xff0c;也是一样&#xff0c;出身于二本&#xff0c;原本以为就三点一线的生活度过一生&#xff0c;直到生活上的变故&#xff0c;才让我有了新的想法和目标&#xff0c;因此我这个二…
阅读更多...
fl studio21版本如何更新FL最新版升级教程

fl studio21版本如何更新FL最新版升级教程

2022年12月7日晚&#xff0c;全球知名的音乐创作软件&#xff0c;FL Studio正式推出最新21版&#xff0c;为原创音乐人提供更好用的DAW&#xff08;数字音乐工作站&#xff09;工具。 FL Studio中文已上线21新版 FL Studio国人也叫它水果编曲软件&#xff0c;是一款有着20多年…
阅读更多...
Java——布隆过滤器

Java——布隆过滤器

在上一篇博客中讲到位图是用来判定一个正整数是否存在的。对于一个负数&#xff0c;我们可以统一规定让他们加上一个数&#xff0c;变成正数&#xff0c;然后用位图的方式存储。但是对于字符串&#xff0c;我们就没办法存储了。因此发明了布隆过滤器 概念 对于网络上很多需要…
阅读更多...
计算机毕设Python+Vue校园新闻发布系统（程序+LW+部署）

计算机毕设Python+Vue校园新闻发布系统（程序+LW+部署）

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
【从零开始学习深度学习】26.卷积神经网络之AlexNet模型介绍及其Pytorch实现【含完整代码】

【从零开始学习深度学习】26.卷积神经网络之AlexNet模型介绍及其Pytorch实现【含完整代码】

目录1. AlexNet模型1.1 AlexNet与LeNet的区别1.2 简化的AlexNet实现1.3 各层输出形状详解2. 读取数据3. 模型训练4. 总结上一篇文章中我们了解到神经网络可以直接基于图像的原始像素进行分类&#xff0c;这种称为端到端&#xff08;end-to-end&#xff09;的方法可以节省很多中…
阅读更多...
腾讯实践：从推荐模型的基础特点看大规模推荐类深度学习系统的设计

腾讯实践：从推荐模型的基础特点看大规模推荐类深度学习系统的设计

省时查报告-专业、及时、全面的行研报告库省时查方案-专业、及时、全面的营销策划方案库【免费下载】2022年11月份热门报告盘点腾讯新闻信息流推荐技术实践.pdf推荐系统在腾讯游戏中的应用实践.pdf基于深度学习的个性化推荐系统实时化改造与升级.pdf推荐技术在vivo互联网商业化…
阅读更多...
Zabbix与乐维监控对比分析（四）——告警管理篇

Zabbix与乐维监控对比分析（四）——告警管理篇

在前面发布的Zabbix与乐维监控对比分析文章中&#xff0c;我们评析了二者在架构与性能、Agent管理、自动发现、权限管理、对象管理等方面的差异。接下来让我们一起看看二者在告警管理方面的差异。 告警管理是所有IT监控平台最重磅的功能之一&#xff0c;也是评判一个监控平台好…
阅读更多...
cad2010怎么隐藏标注尺寸,cad2007怎么隐藏标注尺寸

cad2010怎么隐藏标注尺寸,cad2007怎么隐藏标注尺寸

1、CAD2007怎么隐藏所有的标注尺寸? 1、在"查看器"菜单面板中隐藏的工具有"线宽"、"测量"、"文本"三种工具,可用于隐藏或显示CAD图中的线条宽度、测量尺寸和文本内容。 2、点击选择"测量"工具,将尺寸内容的CAD图隐藏起来。…
阅读更多...
JavaScript-BOM

JavaScript-BOM

&#x1f496;通过看视频教程和红宝书浅浅的写下一些关于BOM的笔记 红宝书知识系统全面&#xff0c;精炼。大概是因为太干货了&#xff0c;涉及的知识点太多&#xff0c;所以我选择看着简单的视频教程&#xff0c;同时打开红宝书。笔记的内容以红宝书为基准。 window对象 BOM的…
阅读更多...
艾美捷内皮细胞生长添加剂解决方案

艾美捷内皮细胞生长添加剂解决方案

内皮细胞生长添加剂是一种培养基补充物&#xff0c;旨在体外优化人原代微血管内皮细胞的生长。这是一种无菌浓缩&#xff08;100X&#xff09;溶液&#xff0c;含有培养正常人微血管内皮细胞所需的生长因子、激素和蛋白质。该补充剂的配制&#xff08;定量和定性&#xff09;旨…
阅读更多...
Linux下的多线程编程

Linux下的多线程编程

线程&#xff08;thread&#xff09;技术早在60年代就被提出&#xff0c;但真正应用多线程到操作系统中去&#xff0c;是在80年代中期&#xff0c;solaris是这方面的佼佼者。传统的Unix也支持线程的概念&#xff0c;但是在一个进程&#xff08;process&#xff09;中只允许有一…
阅读更多...
基于java+springmvc+mybatis+vue+mysql的教资考前指导系统

基于java+springmvc+mybatis+vue+mysql的教资考前指导系统

项目介绍 对于本教资考前指导系统的设计来说&#xff0c;系统开发主要是采用java语言技术&#xff0c;后端采用springboot框架&#xff0c;前端采用vue技术&#xff0c;在整个系统的设计中应用MySQL数据库来完成数据存储&#xff0c;具体根据教资考前指导系统的现状来进行开发…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023