跨境互联网 跨境互联网
首页
  • AI 工具

    • 绘图提示词工具 (opens new window)
    • ChatGPT 指令 (opens new window)
  • ChatGPT

    • ChatGP T介绍
    • ChatGPT API 中文开发手册
    • ChatGPT 中文调教指南
    • ChatGPT 开源项目
  • Midjourney

    • Midjourney 文档
  • Stable Diffusion

    • Stable Diffusion 文档
  • 其他

    • AIGC 热门文章
    • 账号合租 (opens new window)
    • 有趣的网站
  • Vue

    • Vue3前置
  • JAVA基础

    • Stream
    • Git
    • Maven
    • 常用第三方类库
    • 性能调优工具
    • UML系统建模
    • 领域驱动设计
    • 敏捷开发
    • Java 测试
    • 代码规范及工具
    • Groovy 编程
  • 并发编程&多线程

    • 并发编程
    • 高性能队列 Disruptor
    • 多线程并发在电商系统下的应用
  • 其他

    • 面试题
  • 消息中间中间件

    • Kafka
    • RabbitMQ
    • RocketMQ
  • 任务调度

    • Quartz
    • XXL-Job
    • Elastic-Job
  • 源码解析

    • Mybatis 高级使用
    • Mybatis 源码剖析
    • Mybatis-Plus
    • Spring Data JPA
    • Spring 高级使用
    • Spring 源码剖析
    • SpringBoot 高级使用
    • SpringBoot 源码剖析
    • Jdk 解析
    • Tomcat 架构设计&源码剖析
    • Tomcat Web应用服务器
    • Zookeeper 高级
    • Netty
  • 微服务框架

    • 分布式原理
    • 分布式集群架构场景化解决方案
    • Dubbo 高级使用
    • Dubbo 核心源码剖析
    • Spring Cloud Gateway
    • Nacos 实战应用
    • Sentinel 实战应用
    • Seata 分布式事务
  • 数据结构和算法的深入应用
  • 存储

    • 图和Neo4j
    • MongoDB
    • TiDB
    • MySQL 优化
    • MySQL 平滑扩容实战
    • MySQL 海量数据存储与优化
    • Elasticsearch
  • 缓存

    • Redis
    • Aerospike
    • Guava Cache
    • Tair
  • 文件存储

    • 阿里云 OSS 云存储
    • FastDF 文件存储
  • 基础

    • Linux 使用
    • Nginx 使用与配置
    • OpenResty 使用
    • LVS+Keepalived 高可用部署
    • Jekins
  • 容器技术

    • Docker
    • K8S
    • K8S
  • 01.全链路(APM)
  • 02.电商终极搜索解决方案
  • 03.电商亿级数据库设计
  • 04.大屏实时计算
  • 05.分库分表的深入实战
  • 06.多维系统下单点登录
  • 07.多服务之间分布式事务
  • 08.业务幂等性技术架构体系
  • 09.高并发下的12306优化
  • 10.每秒100W请求的秒杀架构体系
  • 11.集中化日志管理平台的应用
  • 12.数据中台配置中心
  • 13.每天千万级订单的生成背后痛点及技术突破
  • 14.红包雨的架构设计及源码实现
  • 人工智能

    • Python 笔记
    • Python 工具库
    • 人工智能(AI) 笔记
    • 人工智能(AI) 项目笔记
  • 大数据

    • Flink流处理框架
  • 加密区

    • 机器学习(ML) (opens new window)
    • 深度学习(DL) (opens new window)
    • 自然语言处理(NLP) (opens new window)
AI 导航 (opens new window)

Revin

