1. ReadWriteLock(读写锁):实现高性能缓存

总结:

要点

内容

适用场景

读多写少、高并发读取场景(如缓存)

锁类型

ReadWriteLock接口,ReentrantReadWriteLock实现

读锁 vs 写锁

多线程可同时读,写独占

按需加载中的“二次检查”

避免重复查询数据库

锁升级

❌ 不支持

锁降级

✅ 支持(写锁降为读锁)

数据一致性

可采用超时失效、Binlog 推送或双写策略

1.1. 读写锁的概念

并发优化的场景:读多写少

  • 实际开发中,缓存常用于提升性能(比如缓存元数据、基础数据)
  • 这类数据 读取频繁、写入稀少,典型读多写少

常规锁(互斥锁)的限制

  • synchronizedReentrantLock 会限制所有线程串行访问,即便是多个读取操作
  • 性能瓶颈:多个读线程也互相阻塞

ReadWriteLock的基本规则:

  1. 允许多个线程同时读共享变量;
  2. 只允许一个线程写共享变量;
  3. 如果一个写线程正在执行写操作,此时禁止读线程读共享变量。

Java 实现类:

  • 接口:ReadWriteLock
  • 实现:ReentrantReadWriteLock(支持可重入)

1.2. 封装线程安全的缓存类

示例:Cache<K, V> 类(线程安全)


class Cache<K,V> {final Map<K, V> m = new HashMap<>();final ReadWriteLock rwl = new ReentrantReadWriteLock();final Lock r = rwl.readLock();final Lock w = rwl.writeLock();V get(K key) {r.lock();try { return m.get(key); }finally { r.unlock(); }}V put(String key, Data v) {w.lock();try { return m.put(key, v); }finally { w.unlock(); }}
}

缓存数据的加载策略

1. 一次性加载(适合数据量小)

  • 程序启动时从源头加载所有数据,调用 put() 写入缓存
  • 简单易行,示意图如下:

2. 按需加载(懒加载,适合数据量大)

原理:

  • 查询缓存时,如果缓存中没有数据,则从源头加载并更新缓存

实现逻辑(含二次检查):

V get(K key) {
V v = null;
r.lock();                    // ① 获取读锁
try { v = m.get(key); }      // ② 尝试从缓存读取
finally { r.unlock(); }      // ③ 释放读锁if (v != null) return v;     // ④ 缓存命中w.lock();                    // ⑤ 获取写锁
try {v = m.get(key);            // ⑥ 再次检查if (v == null) {v = 查询数据库();         // ⑦ 查询源数据m.put(key, v);           // 写入缓存}
} finally {w.unlock();                // 释放写锁
}
return v;
}

为什么要“再次验证”?

  • 防止多个线程同时 miss 缓存,导致重复数据库查询(读写锁是排他的)

1.3. 读写锁的升级与降级

1. 不支持锁的升级

不允许持有读锁时再获取写锁(会死锁)

错误代码示例:

