Java中的ReentrantReadWriteLock使用詳解

更新時間：2023年11月01日 10:56:24 作者：興趣使然的程序猿

這篇文章主要介紹了Java中的ReentrantReadWriteLock使用詳解,ReentrantReadWriteLock是Java中的一個鎖實現(xiàn),它提供了讀寫分離的功能,這種讀寫分離的機制可以提高并發(fā)性能,特別適用于讀多寫少的場景,需要的朋友可以參考下

ReentrantReadWriteLock

ReadWriteLock即讀寫鎖,ReadWriteLock的規(guī)則如下。

a.當有線程獲取了Write鎖時，其他線程不能獲取到任何鎖（寫鎖和讀鎖都不能。

b.當沒有線程獲取Wrete鎖時，所有線程都可以獲取Read鎖。

c.當有Read鎖存在時，獲取不到Write鎖。

1 ReentrantReadWriteLock實現(xiàn)類繼承關系

ReentrantReadWriteLock實現(xiàn)類繼承關系

可見該類實現(xiàn)了ReadWriteLock接口。

2 ReentrantReadWriteLock使用

創(chuàng)建一個讀寫鎖。

static ReadWriteLock lock = new ReentrantReadWriteLock();

獲取寫鎖。

lock.writeLock().lock();

釋放寫鎖。

lock.writeLock().unlock();

獲取讀鎖。

lock.readLock().lock();

釋放讀鎖。

lock.readLock().unlock();

3 ReentrantReadWriteLock使用實例

該實例測試的是上邊的規(guī)則c——當有Read鎖存在時，獲取不到Write鎖。

讓一個線程先獲取到讀鎖并持有5秒鐘。

這是其他線程嘗試去獲取寫鎖，發(fā)現(xiàn)5秒之后其他線程再開始寫入然后在控制臺打印出結(jié)果。

class ReadWriteLockDemo{
    static ReadWriteLock lock = new ReentrantReadWriteLock();
    static String text = "hello";
    public static void modify(){
        lock.writeLock().lock();
        try {
            System.err.println(Thread.currentThread().getName()+"開始修改");
            text += " "+Thread.currentThread().getName();
        }catch (Exception e){
            e.printStackTrace();
        }
        finally {
            lock.writeLock().unlock();
        }
    }
    public static void readWithReadLock(){
        lock.readLock().lock();
        try {
            System.err.println(text);
            Thread.sleep(5000);
            System.err.println("5秒過去了");
        }catch (Exception e){
        }finally {
            lock.readLock().unlock();
        }
    }
    public static void main(String[] args) throws InterruptedException {
        new Thread(()->{
            readWithReadLock();
        }).start();
        Thread.sleep(1000);
        for (int i=0;i<10;i++) {
            new Thread(() -> {
                modify();
            }).start();
        }
    }
}

讀寫鎖執(zhí)行結(jié)果