Java讀寫(xiě)鎖ReadWriteLock的創(chuàng)建使用及測(cè)試分析示例詳解
簡(jiǎn)介
摘要：本文主要介紹ReadWriteLock，可重入讀寫(xiě)鎖的基本使用，該鎖只能在單服務(wù)實(shí)例中使用，不適合分布式多服務(wù)實(shí)例集群。
A ReadWriteLock維護(hù)一對(duì)關(guān)聯(lián)的locks，一個(gè)用于只讀操作，一個(gè)用于寫(xiě)操作。read lock可以由多個(gè)閱讀器同時(shí)進(jìn)行，只要沒(méi)有作者 write lock 是獨(dú)家的。
基本意思可分為如下幾種場(chǎng)景
- 寫(xiě)鎖不存在、多次加讀鎖成功
- 寫(xiě)鎖存在、加讀鎖失敗、加寫(xiě)鎖失敗
- 讀鎖不存在、單次加寫(xiě)鎖成功、多次加寫(xiě)鎖只有第一個(gè)寫(xiě)鎖能成功
- 讀鎖存在、加讀鎖成功、加寫(xiě)鎖失敗
基本方法介紹
創(chuàng)建讀寫(xiě)鎖
ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
使用讀鎖readLock().lock()
如果該鎖被寫(xiě)鎖占有，則該方法會(huì)一直等待鎖
ReadWriteLock readWriteLock = new ReentrantReadWriteLock(); readWriteLock.readLock().lock();
使用讀鎖readLock().tryLock()；readLock().tryLock(6L, TimeUnit.SECONDS)
如果該鎖被寫(xiě)鎖占有，第一個(gè)方法如果獲取不到鎖則返回false，第二個(gè)方法會(huì)等待你設(shè)置的時(shí)間，在你設(shè)置的時(shí)間范圍內(nèi)未獲取到鎖則返回false
ReadWriteLock readWriteLock = new ReentrantReadWriteLock(); readWriteLock.readLock().tryLock(); readWriteLock.readLock().tryLock(6L, TimeUnit.SECONDS);
使用寫(xiě)鎖writeLock().lock()
如果該鎖被寫(xiě)鎖占有，則該方法會(huì)一直等待鎖
ReadWriteLock readWriteLock = new ReentrantReadWriteLock(); readWriteLock.writeLock().lock();
使用讀鎖writeLock().tryLock()；writeLock().tryLock(6L, TimeUnit.SECONDS)
如果該鎖被寫(xiě)鎖占有，第一個(gè)方法如果獲取不到鎖則返回false，第二個(gè)方法會(huì)等待你設(shè)置的時(shí)間，在你設(shè)置的時(shí)間范圍內(nèi)未獲取到鎖則返回false
ReadWriteLock readWriteLock = new ReentrantReadWriteLock(); readWriteLock.writeLock().tryLock(); readWriteLock.writeLock().tryLock(6L, TimeUnit.SECONDS);
使用案例
創(chuàng)建LockManager
該實(shí)例的讀方法用了等待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()+",寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)，message="+message);
}catch (Exception ex){
System.out.println(Thread.currentThread().getName()+",寫(xiě)入異常"+ex);
}finally {
readWriteLock.writeLock().unlock();
}
}else{
System.out.println(Thread.currentThread().getName()+",獲取寫(xiě)鎖失敗");
}
}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();
}
}
}
測(cè)試無(wú)寫(xiě)鎖，只有讀鎖
測(cè)試方法
第一個(gè)線程等待5S輸出，第二個(gè)線程等待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
測(cè)試無(wú)讀鎖，只有寫(xiě)鎖
測(cè)試方法
第一個(gè)線程等待5S輸出，第二個(gè)線程等待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,獲取寫(xiě)鎖失敗
Thread-1,寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)，message=001
測(cè)試先讀鎖，再寫(xiě)鎖
測(cè)試方法
第一個(gè)線程等待5S輸出，第二個(gè)線程等待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,獲取寫(xiě)鎖失敗
Thread-1,讀讀讀讀讀讀讀讀讀讀，message=001
測(cè)試先寫(xiě)鎖，再寫(xiě)鎖
測(cè)試方法 （由于讀鎖獲取等待了6S，所以可以執(zhí)行成功）
第一個(gè)線程等待5S輸出，第二個(gè)線程等待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,寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)，message=001
Thread-2,讀讀讀讀讀讀讀讀讀讀，message=002
測(cè)試方法 （由于讀鎖獲取等待了6S，所以讀鎖獲取失?。?/h4>
第一個(gè)線程等待7S輸出，第二個(gè)線程等待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,寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)寫(xiě)，message=001
以上就是Java讀寫(xiě)鎖ReadWriteLock的創(chuàng)建使用及測(cè)試分析示例詳解的詳細(xì)內(nèi)容，更多關(guān)于Java讀寫(xiě)鎖ReadWriteLock的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
- Java并發(fā)編程之重入鎖與讀寫(xiě)鎖
- Java編程讀寫(xiě)鎖詳解
- Java 讀寫(xiě)鎖實(shí)現(xiàn)原理淺析
- Java并發(fā)編程之ReadWriteLock讀寫(xiě)鎖的操作方法
- Java并發(fā)之搞懂讀寫(xiě)鎖
- Java多線程讀寫(xiě)鎖ReentrantReadWriteLock類詳解
- java并發(fā)編程中ReentrantLock可重入讀寫(xiě)鎖
- Java中讀寫(xiě)鎖ReadWriteLock的原理與應(yīng)用詳解
- 詳解Java?ReentrantReadWriteLock讀寫(xiě)鎖的原理與實(shí)現(xiàn)
- 一文了解Java讀寫(xiě)鎖ReentrantReadWriteLock的使用
- Java AQS中ReentrantReadWriteLock讀寫(xiě)鎖的使用
- Java讀寫(xiě)鎖ReadWriteLock原理與應(yīng)用場(chǎng)景詳解
相關(guān)文章
一文詳解Springboot中filter的原理與注冊(cè)
這篇文章主要為大家詳細(xì)介紹了Springboot中filter的原理與注冊(cè)的相關(guān)知識(shí)，文中的示例代碼講解詳細(xì)，對(duì)我們掌握SpringBoot有一定的幫助，需要的可以參考一下2023-02-02
Java算法實(shí)戰(zhàn)之排一億個(gè)隨機(jī)數(shù)
我們?cè)谏钪薪?jīng)常遇見(jiàn)一些這樣的需求,隨機(jī)點(diǎn)名、公司年會(huì)抽獎(jiǎng)、微信拼手氣紅包等,還有一些游戲比如打地鼠小游戲、俄羅斯方塊等,這些場(chǎng)景中都會(huì)用到一種算法：隨機(jī),這篇文章主要給大家介紹了關(guān)于Java算法實(shí)戰(zhàn)之排一億個(gè)隨機(jī)數(shù)的相關(guān)資料,需要的朋友可以參考下2021-11-11
Java?Swing實(shí)現(xiàn)QQ登錄頁(yè)面
這篇文章主要為大家詳細(xì)介紹了Java?Swing實(shí)現(xiàn)QQ登錄頁(yè)面，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-02-02
springboot2.1.3配置sftp自定義sftp連接池的詳細(xì)過(guò)程
這篇文章主要介紹了springboot2.1.3配置sftp自定義sftp連接池的詳細(xì)過(guò)程,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-08-08
IntelliJ?IDEA?2020.2.3永久破解激活教程(親測(cè)有效)
intellij?idea?2022是一款市面上最好的JAVA?IDE編程工具，該工具支持git、svn、github等版本控制工具，整合了智能代碼助手、代碼自動(dòng)提示等功能，本教程給大家分享IDEA?2022最新永久激活碼，感興趣的朋友參考下吧2020-10-10
使用dynamic datasource springboot starter實(shí)現(xiàn)多數(shù)據(jù)源及源碼分析
這篇文章主要介紹了使用dynamic-datasource-spring-boot-starter做多數(shù)據(jù)源及源碼分析,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-09-09
springboot Jpa多數(shù)據(jù)源(不同庫(kù))配置過(guò)程
這篇文章主要介紹了springboot Jpa多數(shù)據(jù)源(不同庫(kù))配置過(guò)程,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-05-05
Java實(shí)現(xiàn)十進(jìn)制與二進(jìn)制互轉(zhuǎn)的示例詳解
這篇文章主要為大家詳細(xì)介紹了Java如何實(shí)現(xiàn)十進(jìn)制與二進(jìn)制的互轉(zhuǎn)，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)Java有一定幫助，需要的可以參考一下2022-11-11
這篇文章主要介紹了Java ThreadLocal類詳解，文章圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的小伙伴可以參考一下2022-07-07
這篇文章主要介紹了mybatis一直加載xml，找到錯(cuò)誤的解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-02-02