r.lock();
try {if (m.get(key) == null) {w.lock(); // ❌ 升级为写锁,阻塞try { m.put(key, 查询数据库()); }finally { w.unlock(); }}
} finally {r.unlock(); // 死锁
}

2. 支持锁的降级

持有写锁时,可以先获取读锁,再释放写锁

w.lock();         // 写锁
try {if (!cacheValid) {data = 查询数据();cacheValid = true;r.lock();     // 降级为读锁}
} finally {w.unlock();     // 释放写锁
}try {use(data);      // 仍持有读锁
} finally {r.unlock();     // 释放读锁
}

补充:缓存一致性问题及解决方案

常见解决方式:

方式

描述

超时失效机制

每条缓存数据设定有效期,到期重新加载

Binlog 同步

数据库变更触发缓存更新(如 MySQL Binlog)

数据双写

同时写入缓存和数据库(需解决一致性问题)

2. StampedLock(比读写锁更快)

  • StampedLock 提供 写锁、悲观读锁、乐观读 三种模式;
  • 乐观读是 无锁读取 + 校验机制,适合读多写少;
  • stamp 类似数据库中的 version,用于一致性验证;
  • 不支持重入、不支持条件变量、不支持中断;
  • 使用不当可能造成 CPU 飙升问题。

2.1. StampedLock的概念

背景与作用

  • 传统读写锁(ReadWriteLock):适用于“读多写少”的场景,支持多个线程并发读,但写操作会阻塞所有读操作。
  • StampedLock(JDK 1.8 新增)
    • 提供更高性能的读写控制机制;
    • 特别适合读多写少场景;
    • 支持 三种锁模式,引入了性能更优的“乐观读

StampedLock的三种锁模式:

锁类型

特点

互斥性

适用场景

写锁

和写锁类似

与所有其他锁互斥

修改共享数据

悲观读锁

与 ReadLock 类似,可多个线程同时持有

与写锁互斥

读取共享数据(有一定写的可能性)

乐观读

无锁!性能最好

可与写锁并发(需校验)

读取频繁,修改极少场景

  • 加锁后都会返回一个 stamp,释放锁时需要传入。

代码示例:

final StampedLock sl = new StampedLock();// 悲观读锁
long stamp = sl.readLock();
try {// 读取操作
} finally {sl.unlockRead(stamp);
}// 写锁
long stamp = sl.writeLock();
try {// 写操作
} finally {sl.unlockWrite(stamp);
}

2.2. 乐观读原理与用法

乐观读流程:

  1. 调用 tryOptimisticRead() 获取 stamp;
  2. 读取共享变量到局部变量(期间数据可能被其他线程写操作修改!);
  3. 通过 validate(stamp) 判断是否有写操作发生;
    • 若返回 true,说明无写操作,读取有效;
    • 若返回 false,则需“升级为悲观读锁”。

示例代码:

long stamp = sl.tryOptimisticRead();
int curX = x, curY = y;
if (!sl.validate(stamp)) {stamp = sl.readLock(); // 升级为悲观读try {curX = x;curY = y;} finally {sl.unlockRead(stamp);}
}
return Math.sqrt(curX * curX + curY * curY);

为什么比 ReadWriteLock 更快?

  • 乐观读无锁,不阻塞写操作;
  • 只有在检测到写入发生时,才升级为悲观读,大大减少了锁竞争和阻塞

使用注意事项

注意点

说明

❌ 不支持重入

StampedLock不是可重入锁(不可 Reentrant)

❌ 不支持条件变量

不能用 await/signal等 等待通知机制

❌ 不支持中断

调用 interrupt()可能导致 CPU 飙升至 100%,应避免

对比数据库乐观锁

  • 数据库中通过 version 字段实现乐观锁控制;
  • 读取时返回 version,更新时用 where version=旧值 控制;
  • 与 StampedLock 的 stamp 机制非常相似,便于理解乐观读校验的本质。

2.3. 使用模板

1. 读操作模板:

long stamp = sl.tryOptimisticRead();
// 读取局部变量
...
if (!sl.validate(stamp)) {stamp = sl.readLock();try {...} finally {sl.unlockRead(stamp);}
}// 使用局部变量...

2. 写操作模板:

long stamp = sl.writeLock();
try {// 修改共享变量...
} finally {sl.unlockWrite(stamp);
}

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

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

相关文章

【决胜公务员考试】求职OMG——见面课测验1

2025最新版&#xff01;&#xff01;&#xff01;6.8截至答题&#xff0c;大家注意呀&#xff01; 博主码字不易点个关注吧,祝期末顺利~~ 1.单选题(2分) 下列说法错误的是:&#xff08; B &#xff09; A.选调生属于公务员系统 B.公务员属于事业编 C.选调生有基层锻炼的要求 D…

vue3 el-button 自定义本地图标

设置不生效的原因可能有&#xff1a;1.style标签里没加scoped <style scoped></style>2.本地图片路径指向错误3.自定义图片长宽没设置4.deep深度选择器使用错误&#xff0c;vue3用:deep() <el-tooltip content"重新匹配" placement"top"&g…

如何在最短时间内提升打ctf(web)的水平?

刚刚刷完2遍 bugku 的 web 题&#xff0c;前来答题。 每个人对刷题理解是不同&#xff0c;有的人是看了writeup就等于刷了&#xff0c;有的人是收藏了writeup就等于刷了&#xff0c;有的人是跟着writeup做了一遍就等于刷了&#xff0c;还有的人是独立思考做了一遍就等于刷了。…

6.8 note

paxos算法_初步感知 Paxos算法保证一致性主要通过以下几个关键步骤和机制&#xff1a; 准备阶段 - 提议者向所有接受者发送准备请求&#xff0c;请求中包含一个唯一的编号。 - 接受者收到请求后&#xff0c;会检查编号&#xff0c;如果编号比它之前见过的都大&#xff0c;就会承…

c++ openssl 使用 DES(数据加密标准)进行加密和解密的基本操作

使用 DES&#xff08;数据加密标准&#xff09;进行加密和解密的基本操作&#xff0c;重点展示了 ECB 和 CBC 模式&#xff0c;并且通过篡改密文的方式来进行攻击。下面是对每个部分的详细解析。 1. 结构体 Slip struct Slip {char from[16] { 0 }; // 交易的发起者&#x…

OpenWrt:使用ALSA实现边录边播

ALSA是Linux系统中的高级音频架构&#xff08;Advanced Linux Sound Architecture&#xff09;。目前已经成为了linux的主流音频体系结构&#xff0c;想了解更多的关于ALSA的知识&#xff0c;详见&#xff1a;http://www.alsa-project.org 在内核设备驱动层&#xff0c;ALSA提供…

【.net core】天地图坐标转换为高德地图坐标(WGS84 坐标转 GCJ02 坐标)

类文件 public static class WGS84ToGCJ02Helper {// 定义一些常量private const double PI 3.14159265358979324;private const double A 6378245.0;private const double EE 0.00669342162296594323;// 判断坐标是否在中国范围内&#xff08;不在国内则不进行转换&#x…

Matlab自学笔记五十七:符号运算、可变精度运算、双精度浮点型运算,三种运算精度的概念、比较、选择和应用

1.可变精度算术的概念 默认的&#xff0c;Matlab双精度浮点数使用16位数字精度&#xff0c;而符号数学工具箱的vpa函数&#xff0c;提供了无限大的可变精度&#xff0c;它默认使用32位数字精度&#xff0c;32位指的是有效数字的位数&#xff1b; 2.具体用法 程序示例&#x…

由汇编代码确定switch语句

int switch2(int x) {int result0;switch(x){/* switch语句主体缺失 */}return result; }在编译函数时&#xff0c;GCC为程序的初始部分以及跳转表生成了如下汇编代码。 1 MOVL 8(%ebp), %eax ;x位于相对于寄存器%ebp偏移量为8的地方。 2 ADDL $2, %eax …

java 使用HanLP 入门教程

1. 安装 HanLP Maven 依赖 <dependency><groupId>com.hankcs</groupId><artifactId>hanlp</artifactId><version>portable-1.8.4</version> <!-- 最新版本请查看官网 --> </dependency>注意&#xff1a;portable 版本…

vm虚拟机添加虚拟机无反应,获取所有权

问题描述 虚拟机忘记关机&#xff0c;就把电脑关了&#xff0c;早上打开用不了了&#xff0c;重新添加&#xff0c;也没反应&#xff0c;获取所有权后就没了 问题解决 将虚拟机文件目录下的.lck文件夹&#xff0c;删除&#xff0c;或者改个名&#xff0c;我是改为了.backup方…

为何选择Spring框架学习设计模式与编码技巧?

&#x1f4cc; 结论先行 推荐项目&#xff1a;Spring Framework 推荐理由&#xff1a;设计模式覆盖全面 编码技巧教科书级实现 Java 生态基石地位 &#x1f3c6; 三维度对比分析 维度SpringMyBatisXXL-JOB设计模式⭐⭐⭐⭐⭐⭐⭐⭐⭐⭐代码抽象⭐⭐⭐⭐⭐⭐⭐⭐⭐⭐生态价…

MySQL 索引:聚集索引与二级索引

在数据库性能优化的征途中&#xff0c;索引无疑扮演着至关重要的角色。正确理解和使用索引&#xff0c;能够显著提升查询效率&#xff0c;为应用带来丝滑般的操作体验。今天&#xff0c;我们将深入 MySQL 的心脏&#xff0c;重点探讨 InnoDB 存储引擎中两种核心的索引类型&…

【Elasticsearch】映射:详解 _source store 字段

映射&#xff1a;详解 _source & store 字段 1._source 字段1.1 特点1.2 示例 2.store 字段2.1 特点2.2 示例 3.两者对比3.1 使用建议3.2 实际应用示例 1._source 字段 _source 是 Elasticsearch 中一个特殊的元字段&#xff0c;它存储了文档在索引时的原始 JSON 内容。 …

新建网站部署流程

1. 新建 Node 服务&#xff0c;指定端口并代理前端静态资源 操作步骤&#xff1a; 初始化 Node 项目mkdir my-website && cd my-website npm init -y npm install express创建 app.js&#xff08;示例代码&#xff09;const express require(express); const app e…

时序数据库IoTDB结合SeaTunnel实现高效数据同步

益、基本概念介绍 1.1 Apache IoTDB Apache IoTDB是一款专为工业物联网设计的时序数据库管理系统&#xff0c;集数据收集、存储、管理与分析于一体&#xff0c;满足海量数据存储、高速读取及复杂数据分析需求。其架构包括时序文件&#xff08;TsFile&#xff09;、数据库引擎…

k8s业务程序联调工具-KtConnect

概述 原理 工具作用是建立了一个从本地到集群的单向VPN&#xff0c;根据VPN原理&#xff0c;打通两个内网必然需要借助一个公共中继节点&#xff0c;ktconnect工具巧妙的利用k8s原生的portforward能力&#xff0c;简化了建立连接的过程&#xff0c;apiserver间接起到了中继节…

RFID推动新能源汽车零部件生产系统管理应用案例

RFID推动新能源汽车零部件生产系统管理应用案例 一、项目背景 新能源汽车零部件场景 在新能源汽车零部件生产领域&#xff0c;电子冷却水泵等关键部件的装配溯源需求日益增长。传统 RFID 溯源方案采用 “网关 RFID 读写头” 模式&#xff0c;存在单点位单独头溯源、网关布线…

C#封装HttpClient:HTTP请求处理最佳实践

C#封装HttpClient&#xff1a;HTTP请求处理最佳实践 在现代的.NET应用程序开发中&#xff0c;与外部服务进行HTTP通信是一项常见需求。HttpClient作为.NET框架中处理HTTP请求的核心组件&#xff0c;为我们提供了强大而灵活的API。然而&#xff0c;直接使用原生的HttpClient可能…

【Redis/2】核心特性、应用场景与安装配置

文章目录 一、初识 Redis1.1 Redis 概述1. Redis 简介2. Redis 的发展历程 1.2 Redis 核心特性1. 高性能2. 丰富的数据类型3. 持久化4. 原子操作5. 主从复制6. 高可用性与分布式7. 内存存储与低延迟8. 灵活的过期策略9. 事务支持10. 简单的 API总结 1.3 Redis 应用场景Redis 适…