Java多線程 ReentrantReadWriteLock原理及實例詳解

更新時間：2019年09月06日 09:30:33 作者：慢慢來

這篇文章主要介紹了Java多線程 ReentrantReadWriteLock原理及實例詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

讀寫鎖ReentrantReadWriteLock概述

讀寫鎖ReentrantReadWriteLock，使用它比ReentrantLock效率更高。

讀寫鎖表示兩個鎖，一個是讀操作相關的鎖，稱為共享鎖；另一個是寫操作相關的鎖，稱為排他鎖。

1、讀和讀之間不互斥，因為讀操作不會有線程安全問題

2、寫和寫之間互斥，避免一個寫操作影響另外一個寫操作，引發(fā)線程安全問題

3、讀和寫之間互斥，避免讀操作的時候寫操作修改了內容，引發(fā)線程安全問題

多個Thread可以同時進行讀取操作，但是同一時刻只允許一個Thread進行寫入操作。

讀操作和讀操作共享

請看例子

ThreadDomain44類和main方法

public class ThreadDomain44 extends ReentrantReadWriteLock
{
  public void read()
  {
    try
    {
      readLock().lock();
      System.out.println(Thread.currentThread().getName() + "獲得了讀鎖, 時間為" +
          System.currentTimeMillis());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      readLock().unlock();
    }
  }
  public static void main(String[] args)
  {
    final ThreadDomain44 td = new ThreadDomain44();
    Runnable readRunnable = new Runnable()
    {
      public void run()
      {
        td.read();
      }
    };
    Thread t0 = new Thread(readRunnable);
    Thread t1 = new Thread(readRunnable);
    t0.start();
    t1.start();
  }
}

輸出結果如下

Thread-0獲得了讀鎖, 時間為1564018325618
Thread-1獲得了讀鎖, 時間為1564018325618

盡管加了Thread.sleep(10000);兩個線程幾乎同時執(zhí)行l(wèi)ock()后面的方法。說明readLock().lock()允許多個線程執(zhí)行并且能提高執(zhí)行效率。

寫操作和寫操作互斥

請看例子

public class ThreadDomain45 extends ReentrantReadWriteLock {
  public void write()
  {
    try
    {
      writeLock().lock();
      System.out.println(Thread.currentThread().getName() + "獲得了寫鎖, 時間為" +
          new Date());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      writeLock().unlock();
    }
  }

  public static void main(String[] args)
  {
    final ThreadDomain45 td = new ThreadDomain45();
    Runnable readRunnable = new Runnable()
    {
      public void run()
      {
        td.write();
      }
    };
    Thread t0 = new Thread(readRunnable);
    Thread t1 = new Thread(readRunnable);
    t0.start();
    t1.start();
  }
}

輸出結果

Thread-1獲得了寫鎖, 時間為Tue Jul 30 11:26:21 CST 2019
Thread-0獲得了寫鎖, 時間為Tue Jul 30 11:26:31 CST 2019

可以看到，后獲得鎖的Thread-0等待了十秒，說明寫和寫互斥

讀操作和寫操作互斥/寫操作和讀操作互斥

例子如下

public class ThreadDomain46 extends ReentrantReadWriteLock {
  public void write()
  {
    try
    {
      writeLock().lock();
      System.out.println(Thread.currentThread().getName() + "獲得了寫鎖, 時間為" +
          new Date());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      writeLock().unlock();
    }
  }

  public void read()
  {
    try
    {
      readLock().lock();
      System.out.println(Thread.currentThread().getName() + "獲得了讀鎖, 時間為" +
          new Date());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      readLock().unlock();
    }
  }

  public static void main(String[] args)
  {
    final ThreadDomain46 td = new ThreadDomain46();
    Runnable readRunnable = new Runnable()
    {
      public void run()
      {
        td.read();
      }
    };
    Runnable writeRunnable = new Runnable()
    {
      public void run()
      {
        td.write();
      }
    };
    Thread t0 = new Thread(readRunnable);
    Thread t1 = new Thread(writeRunnable);
    t0.start();
    t1.start();
  }
}

輸出結果如下

Thread-0獲得了讀鎖, 時間為Tue Jul 30 11:49:15 CST 2019
Thread-1獲得了寫鎖, 時間為Tue Jul 30 11:49:26 CST 2019

可以看到Thread-0獲得讀鎖執(zhí)行完10s后Thread-1才獲得了寫鎖，說明讀操作和寫操作互斥。
另一種輸出結果如下

Thread-1獲得了寫鎖, 時間為Tue Jul 30 14:14:07 CST 2019
Thread-0獲得了讀鎖, 時間為Tue Jul 30 14:14:17 CST 2019

可以看到Thread-1獲得寫鎖執(zhí)行完10s后Thread-0才獲得了讀鎖，說明寫操作和讀操作互斥。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

Java如何實現(xiàn)通過證書訪問Https請求
這篇文章主要介紹了Java如何實現(xiàn)通過證書訪問Https請求，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2022-01-01
Java 數(shù)據(jù)庫連接池 DBCP 的介紹
這篇文章主要給大家分享的是 Java 數(shù)據(jù)庫連接池 DBCP 的介紹，是 Apache 旗下 Commons 項目下的一個子項目，提供連接池功能DBCP，下面來看看文章的具體介紹內容吧,需要的朋友可以參考一下
2021-11-11
Java開啟JMX遠程監(jiān)控服務配置
這篇文章主要為大家介紹了Java開啟JMX遠程監(jiān)控的服務配置，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2023-05-05
教你使用java實現(xiàn)去除各種空格
本文給大家匯總介紹了5種java中去除空格的方法，分別是String.trim()、str.replace(" ", "");、replaceAll(" +","");以及自定義的remove函數(shù)，非常的簡單實用，需要的小伙伴可以參考下。
2015-03-03
Java責任鏈模式定義與用法分析
這篇文章主要介紹了Java責任鏈模式定義與用法,結合具體實例分析了java責任鏈模式的功能、定義、使用方法、適用情況等,需要的朋友可以參考下
2017-06-06
Java 八種基本類型和基本類型封裝類
八種基本數(shù)據(jù)類型分別是：int、short、float、double、long、boolean、byte、char；下面跟隨腳本之家小編一起學習java八種基本類型和基本類型封裝類
2017-09-09
Hadoop之Mapreduce序列化
本文主要帶我們了解Mapreduce序列化，序列化就是把內存中的對象，轉換成字節(jié)序列（或其他數(shù)據(jù)傳輸協(xié)議）以便于存儲到磁盤（持久化）和網(wǎng)絡傳輸。想進一步了解更多的小伙伴，可以參考閱讀本文
2023-03-03
Java如何基于okhttp請求SSE接口流式返回詳解
對于流式返回,Spring Boot提供了兩種不同的方式,下面這篇文章主要給大家介紹了關于Java如何基于okhttp請求SSE接口流式返回的相關資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
2024-03-03
MyBatis類型轉換模塊的實現(xiàn)
MyBatis是一個持久層框架ORM框架,實現(xiàn)數(shù)據(jù)庫中數(shù)據(jù)和Java對象中的屬性的雙向映射,那么不可避免的就會碰到類型轉換的問題,本文主要介紹了MyBatis類型轉換模塊的實現(xiàn),感興趣的可以了解一下
2023-09-09
C#中NAudio音頻庫的安裝與使用教程詳解
NAudio為.NET平臺下的開源庫,采用ML-PL協(xié)議,它支持許多音頻操作,可實現(xiàn)多種API播放與錄制、多種不同音頻格式等功能,下面就跟隨小編一起學習一下NAudio的安裝與使用吧
2023-11-11