首页
  • AI 工具

    • 绘图提示词工具 (opens new window)
    • ChatGPT 指令 (opens new window)
  • ChatGPT

    • ChatGP T介绍
    • ChatGPT API 中文开发手册
    • ChatGPT 中文调教指南
    • ChatGPT 开源项目
  • Midjourney

    • Midjourney 文档
  • Stable Diffusion

    • Stable Diffusion 文档
  • 其他

    • AIGC 热门文章
    • 账号合租 (opens new window)
    • 有趣的网站
  • Vue

    • Vue3前置
  • JAVA基础

    • Stream
    • Git
    • Maven
    • 常用第三方类库
    • 性能调优工具
    • UML系统建模
    • 领域驱动设计
    • 敏捷开发
    • Java 测试
    • 代码规范及工具
    • Groovy 编程
  • 并发编程&多线程

    • 并发编程
    • 高性能队列 Disruptor
    • 多线程并发在电商系统下的应用
  • 其他

    • 面试题
  • 消息中间中间件

    • Kafka
    • RabbitMQ
    • RocketMQ
  • 任务调度

    • Quartz
    • XXL-Job
    • Elastic-Job
  • 源码解析

    • Mybatis 高级使用
    • Mybatis 源码剖析
    • Mybatis-Plus
    • Spring Data JPA
    • Spring 高级使用
    • Spring 源码剖析
    • SpringBoot 高级使用
    • SpringBoot 源码剖析
    • Jdk 解析
    • Tomcat 架构设计&源码剖析
    • Tomcat Web应用服务器
    • Zookeeper 高级
    • Netty
  • 微服务框架

    • 分布式原理
    • 分布式集群架构场景化解决方案
    • Dubbo 高级使用
    • Dubbo 核心源码剖析
    • Spring Cloud Gateway
    • Nacos 实战应用
    • Sentinel 实战应用
    • Seata 分布式事务
  • 数据结构和算法的深入应用
  • 存储

    • 图和Neo4j
    • MongoDB
    • TiDB
    • MySQL 优化
    • MySQL 平滑扩容实战
    • MySQL 海量数据存储与优化
    • Elasticsearch
  • 缓存

    • Redis
    • Aerospike
    • Guava Cache
    • Tair
  • 文件存储

    • 阿里云 OSS 云存储
    • FastDF 文件存储
  • 基础

    • Linux 使用
    • Nginx 使用与配置
    • OpenResty 使用
    • LVS+Keepalived 高可用部署
    • Jekins
  • 容器技术

    • Docker
    • K8S
    • K8S
  • 01.全链路(APM)
  • 02.电商终极搜索解决方案
  • 03.电商亿级数据库设计
  • 04.大屏实时计算
  • 05.分库分表的深入实战
  • 06.多维系统下单点登录
  • 07.多服务之间分布式事务
  • 08.业务幂等性技术架构体系
  • 09.高并发下的12306优化
  • 10.每秒100W请求的秒杀架构体系
  • 11.集中化日志管理平台的应用
  • 12.数据中台配置中心
  • 13.每天千万级订单的生成背后痛点及技术突破
  • 14.红包雨的架构设计及源码实现
  • 人工智能

    • Python 笔记
    • Python 工具库
    • 人工智能(AI) 笔记
    • 人工智能(AI) 项目笔记
  • 大数据

    • Flink流处理框架
  • 加密区

    • 机器学习(ML) (opens new window)
    • 深度学习(DL) (opens new window)
    • 自然语言处理(NLP) (opens new window)
AI 导航 (opens new window)
  • 谈一谈对CAS的理解
  • Elasticsearch
  • 网络
  • 单点登录
  • 容器
  • 负载均衡
  • Docker
  • Redis
  • Redis
  • IO
  • JDK与Java8
  • Nginx
  • Netty
  • 锁
    • 题目描述
    • 1.面试题分析
    • 2.ReentrantReadWriteLock简介
    • 3.ReentrantReadWriteLock特性
    • 4.ReentrantReadWriteLock的主要成员和结构图
      • 4.1. ReentrantReadWriteLock的继承关系
      • 读写锁 ReadWriteLock
      • 4.2.ReentrantReadWriteLock的核心变量
      • ReentrantReadWriteLock类包含三个核心变量:
      • 4.3.ReentrantReadWriteLock的成员变量和构造函数
    • 5.ReentrantReadWriteLock的核心实现
      • 5.1.读写状态的设计
      • 5.2.写锁的获取与释放
      • 5.3.读锁的获取与释放
      • 5.4.锁降级
      • 5.5.读锁与写锁的整体流程
    • 6.ReentrantReadWriteLock总结
  • 设计模式
  • MySQL
  • 并发编程
  • 数据结构与算法
  • Spring与SpringBoot
  • SpringCloud与Dubbo
  • MyBatis
  • 分布式理论
  • JVM
  • 面试
Revin
2023-07-18
目录

锁

# ReentrantReadWriteLock

# 题目描述

ReentrantReadWriteLock的实现原理与锁获取?

# 1.面试题分析

在有些业务场景中,我们大多在读取数据,很少写入数据,这种情况下,如果仍使用独占锁,效率将及其低下。

针对这种情况,Java提供了读写锁——ReentrantReadWriteLock

有点类似MySQL数据库为代表的读写分离机制,既然我们知道了读写锁是用于读多写少的场景。那问题来了,ReentrantReadWriteLock是怎样来实现的呢,它与ReentrantLock的实现又有什么的区别呢?

