热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

并发编程|StampedLock工具类之悲观读锁readLock

StampedLock提供的悲观读锁readLoke,是一种共享锁,在读多写少的场景十分适用,可以极

StampedLock提供三种模式的读写锁,分别为写锁、悲观读锁、乐观读锁
记忆口诀是写写互斥、读写互斥、读读共享

为更好的理解,请先阅读
并发编程 | StampedLock工具类之写锁解析 writeLock
由于内容较多,本文将针对悲观读锁的使用进行解析说明,乐观读锁请阅读后续章节


01.悲观读锁readLock
悲观读锁是一个共享锁,没有线程占用写锁的情况下,多个线程可以同时获取读锁。如果其他线程已经获得了写锁,则阻塞当前线程。

StampedLock.readLock中同样使用stamp(邮戳)的概念。
它代表线程获取到锁的版本,每一把锁都有一个唯一的stamp。
stamp是一个long类型的数字,具体使用继续向下阅读。

02.基本示例

读锁的基本使用方式

(如代码超出页面请横向滑动代码区域)

    StampedLock sl = new StampedLock();
    //获取读锁,并得到stamp1
    long stamp1 = sl.readLock();
    System.out.println("get read lock1,stamp="+stamp1);
    //再次获取读锁,并得到stamp2
    long stamp2 = sl.readLock();
    System.out.println("get read lock2,stamp="+stamp2);
    //使用stamp1解锁
    sl.unlockRead(stamp1);
    //使用stamp2解锁
    sl.unlockRead(stamp2);
    //获得写锁,并得到stamp3
    long stamp3 = sl.writeLock();
    System.out.println("get write lock,stamp="+stamp3);

    运行结果

      get read lock1,stamp=257
      get read lock2,stamp=258
      get write lock,stamp=384


      说明

      读锁可以多次获取(没有写锁占用的情况下),写锁必须在读锁全部释放之后才能获取写锁。


      03.同线程读写互斥示例

      读锁未全部释放时获取写锁

      (如代码超出页面请横向滑动代码区域)

        StampedLock sl1 = new StampedLock();
        //获取读锁,成功
        long stamp11 = sl1.readLock();
        System.out.println("get read lock1,stamp="+stamp11);
        //获取读锁,成功
        long stamp21 = sl1.readLock();
        System.out.println("get read lock2,stamp="+stamp21);
        //释放stamp21的读锁,成功
        sl1.unlockRead(stamp21);
        //获取写锁,失败,被阻塞
        long stamp31 = sl1.writeLock();
        System.out.println("get write lock,stamp="+stamp31);

        运行结果

          get read lock1,stamp=257
          get read lock2,stamp=258
          ...获取写锁时阻塞...

          说明

          只要还有任意的锁没有释放(论是写锁还是读锁),这时候来尝试获取写锁都会失败,因为读写互斥,写写互斥。写锁本身就是排它锁。


          04.同线程读写互斥示例

          (如代码超出页面请横向滑动代码区域)

            StampedLock sl2 = new StampedLock();
            //获取读锁
            long stamp12 = sl2.readLock();
            System.out.println(Thread.currentThread().getName()+" get read lock1,stamp="+stamp12);
            new Thread(new Runnable() {
            @Override
            public void run() {
            System.out.println(Thread.currentThread().getName()+" run");
            //如果main线程的读锁释放了,才能获得写锁
            long stamp121 = sl2.writeLock();
            System.out.println(Thread.currentThread().getName()+" get write lock2,stamp="+stamp121);
            //释放写锁
            sl2.unlock(stamp121);
            System.out.println(Thread.currentThread().getName()+" unlock write lock2,stamp="+stamp121);
            }
            }).start();
            // 睡眠3秒,然后再释放读锁
            Thread.sleep(3000);
            System.out.println(Thread.currentThread().getName()+" unlock read lock1,stamp="+stamp12);
            // 释放读锁
            sl2.unlockRead(stamp12);

            运行结果

              main get read lock1,stamp=257
              //Thread-0线程已经开始运行,并尝试获取写锁,但是无法获取
              Thread-0 run  
              ....此处睡眠3秒....
              main unlock read lock1,stamp=257
              //3秒后主线程释放了读锁,所以Thread-0瞬间获得了写锁,继续运行
              Thread-0 get write lock2,stamp=384
              Thread-0 unlock write lock2,stamp=384

              说明

              在多个线程之间依然存在写写互斥、读写互斥、读读共享的关系


              05.总结

              为什么叫悲观读锁?悲观锁认为数据是极有可能被修改的,所以在使用数据之前都需要先加锁,锁未释放之前如果有其他线程想要修改数据(加写锁)就必须阻塞它。

              悲观读锁并算不上绝对的悲观,排他锁才是真正的悲观锁,由于读锁具有读读共享的特性,所以对于读多写少的场景十分适用,可以大大提高并发性能。

              下篇文章要讲解的乐观读锁tryOptimisticRead,性能更加强劲


              想快速精通并发编程点击公众下方的“阅读原文学习由Kevin本人录制的《JAVA并发编程-豪华版》课程。



              推荐阅读
              • 深入解析 Apache Shiro 安全框架架构
                本文详细介绍了 Apache Shiro,一个强大且灵活的开源安全框架。Shiro 专注于简化身份验证、授权、会话管理和加密等复杂的安全操作,使开发者能够更轻松地保护应用程序。其核心目标是提供易于使用和理解的API,同时确保高度的安全性和灵活性。 ... [详细]
              • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
              • 深入理解 SQL 视图、存储过程与事务
                本文详细介绍了SQL中的视图、存储过程和事务的概念及应用。视图为用户提供了一种灵活的数据查询方式,存储过程则封装了复杂的SQL逻辑,而事务确保了数据库操作的完整性和一致性。 ... [详细]
              • 本文详细介绍了 Dockerfile 的编写方法及其在网络配置中的应用,涵盖基础指令、镜像构建与发布流程,并深入探讨了 Docker 的默认网络、容器互联及自定义网络的实现。 ... [详细]
              • 数据库内核开发入门 | 搭建研发环境的初步指南
                本课程将带你从零开始,逐步掌握数据库内核开发的基础知识和实践技能,重点介绍如何搭建OceanBase的开发环境。 ... [详细]
              • 本文详细介绍了Akka中的BackoffSupervisor机制,探讨其在处理持久化失败和Actor重启时的应用。通过具体示例,展示了如何配置和使用BackoffSupervisor以实现更细粒度的异常处理。 ... [详细]
              • 并发编程:深入理解设计原理与优化
                本文探讨了并发编程中的关键设计原则,特别是Java内存模型(JMM)的happens-before规则及其对多线程编程的影响。文章详细介绍了DCL双重检查锁定模式的问题及解决方案,并总结了不同处理器和内存模型之间的关系,旨在为程序员提供更深入的理解和最佳实践。 ... [详细]
              • 优化ListView性能
                本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
              • 本文将介绍如何编写一些有趣的VBScript脚本,这些脚本可以在朋友之间进行无害的恶作剧。通过简单的代码示例,帮助您了解VBScript的基本语法和功能。 ... [详细]
              • 本文详细介绍了如何在Linux系统上安装和配置Smokeping,以实现对网络链路质量的实时监控。通过详细的步骤和必要的依赖包安装,确保用户能够顺利完成部署并优化其网络性能监控。 ... [详细]
              • 本文探讨了在Java多线程环境下,如何确保具有相同key值的线程能够互斥执行并按顺序输出结果。通过优化代码结构和使用线程安全的数据结构,我们解决了线程同步问题,并实现了预期的并发行为。 ... [详细]
              • Python 异步编程:深入理解 asyncio 库(上)
                本文介绍了 Python 3.4 版本引入的标准库 asyncio,该库为异步 IO 提供了强大的支持。我们将探讨为什么需要 asyncio,以及它如何简化并发编程的复杂性,并详细介绍其核心概念和使用方法。 ... [详细]
              • 2023年京东Android面试真题解析与经验分享
                本文由一位拥有6年Android开发经验的工程师撰写,详细解析了京东面试中常见的技术问题。涵盖引用传递、Handler机制、ListView优化、多线程控制及ANR处理等核心知识点。 ... [详细]
              • MySQL索引详解与优化
                本文深入探讨了MySQL中的索引机制,包括索引的基本概念、优势与劣势、分类及其实现原理,并详细介绍了索引的使用场景和优化技巧。通过具体示例,帮助读者更好地理解和应用索引以提升数据库性能。 ... [详细]
              • 微软Exchange服务器遭遇2022年版“千年虫”漏洞
                微软Exchange服务器在新年伊始遭遇了一个类似于‘千年虫’的日期处理漏洞,导致邮件传输受阻。该问题主要影响配置了FIP-FS恶意软件引擎的Exchange 2016和2019版本。 ... [详细]
              author-avatar
              书友44802979
              这个家伙很懒,什么也没留下!
              PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
              Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有