读写锁: ReentrantReadWriteLock

在多线程编程中，怎样高效地管理对共享资源的并发访问是一个关键题目。Java 提供了多种同步机制来办理这个题目，此中 ReentrantReadWriteLock 是一种特殊恰当读多写少场景下的锁机制。它答应多个读线程同时访问资源，但在有写线程时会制止其他全部线程（包罗读和写）的访问，从而进步了吞吐量。本文将具体先容 ReentrantReadWriteLock 的工作原理，并通过现实案例演示其在项目中的应用。
什么是 ReentrantReadWriteLock？

ReentrantReadWriteLock 是 Java 并发包 (java.util.concurrent.locks) 中提供的一种读写锁实现。它分为两种模式：

• 读锁：答应多个读线程并发地读取共享资源。
  
• 写锁：确保同一时间只有一个写线程可以或许修改资源，且在写利用期间克制任何读或写线程的访问。
  

这种筹划使得在高读低写的场景下，可以明显提拔体系的性能，由于大多数环境下，多个线程可以同时举行只读利用，而不必要相互壅闭。
紧张特性

• 重入性：支持同一个线程多次获取类似范例的锁（即读锁或写锁），而且必须按次序开释相应次数的锁。
  
• 公平性计谋：可以选择是否启用公平锁模式，以决定是优先处理惩罚等候时间最长的哀求还是按照先辈先出的原则分配锁。
  
• 可停止：读锁和写锁都提供了可停止的方法，答应等候获取锁的线程相应停止信号。
  
• 超时实验：可以设置一个最大等候时间来实验获取锁，假如凌驾该时间则放弃实验。
  

使用 ReentrantReadWriteLock

ReentrantReadWriteLock 通常用于以下几种环境：

• 当读利用远多于写利用时，使用读写锁可以进步体系性能。
  
• 对缓存数据布局的利用，如 Map 或 List，当必要包管线程安全的同时又盼望尽大概淘汰锁竞争。
  
• 文件读写利用，尤其是那些频仍读取但偶然更新的环境。
  

根本用法

2. import java.util.concurrent.locks.ReentrantReadWriteLock;
4. public class Cache {
5.     private final ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
6.     private final Lock readLock = rwl.readLock();
7.     private final Lock writeLock = rwl.writeLock();
8.     private volatile Object data;
10.     public Object read() {
11.         readLock.lock();
12.         try {
13.             return data;
14.         } finally {
15.             readLock.unlock();
16.         }
17.     }
19.     public void write(Object newData) {
20.         writeLock.lock();
21.         try {
22.             data = newData;
23.         } finally {
24.             writeLock.unlock();
25.         }
26.     }
27. }

复制代码

在这个例子中，我们创建了一个简单的缓存类 Cache，它包罗两个方法 read() 和 write() 分别用于读取和更新缓存的数据。通过使用 ReentrantReadWriteLock，我们可以让多个线程同时读取缓存，但在写入时独占访问权限，确保数据的划一性。


进阶用法

公平锁 vs 非公平锁

默认环境下，ReentrantReadWriteLock 黑白公平的，意味着它不会依照严酷的 FIFO 列队规则。假如你的应用场景要求较高的相应性和较低的耽误，那么非公平锁大概是更好的选择；相反，假如更关心公平性和制止饥饿征象，则可以思量使用公平锁。

2. // 创建一个公平的读写锁
3. ReentrantReadWriteLock fairLock = new ReentrantReadWriteLock(true);

复制代码

实验获取锁

偶然候你大概不想不停等候获取锁，而是盼望在一段时间后主动放弃。这时可以使用 tryLock() 方法，并指定一个超时时间。假如乐成获取到锁，则返回 true；否则返回 false。

2. if (writeLock.tryLock(10, TimeUnit.SECONDS)) {
3.     try {
4.         // 成功获取写锁后的代码
5.     } finally {
6.         writeLock.unlock();
7.     }
8. } else {
9.     // 获取写锁失败后的处理逻辑
10. }

复制代码

可停止锁

除了超时外，还可以使等候获取锁的线程相应停止信号。这对于长时间持有锁的任务尤其有用，由于它可以资助防止死锁或其他不可规复的状态。

2. writeLock.lockInterruptibly();
3. try {
4.     // 写入操作
5. } catch (InterruptedException e) {
6.     Thread.currentThread().interrupt(); // 保留中断状态
7. } finally {
8.     if (writeLock.isHeldByCurrentThread()) {
9.         writeLock.unlock();
10.     }
11. }

复制代码

实战案例 - 线程安全的缓存实现

假设我们要构建一个线程安全的缓存体系，它可以存储键值对，并支持高效的读取和更新利用。我们将使用 ReentrantReadWriteLock 来掩护共享的缓存数据布局。

2. import java.util.Map;
3. import java.util.concurrent.ConcurrentHashMap;
4. import java.util.concurrent.locks.ReentrantReadWriteLock;
6. public class SafeCache<K, V> {
7.     private final Map<K, V> cache = new ConcurrentHashMap<>();
8.     private final ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
10.     public V get(K key) {
11.         rwl.readLock().lock();
12.         try {
13.             return cache.get(key);
14.         } finally {
15.             rwl.readLock().unlock();
16.         }
17.     }
19.     public void put(K key, V value) {
20.         rwl.writeLock().lock();
21.         try {
22.             cache.put(key, value);
23.         } finally {
24.             rwl.writeLock().unlock();
25.         }
26.     }
28.     public void remove(K key) {
29.         rwl.writeLock().lock();
30.         try {
31.             cache.remove(key);
32.         } finally {
33.             rwl.writeLock().unlock();
34.         }
35.     }
36. }

复制代码

在这个例子中，SafeCache 类内部维护了一个 ConcurrentHashMap 作为底层的数据布局，并通过 ReentrantReadWriteLock 来控制对它的访问。读取利用只必要获取读锁，因此可以在多个线程之间并发实行；而写入和删除利用则必要获取写锁，确保同一时候只有一个线程可以或许修改缓存内容。


注意事项

只管 ReentrantReadWriteLock 提供了很多上风，但在现实应用中也必要注意以下几点：

• 过分使用：不要滥用读写锁，尤其是在写利用频仍大概写利用自己非常耗时的环境下，这大概会导致严肃的性能瓶颈。
  
• 死锁风险：当多个线程试图获取差别次序的锁时，轻易引发死锁题目。因此，在筹划步调时应只管保持划一的加锁次序。
  
• 性能评估：固然理论上读写锁比独占锁更高效，但在某些特定条件下（比方读写比例靠近 1:1），它的性能大概不如预期。因此，发起根据现实环境举行基准测试，以确定最佳方案。
  

结语

感谢您的阅读！假如您对 ReentrantReadWriteLock 或其他并发编程话题有任何疑问或见解，欢迎继续探究。