最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Java讀寫鎖ReadWriteLock的創(chuàng)建使用及測試分析示例詳解

 更新時間:2023年01月12日 15:27:35   作者:昵稱為空C  
這篇文章主要為大家介紹了Java讀寫鎖ReadWriteLock的創(chuàng)建使用及測試分析示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

簡介

摘要:本文主要介紹ReadWriteLock,可重入讀寫鎖的基本使用,該鎖只能在單服務(wù)實例中使用,不適合分布式多服務(wù)實例集群。

A ReadWriteLock維護一對關(guān)聯(lián)的locks,一個用于只讀操作,一個用于寫操作。read lock可以由多個閱讀器同時進行,只要沒有作者 write lock 是獨家的。

基本意思可分為如下幾種場景

  • 寫鎖不存在、多次加讀鎖成功
  • 寫鎖存在、加讀鎖失敗、加寫鎖失敗
  • 讀鎖不存在、單次加寫鎖成功、多次加寫鎖只有第一個寫鎖能成功
  • 讀鎖存在、加讀鎖成功、加寫鎖失敗

基本方法介紹

創(chuàng)建讀寫鎖

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

使用讀鎖readLock().lock()

如果該鎖被寫鎖占有,則該方法會一直等待鎖

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.readLock().lock();

使用讀鎖readLock().tryLock();readLock().tryLock(6L, TimeUnit.SECONDS)

如果該鎖被寫鎖占有,第一個方法如果獲取不到鎖則返回false,第二個方法會等待你設(shè)置的時間,在你設(shè)置的時間范圍內(nèi)未獲取到鎖則返回false

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.readLock().tryLock();
readWriteLock.readLock().tryLock(6L, TimeUnit.SECONDS);

使用寫鎖writeLock().lock()

如果該鎖被寫鎖占有,則該方法會一直等待鎖

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.writeLock().lock();

使用讀鎖writeLock().tryLock();writeLock().tryLock(6L, TimeUnit.SECONDS)

如果該鎖被寫鎖占有,第一個方法如果獲取不到鎖則返回false,第二個方法會等待你設(shè)置的時間,在你設(shè)置的時間范圍內(nèi)未獲取到鎖則返回false

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.writeLock().tryLock();
readWriteLock.writeLock().tryLock(6L, TimeUnit.SECONDS);

使用案例

創(chuàng)建LockManager

該實例的讀方法用了等待6S

public class LockManager {
    private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    public void write(String message,Long sleep) {
        try{
            if(readWriteLock.writeLock().tryLock()){
                try{
                    Thread.sleep(sleep);
                    System.out.println(Thread.currentThread().getName()+",寫寫寫寫寫寫寫寫寫寫,message="+message);
                }catch (Exception ex){
                    System.out.println(Thread.currentThread().getName()+",寫入異常"+ex);
                }finally {
                    readWriteLock.writeLock().unlock();
                }
            }else{
                System.out.println(Thread.currentThread().getName()+",獲取寫鎖失敗");
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }
    public void read(String message,Long sleep){
        try{
            if(readWriteLock.readLock().tryLock(6L, TimeUnit.SECONDS)){
                try{
                    Thread.sleep(sleep);
                    System.out.println(Thread.currentThread().getName()+",讀讀讀讀讀讀讀讀讀讀,message="+message);
                }catch (Exception ex){
                    System.out.println(Thread.currentThread().getName()+",讀取異常"+ex);
                }finally {
                    readWriteLock.readLock().unlock();
                }
            }else{
                System.out.println(Thread.currentThread().getName()+",獲取讀鎖失敗");
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }
}

測試無寫鎖,只有讀鎖

測試方法

第一個線程等待5S輸出,第二個線程等待4S輸出

@Test
public void testOnlyRead() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.read("001",5000L)).start();
    new Thread(()->lockManager.read("002",4000L)).start();
    Thread.sleep(20000L);
}

輸出結(jié)果

Thread-2,讀讀讀讀讀讀讀讀讀讀,message=002
Thread-1,讀讀讀讀讀讀讀讀讀讀,message=001

測試無讀鎖,只有寫鎖

測試方法

第一個線程等待5S輸出,第二個線程等待4S輸出

@Test
public void testOnlyWrite() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.write("001",5000L)).start();
    new Thread(()->lockManager.write("002",4000L)).start();
    Thread.sleep(20000L);
}

輸出結(jié)果

Thread-2,獲取寫鎖失敗
Thread-1,寫寫寫寫寫寫寫寫寫寫,message=001

測試先讀鎖,再寫鎖

測試方法

第一個線程等待5S輸出,第二個線程等待4S輸出

@Test
public void testReadWrite() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.read("001",5000L)).start();
    new Thread(()->lockManager.write("002",4000L)).start();
    Thread.sleep(20000L);
}

輸出結(jié)果

Thread-2,獲取寫鎖失敗
Thread-1,讀讀讀讀讀讀讀讀讀讀,message=001

測試先寫鎖,再寫鎖

測試方法 (由于讀鎖獲取等待了6S,所以可以執(zhí)行成功)

第一個線程等待5S輸出,第二個線程等待4S輸出

