突击并发编程JUC系列-ReentrantReadWriteLock
时间:2022-07-26
本文章向大家介绍突击并发编程JUC系列-ReentrantReadWriteLock,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
突击并发编程JUC系列演示代码地址: https://github.com/mtcarpenter/JavaTutorial
本章节将学习 ReentrantReadWriteLock
(读写锁),ReadWriteLock
也是 java 5
之后引入的,之前提到锁(如Mutex
和ReentrantLock
)基本都是排他锁,这些锁在同一时刻只允许一个线程进行访问,而读写锁在同一时刻可以允许多个读线程访问,但是在写线程访问时,所有的读线程和其他写线程均被阻塞。读写锁维护了一对锁,一个读锁和一个写锁,通过分离读锁和写锁,使得并发性相比一般的排他锁有了很大提升。
读写锁的访问约束:
-
读-读不互斥
:读读之间不阻塞 -
读-写互斥
:读堵塞写,写也阻塞读 -
写-写互斥
:写写阻塞
ReadWriteLock
ReentrantReadWriteLock
为ReadWriteLock
接口的实现,ReadWriteLock
仅定义了获取读锁和写锁的两个方法,即readLock()
方法和writeLock()
方法。
public interface ReadWriteLock {
Lock readLock();
Lock writeLock();
}
除了接口方法之外,ReentrantReadWriteLock
还提供了一些便于外界监控其内部工作状态的方法。
-
int getReadLockCount()
: 返回当前读锁被获取的次数。该次数不等于获取读锁的线程数,例如,仅一个线程,他连续获取(重进入)了 n 次读锁,那么占据读锁的线程数是 1 ,但该方法返回 n。 -
int getReadHoldCount()
:返回当前线程获取读锁的次数。该方法在 Java 6 中加入到 ReentrantReadWriteLock 中,使用ThreadLocal
保存当前线程获取次数,这也使得 Java 6 的实现变得更加复杂 -
boolean isWriteLocked()
: 判断写锁是否被获取 -
int getWriteHoldCount()
: 返回当前写锁被获取的次数
ReentrantReadWriteLock
通过 ReentrantReadWriteLock
实现一个简单的缓存,代码示例如下:
public class LockExample3 {
private static final Map<String, Object> map = new HashMap<>();
private static final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
private static final Lock readLock = lock.readLock();
private static final Lock writeLock = lock.writeLock();
/**
* 向 map 存入数据
*
* @param key
* @param value
* @return
*/
public static Object put(String key, Object value) {
writeLock.lock();
try {
return map.put(key, value);
} finally {
writeLock.unlock();
}
}
/**
* 获取单个键值的值
*
* @param key
* @return
*/
public static Object get(String key) {
readLock.lock();
try {
return map.get(key);
} finally {
readLock.unlock();
}
}
/**
* 获取 map 的键值
*
* @return
*/
public static Set<String> getAllKeys() {
readLock.lock();
try {
return map.keySet();
} finally {
readLock.unlock();
}
}
/**
* 清除 map 所有的数据
*/
public static void clear() {
writeLock.lock();
try {
map.clear();
} finally {
writeLock.unlock();
}
}
}
测试代码
public class LockExample3Test {
// 请求总数
public static int requestTotal = 10;
public static void main(String[] args) throws Exception {
ExecutorService executorService = Executors.newCachedThreadPool();
final CountDownLatch countDownLatch = new CountDownLatch(requestTotal);
for (int i = 0; i < requestTotal; i++) {
final String temp = String.valueOf(i);
executorService.execute(() -> {
try {
add(temp);
} catch (Exception e) {
}
countDownLatch.countDown();
});
}
// 等待所有的线程运行完成
countDownLatch.await();
// 多线程获取 key
for (int i = 0; i < requestTotal; i++) {
final String temp = String.valueOf(i);
executorService.execute(() -> {
try {
get(temp);
} catch (Exception e) {
}
});
}
executorService.shutdown();
TimeUnit.SECONDS.sleep(1);
// 获取所有的keys
System.out.println("获取所有的键值t" + LockExample3.getAllKeys());
// 清除所有的 keys
LockExample3.clear();
// 再次获取所有的keys 发现已被清空
System.out.println("获取所有的键值t" + LockExample3.getAllKeys());
}
private static void add(String i) {
LockExample3.put(i, Thread.currentThread().getName());
}
private static void get(String i) {
System.out.println(i + "t" + LockExample3.get(i));
}
}
运行结果如下:
0 pool-1-thread-1
1 pool-1-thread-2
2 pool-1-thread-3
4 pool-1-thread-5
3 pool-1-thread-4
8 pool-1-thread-9
7 pool-1-thread-8
6 pool-1-thread-7
5 pool-1-thread-6
9 pool-1-thread-10
获取所有的键值 [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]
获取所有的键值 []
欢迎关注公众号 山间木匠 , 我是小春哥,从事 Java 后端开发,会一点前端、通过持续输出系列技术文章以文会友,如果本文能为您提供帮助,欢迎大家关注、点赞、分享支持,我们下期再见!
- 海量数据迁移之外部表切分(r2笔记52天)
- 怎样突破表名30个字符的限制(r2笔记51天)
- C/C++——排序
- 关于move tablespace的问题总结(r2笔记50天)
- 一些极度危险的linux命令(r2笔记49天)
- 挑战数据结构与算法面试题——80题全解析(一)
- 关于操作失误的数据修复(r2笔记48天)
- 挑战数据结构与算法面试题——80题全解析(三)
- 巧用rowid简化sql查询(r2笔记47天)
- 算法类面试题解析——美团2016校招:棋子翻转
- 算法类面试题解析——美团2016校招:最大差值
- 用Python进行机器学习小案例
- 启用ODM极速调优IO (r2笔记66天)
- 通过addm分析io问题(r2笔记64天)
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法