ReentrantReadWriteLock详解

小灰灰 2022-11-11 13:13 131阅读 0赞

> ReentrantReadWriteLock 是读写锁，和ReentrantLock会有所不同，对于读多写少的场景使用ReentrantReadWriteLock 性能会比ReentrantLock高出不少。在多线程读时互不影响，不像ReentrantLock即使是多线程读也需要每个线程获取锁。不过任何一个线程在写的时候就和ReentrantLock类似，其他线程无论读还是写都必须获取锁。需要注意的是同一个线程可以拥有 writeLock 与 readLock (但必须先获取 writeLock 再获取 readLock, 反过来进行获取会导致死锁)

## 类结构 ##

![在这里插入图片描述][20210320154258458.png]

## 核心方法 ##

ReentrantReadWriteLock 实现了 ReadWriteLock接口，ReadWriteLock接口只有两个核心方法

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70]  
获取读锁或者获取写锁

## 构造函数 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70 1]  
默认不传参，代表非公平锁，可以看到里面是初始化了两把锁，一个readerLock读锁，一个writerLock写锁。很符合多线程编码优化原则，尽量减少锁粒度

## 简单的使用 ##

private static final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    
        public static void main(String[] args) { 
            Integer test = 2;
            ExecutorService threadPool = Executors.newFixedThreadPool(10);
    
    
            for (int i = 0; i < 3; i++) { 
                threadPool.execute(() -> { 
                    try { 
                        readWriteLock.writeLock().lockInterruptibly();
                        System.out.println("写入数据" + test);
                        // 假装耗时操作
                        TimeUnit.SECONDS.sleep(5);
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    } finally { 
                        readWriteLock.writeLock().unlock();
                    }
                });
            }
            for (int i = 0; i < 20; i++) { 
                threadPool.execute(() -> { 
                    try { 
                        readWriteLock.readLock().lockInterruptibly();
                        System.out.println("读取数据" + test);
                        // 假装耗时操作
                        TimeUnit.SECONDS.sleep(5);
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    } finally { 
                        readWriteLock.readLock().unlock();
                    }
                });
            }
        }

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70 2]  
自己运行会发现 在运行写数据是串行的，每次写入数据都需要等待3秒，而读数据则是瞬间10个线程一起读取的

[20210320154258458.png]: /images/20221022/f517503e11934df38dd64ee6d86ba84d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70]: /images/20221022/d33f6022284d4123aa80a0b0f82df5a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70 1]: /images/20221022/7e37e10b799b45c3b20219975a8dfbb6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/2021032016382289.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0,size_16,color_FFFFFF,t_70