@Test
public void testWriteRead() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.write("001",5000L)).start();
    new Thread(()->lockManager.read("002",4000L)).start();
    Thread.sleep(20000L);
}

輸出結(jié)果

Thread-1,寫寫寫寫寫寫寫寫寫寫,message=001
Thread-2,讀讀讀讀讀讀讀讀讀讀,message=002

測試方法 (由于讀鎖獲取等待了6S,所以讀鎖獲取失?。?/h4>

第一個線程等待7S輸出,第二個線程等待4S輸出

@Test
public void testWriteRead2() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.write("001",7000L)).start();
    new Thread(()->lockManager.read("002",4000L)).start();
    Thread.sleep(20000L);
}

輸出結(jié)果

Thread-2,獲取讀鎖失敗
Thread-1,寫寫寫寫寫寫寫寫寫寫,message=001

以上就是Java讀寫鎖ReadWriteLock的創(chuàng)建使用及測試分析示例詳解的詳細內(nèi)容,更多關(guān)于Java讀寫鎖ReadWriteLock的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • 一文詳解Springboot中filter的原理與注冊

    一文詳解Springboot中filter的原理與注冊

    這篇文章主要為大家詳細介紹了Springboot中filter的原理與注冊的相關(guān)知識,文中的示例代碼講解詳細,對我們掌握SpringBoot有一定的幫助,需要的可以參考一下
    2023-02-02
  • Java算法實戰(zhàn)之排一億個隨機數(shù)

    Java算法實戰(zhàn)之排一億個隨機數(shù)

    我們在生活中經(jīng)常遇見一些這樣的需求,隨機點名、公司年會抽獎、微信拼手氣紅包等,還有一些游戲比如打地鼠小游戲、俄羅斯方塊等,這些場景中都會用到一種算法:隨機,這篇文章主要給大家介紹了關(guān)于Java算法實戰(zhàn)之排一億個隨機數(shù)的相關(guān)資料,需要的朋友可以參考下
    2021-11-11
  • Java?Swing實現(xiàn)QQ登錄頁面

    Java?Swing實現(xiàn)QQ登錄頁面

    這篇文章主要為大家詳細介紹了Java?Swing實現(xiàn)QQ登錄頁面,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2022-02-02
  • springboot2.1.3配置sftp自定義sftp連接池的詳細過程

    springboot2.1.3配置sftp自定義sftp連接池的詳細過程

    這篇文章主要介紹了springboot2.1.3配置sftp自定義sftp連接池的詳細過程,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-08-08
  • IntelliJ?IDEA?2020.2.3永久破解激活教程(親測有效)

    IntelliJ?IDEA?2020.2.3永久破解激活教程(親測有效)

    intellij?idea?2022是一款市面上最好的JAVA?IDE編程工具,該工具支持git、svn、github等版本控制工具,整合了智能代碼助手、代碼自動提示等功能,本教程給大家分享IDEA?2022最新永久激活碼,感興趣的朋友參考下吧
    2020-10-10
  • 使用dynamic datasource springboot starter實現(xiàn)多數(shù)據(jù)源及源碼分析

    使用dynamic datasource springboot starter實現(xiàn)多數(shù)據(jù)源及源碼分析

    這篇文章主要介紹了使用dynamic-datasource-spring-boot-starter做多數(shù)據(jù)源及源碼分析,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-09-09
  • springboot Jpa多數(shù)據(jù)源(不同庫)配置過程

    springboot Jpa多數(shù)據(jù)源(不同庫)配置過程

    這篇文章主要介紹了springboot Jpa多數(shù)據(jù)源(不同庫)配置過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • Java實現(xiàn)十進制與二進制互轉(zhuǎn)的示例詳解

    Java實現(xiàn)十進制與二進制互轉(zhuǎn)的示例詳解

    這篇文章主要為大家詳細介紹了Java如何實現(xiàn)十進制與二進制的互轉(zhuǎn),文中的示例代碼講解詳細,對我們學(xué)習(xí)Java有一定幫助,需要的可以參考一下
    2022-11-11
  • Java ThreadLocal類使用詳解

    Java ThreadLocal類使用詳解

    這篇文章主要介紹了Java ThreadLocal類詳解,文章圍繞主題展開詳細的內(nèi)容介紹,具有一定的參考價值,需要的小伙伴可以參考一下
    2022-07-07
  • mybatis一直加載xml,找到錯誤的解決方案

    mybatis一直加載xml,找到錯誤的解決方案

    這篇文章主要介紹了mybatis一直加載xml,找到錯誤的解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-02-02

最新評論

天津市| 怀柔区| 华池县| 枣强县| 淮北市| 方正县| 顺昌县| 上高县| 澄城县| 离岛区| 阿荣旗| 田东县| 新源县| 景谷| 莱西市| 阜南县| 桦川县| 广汉市| 礼泉县| 福安市| 衡山县| 于田县| 玉溪市| 常宁市| 保定市| 安福县| 云浮市| 齐齐哈尔市| 大竹县| 马山县| 龙门县| 宾阳县| 福鼎市| 怀远县| 固安县| 马公市| 九江县| 肥西县| 毕节市| 大新县| 郴州市|