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)文章!
- 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)文章
springboot2.1.3配置sftp自定義sftp連接池的詳細過程
這篇文章主要介紹了springboot2.1.3配置sftp自定義sftp連接池的詳細過程,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-08-08
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-spring-boot-starter做多數(shù)據(jù)源及源碼分析,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-09-09
springboot Jpa多數(shù)據(jù)源(不同庫)配置過程
這篇文章主要介紹了springboot Jpa多數(shù)據(jù)源(不同庫)配置過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-05-05
Java實現(xiàn)十進制與二進制互轉(zhuǎn)的示例詳解
這篇文章主要為大家詳細介紹了Java如何實現(xiàn)十進制與二進制的互轉(zhuǎn),文中的示例代碼講解詳細,對我們學(xué)習(xí)Java有一定幫助,需要的可以參考一下2022-11-11

