1. 读写锁介绍

现实中有这样一种场景:对共享资源有读和写的操作,且写操作没有读操作那么频繁。在没有写操作的时候,多个线程同时读一个资源没有任何问题,所以应该允许多个线程同时读取共享资源;但是如果一个线程想去写这些共享资源,就不应该允许其他线程对该资源进行读和写的操作了。
针对这种场景, JAVA 的并发包提供了读写锁 ReentrantReadWriteLock,它表示两个锁,一个是读操作相关的锁,称为共享锁;一个是写相关的锁,称为排他锁

  1. 线程进入读锁的前提条件:
    • 没有其他线程的写锁
    • 没有写请求, 或者==有写请求,但调用线程和持有锁的线程是同一个(可重入锁)。 ==

b. 线程进入写锁的前提条件:

  1. - 没有其他线程的读锁
  2. - 没有其他线程的写锁

而读写锁有以下三个重要的特性:
(1)公平选择性:支持非公平(默认)和公平的锁获取方式,吞吐量还是非公平优于公平。
(2)重进入:读锁和写锁都支持线程重进入。
(3)锁降级:遵循获取写锁、获取读锁再释放写锁的次序,写锁能够降级成为读锁。

2. ReentrantReadWriteLock

ReentrantReadWriteLock 类的整体结构

  1. public class ReentrantReadWriteLock implements ReadWriteLock,java.io.Serializable {
  2. /** 读锁 */
  3. private final ReentrantReadWriteLock.ReadLock readerLock;
  4. /** 写锁 */
  5. private final ReentrantReadWriteLock.WriteLock writerLock;
  6. final Sync sync;
  7. /** 使用默认(非公平)的排序属性创建一个新的
  8. ReentrantReadWriteLock */
  9. public ReentrantReadWriteLock() {
  10. this(false);
  11. }
  12. /** 使用给定的公平策略创建一个新的 ReentrantReadWriteLock */
  13. public ReentrantReadWriteLock(boolean fair) {
  14. sync = fair ? new FairSync() : new NonfairSync();
  15. readerLock = new ReadLock(this);
  16. writerLock = new WriteLock(this);
  17. }
  18. /** 返回用于写入操作的锁 */
  19. public ReentrantReadWriteLock.WriteLock writeLock() {
  20. return writerLock;
  21. }
  22. /** 返回用于读取操作的锁 */
  23. public ReentrantReadWriteLock.ReadLock readLock() {
  24. return readerLock;
  25. }
  26. abstract static class Sync extends AbstractQueuedSynchronizer {}
  27. static final class NonfairSync extends Sync {}
  28. static final class FairSync extends Sync {}
  29. public static class ReadLock implements Lock, java.io.Serializable {}
  30. public static class WriteLock implements Lock, java.io.Serializable {}
  31. }

可以看到, ReentrantReadWriteLock 实现了 ReadWriteLock 接口,ReadWriteLock 接口定义了获取读锁和写锁的规范,具体需要实现类去实现;同时其还实现了 Serializable 接口,表示可以进行序列化,在源代码中可以看到 ReentrantReadWriteLock 实现了自己的序列化逻辑。

3. 入门案例

场景: 使用 ReentrantReadWriteLock 对一个 hashmap 进行读和写操作

3.1 实现案例

  1. //资源类
  2. class MyCache {
  3. //创建 map 集合
  4. private volatile Map<String,Object> map = new HashMap<>();
  5. //创建读写锁对象
  6. private ReadWriteLock rwLock = new ReentrantReadWriteLock();
  7. //放数据
  8. public void put(String key,Object value) {
  9. //添加写锁
  10. rwLock.writeLock().lock();
  11. try {
  12. System.out.println(Thread.currentThread().getName()+""+key);
  13. //暂停一会
  14. TimeUnit.MICROSECONDS.sleep(300);
  15. //放数据
  16. map.put(key,value);
  17. System.out.println(Thread.currentThread().getName()+""+key);
  18. } catch (InterruptedException e) {
  19. e.printStackTrace();
  20. } finally {
  21. //释放写锁
  22. rwLock.writeLock().unlock();
  23. }
  24. }
  25. //取数据
  26. public Object get(String key) {
  27. //添加读锁
  28. rwLock.readLock().lock();
  29. Object result = null;
  30. try {
  31. System.out.println(Thread.currentThread().getName()+""+key);
  32. //暂停一会
  33. TimeUnit.MICROSECONDS.sleep(300);
  34. result = map.get(key);
  35. System.out.println(Thread.currentThread().getName()+""+key);
  36. } catch (InterruptedException e) {
  37. e.printStackTrace();
  38. } finally {
  39. //释放读锁
  40. rwLock.readLock().unlock();
  41. }
  42. return result;
  43. }
  44. }

4. 小结(重要)

  • 在线程持有读锁的情况下,该线程不能取得写锁(因为获取写锁的时候,如果发现当前的读锁被占用,就马上获取失败,不管读锁是不是被当前线程持有)。
  • 在线程持有写锁的情况下,该线程可以继续获取读锁(获取读锁时如果发现写锁被占用,只有写锁没有被当前线程占用的情况才会获取失败)。

原因: 当线程获取读锁的时候,可能有其他线程同时也在持有读锁,因此不能把获取读锁的线程“升级” 为写锁;而对于获得写锁的线程,它一定独占了读写锁,因此可以继续让它获取读锁,当它同时获取了写锁和读锁后,还可以先释放写锁继续持有读锁,这样一个写锁就“降级” 为了读锁。