# 2.ReentrantReadWriteLock简介

很多情况下有这样一种场景:对共享资源有读和写的操作,且写操作没有读操作那么频繁。

在没有写操作的时候,多个线程同时读一个资源没有任何问题,所以应该允许多个线程同时读取共享资源,但是如果一个线程想去写这些共享资源,就不应该允许其他线程对该资源进行读和写的操作了。

针对这种场景,JAVA的并发包提供了读写锁ReentrantReadWriteLock,它表示两个锁,一个是读操作相关的锁,称为共享锁;一个是写相关的锁,称为排他锁。

# 3.ReentrantReadWriteLock特性

  • 公平性:读写锁支持非公平和公平的锁获取方式,非公平锁的吞吐量优于公平锁的吞吐量,默认构造的是非公平锁

  • 可重入:在线程获取读锁之后能够再次获取读锁,但是不能获取写锁,而线程在获取写锁之后能够再次获取写锁,同时也能获取读锁

  • 锁降级:线程获取写锁之后获取读锁,再释放写锁,这样实现了写锁变为读锁,也叫锁降级

# 4.ReentrantReadWriteLock的主要成员和结构图

# 4.1. ReentrantReadWriteLock的继承关系

WM_ReentrantReadWriteLock的实现原理与锁获取_Page2_1

public interface ReadWriteLock {
  /**
  * Returns the lock used for reading.
  *
  * @return the lock used for reading.
  */
  Lock readLock();
  /**
  * Returns the lock used for writing.
  *
  * @return the lock used for writing.
  */
  Lock writeLock();
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

# 读写锁 ReadWriteLock

读写锁维护了一对相关的锁,一个用于只读操作,一个用于写入操作。

只要没有写入,读取锁可以由多个读线程同时保持,写入锁是独占的。

# 4.2.ReentrantReadWriteLock的核心变量

WM_ReentrantReadWriteLock的实现原理与锁获取_Page3_1

# ReentrantReadWriteLock类包含三个核心变量:

  1. ReaderLock:读锁,实现了Lock接口
  2. WriterLock:写锁,也实现了Lock接口
  3. Sync:继承自AbstractQueuedSynchronize(AQS),可以为公平锁FairSync 或 非公平锁

NonfairSync

# 4.3.ReentrantReadWriteLock的成员变量和构造函数

/** 内部提供的读锁 */
  private final ReentrantReadWriteLock.ReadLock readerLock;
  /** 内部提供的写锁 */
  private final ReentrantReadWriteLock.WriteLock writerLock;
  /** AQS来实现的同步器 */
  final Sync sync;
  /**
  * Creates a new {@code ReentrantReadWriteLock} with
  * 默认创建非公平的读写锁
  */
  public ReentrantReadWriteLock() {
    this(false);
 }
  /**
  * Creates a new {@code ReentrantReadWriteLock} with
  * the given fairness policy.
  *
  * @param fair {@code true} if this lock should use a fair ordering policy
  */
  public ReentrantReadWriteLock(boolean fair) {
    sync = fair ? new FairSync() : new NonfairSync();
    readerLock = new ReadLock(this);
    writerLock = new WriteLock(this);
 }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

# 5.ReentrantReadWriteLock的核心实现

ReentrantReadWriteLock实现关键点,主要包括:

  • 读写状态的设计
  • 写锁的获取与释放
  • 读锁的获取与释放
  • 锁降级

# 5.1.读写状态的设计

之前谈ReentrantLock的时候,Sync类是继承于AQS,主要以int state为线程锁状态,0表示没有被线程占用,1表示已经有线程占用。

同样ReentrantReadWriteLock也是继承于AQS来实现同步,那int state怎样同时来区分读锁和写锁的?

如果在一个整型变量上维护多种状态,就一定需要“按位切割使用”这个变量,

ReentrantReadWriteLock将int类型的state将变量切割成两部分:

