Java讀寫鎖ReadWriteLock的創(chuàng)建使用及測試分析示例詳解
簡介
摘要:本文主要介紹ReadWriteLock,可重入讀寫鎖的基本使用,該鎖只能在單服務(wù)實例中使用,不適合分布式多服務(wù)實例集群。
A ReadWriteLock維護(hù)一對關(guān)聯(lián)的locks,一個用于只讀操作,一個用于寫操作。read lock可以由多個閱讀器同時進(jìn)行,只要沒有作者 write lock 是獨(dú)家的。
基本意思可分為如下幾種場景
- 寫鎖不存在、多次加讀鎖成功
- 寫鎖存在、加讀鎖失敗、加寫鎖失敗
- 讀鎖不存在、單次加寫鎖成功、多次加寫鎖只有第一個寫鎖能成功
- 讀鎖存在、加讀鎖成功、加寫鎖失敗
基本方法介紹
創(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)建使用及測試分析示例詳解的詳細(xì)內(nèi)容,更多關(guān)于Java讀寫鎖ReadWriteLock的資料請關(guān)注腳本之家其它相關(guān)文章!
- Java并發(fā)編程之重入鎖與讀寫鎖
- Java編程讀寫鎖詳解
- Java 讀寫鎖實現(xiàn)原理淺析
- Java并發(fā)編程之ReadWriteLock讀寫鎖的操作方法
- Java并發(fā)之搞懂讀寫鎖
- Java多線程讀寫鎖ReentrantReadWriteLock類詳解
- java并發(fā)編程中ReentrantLock可重入讀寫鎖
- Java中讀寫鎖ReadWriteLock的原理與應(yīng)用詳解
- 詳解Java?ReentrantReadWriteLock讀寫鎖的原理與實現(xiàn)
- 一文了解Java讀寫鎖ReentrantReadWriteLock的使用
- Java AQS中ReentrantReadWriteLock讀寫鎖的使用
- Java讀寫鎖ReadWriteLock原理與應(yīng)用場景詳解
相關(guān)文章
詳解spring cloud hystrix 請求合并collapsing
這篇文章主要介紹了詳解spring cloud hystrix 請求合并collapsing,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2018-05-05Java?多線程并發(fā)編程提高數(shù)據(jù)處理效率的詳細(xì)過程
這篇文章主要介紹了Java?多線程并發(fā)編程提高數(shù)據(jù)處理效率,本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-04-04Java中JDom解析XML_動力節(jié)點(diǎn)Java學(xué)院整理
JDOM是一種解析XML的Java工具包。DOM適合于當(dāng)今流行的各種語言,包括Java,JavaScripte,VB,VBScript,Perl,C,C++等。下面通過本文給大家介紹Java中JDom解析XML的方法,感興趣的朋友一起學(xué)習(xí)吧2017-07-07IntelliJ IDEA 2017.1.4 x64配置步驟(介紹)
下面小編就為大家?guī)硪黄狪ntelliJ IDEA 2017.1.4 x64配置步驟(介紹)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-06-06解決mybatis批量更新(update foreach)失敗的問題
這篇文章主要介紹了解決mybatis批量更新(update foreach)失敗的問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-11-11