  • 高16位记录读锁状态
  • 低16位记录写锁状态

img

abstract static class Sync extends AbstractQueuedSynchronizer {
  // 版本序列号
  private static final long serialVersionUID = 6317671515068378041L;    
  // 高16位为读锁,低16位为写锁
  static final int SHARED_SHIFT  = 16;
  // 读锁单位
  static final int SHARED_UNIT   = (1 << SHARED_SHIFT);
  // 读锁最大数量
  static final int MAX_COUNT    = (1 << SHARED_SHIFT) - 1;
  // 写锁最大数量
  static final int EXCLUSIVE_MASK = (1 << SHARED_SHIFT) - 1;
  // 本地线程计数器
  private transient ThreadLocalHoldCounter readHolds;
  // 缓存的计数器
  private transient HoldCounter cachedHoldCounter;
  // 第一个读线程
  private transient Thread firstReader = null;
  // 第一个读线程的计数
  private transient int firstReaderHoldCount;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

# 5.2.写锁的获取与释放

protected final boolean tryAcquire(int acquires) {
      /*
      * Walkthrough:
      * 1. If read count nonzero or write count nonzero
      *  and owner is a different thread, fail.
      * 2. If count would saturate, fail. (This can only
      *  happen if count is already nonzero.)
      * 3. Otherwise, this thread is eligible for lock if
      *  it is either a reentrant acquire or
      *  queue policy allows it. If so, update state
      *  and set owner.
      */
      Thread current = Thread.currentThread();
      int c = getState();
      //获取独占锁(写锁)的被获取的数量
      int w = exclusiveCount(c);
      if (c != 0) {
        // (Note: if c != 0 and w == 0 then shared count != 0)
        //1.如果同步状态不为0,且写状态为0,则表示当前同步状态被读锁获取
        //2.或者当前拥有写锁的线程不是当前线程
        if (w == 0 || current != getExclusiveOwnerThread())
          return false;
        if (w + exclusiveCount(acquires) > MAX_COUNT)
          throw new Error("Maximum lock count exceeded");
        // Reentrant acquire
        setState(c + acquires);
        return true;
     }
      if (writerShouldBlock() ||
        !compareAndSetState(c, c + acquires))
        return false;
      setExclusiveOwnerThread(current);
      return true;
   }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

1)c是获取当前锁状态,w是获取写锁的状态。

2)如果锁状态不为零,而写锁的状态为0,则表示读锁状态不为0,所以当前线程不能获取写锁。或者锁状态不为零,而写锁的状态也不为0,但是获取写锁的线程不是当前线程,则当前线程不能获取写锁。

3)写锁是一个可重入的排它锁,在获取同步状态时,增加了一个读锁是否存在的判断。

写锁的释放与ReentrantLock的释放过程类似,每次释放将写状态减1,直到写状态为0时,才表示该写锁被释放了。

# 5.3.读锁的获取与释放

protected final int tryAcquireShared(int unused) {
  for(;;) {
    int c = getState();
    int nextc = c + (1<<16);
    if(nextc < c) {
     throw new Error("Maxumum lock count exceeded");
   }
    if(exclusiveCount(c)!=0 && owner != Thread.currentThread())
     return -1;
    if(compareAndSetState(c,nextc))
     return 1;
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13

1)读锁是一个支持重进入的共享锁,可以被多个线程同时获取。

2)在没有写状态为0时,读锁总会被成功获取,而所做的也只是增加读状态(线程安全)

3)读状态是所有线程获取读锁次数的总和,而每个线程各自获取读锁的次数只能选择保存在

ThreadLocal中,由线程自身维护。

读锁的每次释放均减小状态(线程安全的,可能有多个读线程同时释放锁),减小的值是1<<16。

# 5.4.锁降级

降级是指当前把持住写锁,再获取到读锁,随后释放(先前拥有的)写锁的过程。

锁降级过程中的读锁的获取是否有必要,答案是必要的。主要是为了保证数据的可见性,如果当前线程不获取读锁而直接释放写锁,假设此刻另一个线程获取的写锁,并修改了数据,那么当前线程就步伐感知到线程T的数据更新,如果当前线程遵循锁降级的步骤,那么线程T将会被阻塞,直到当前线程使数据并释放读锁之后,线程T才能获取写锁进行数据更新。

# 5.5.读锁与写锁的整体流程

WM_ReentrantReadWriteLock的实现原理与锁获取_Page7_1

# 6.ReentrantReadWriteLock总结

本篇详细介绍了ReentrantReadWriteLock的特征、实现、锁的获取过程,通过4个关键点的核心设计:

  • 读写状态的设计
  • 写锁的获取与释放
  • 读锁的获取与释放
  • 锁降级

从而才能实现:共享资源有读和写的操作,且写操作没有读操作那么频繁的应用场景。

上次更新: 2025/04/03, 11:07:08
Netty
设计模式

← Netty 设计模式→

最近更新
01
tailwindcss
03-26
02
PaddleSpeech
02-18
03
whisper
02-18
更多文章>
Theme by Vdoing | Copyright © 2019-2025 跨境互联网 | 豫ICP备14016603号-5 | 豫公网安备41090002410995号
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式