1.ReadWriteLock介紹

為什么我們有了Lock,還要用ReadWriteLock呢,我們對共享資源加鎖之后,所有的執行緒都將會等待,Lock讀操作也鎖,寫操作也會鎖,而對共享資源讀的時候,其實是不用加鎖的,當然讀寫同時存在的情況也會有,
比如我們資料庫常用操作有增刪改查,增刪改都是寫操作,寫操作必須加鎖,而讀操作可以共享,不是所有的操作都需要加鎖,
為了進一步提高復用性和粒度,寫操作獨占,讀操作共享,不加鎖,
ReadWriteLock管理一組鎖,一個是只讀的鎖,一個是寫鎖,讀鎖可以在沒有寫鎖的時候被多個執行緒同時持有,寫鎖是獨占的,
即讀讀可共享,寫讀寫寫要獨占
讀操作不用關心資源爭搶和資料一致性的操作
多個執行緒同時讀一個資源類沒有任何問題,所以為了滿足并發量,讀取共享資源應該可以同時進行,
但是如果有一個執行緒想去寫共享資源來,就不應該再有其它執行緒可以對該資源進行讀或寫,
小總結:
??讀-讀能共存
??讀-寫不能共存
??寫-寫不能共存
ReadWriteLock適用于讀多寫少的并發情況,
Java并發包中ReadWriteLock是一個介面,主要有兩個方法,如下:
public interface ReadWriteLock {
/**
* 回傳讀鎖
*/
Lock readLock();
/**
* 回傳寫鎖
*/
Lock writeLock();
}
Java并發庫中ReetrantReadWriteLock實作了ReadWriteLock介面并添加了可重入的特性,
2.不用讀寫鎖的案例
class MyCache{
//volalite保證資料再執行緒間的可見性和一定的有序性
private volatile Map<String,Object> map=new HashMap<>();
public void put(String key,Object value){
System.out.println(Thread.currentThread().getName()+"\t ---寫入資料"+key);
map.put(key,value);
try {TimeUnit.SECONDS.sleep(3);} catch (InterruptedException e) {e.printStackTrace();}
System.out.println(Thread.currentThread().getName()+"\t ---寫入完成");
}
public void get(String key){
System.out.println(Thread.currentThread().getName()+"\t 讀取資料");
Object result=map.get(key);
System.out.println(Thread.currentThread().getName()+"\t 讀取完成"+result);
}
}
public class ReadWriteLockDemo {
public static void main(String[] args) {
// TODO Auto-generated method stub
MyCache myCache=new MyCache();
for(int i=1;i<=5;i++){
final int tempInt=i;
new Thread(()->{
myCache.put(tempInt+"",tempInt+"");
},String.valueOf(i)).start();
}
for(int i=1;i<=5;i++){
final int tempInt=i;
new Thread(()->{
myCache.get(tempInt+"");
},String.valueOf(i)).start();
}
}
}

上面的運行結果出現了一個很嚴重的問題,比如說,執行緒1在寫入資料的時候,還沒等執行緒1寫完,其它執行緒也在寫和讀,這違背了事務的原子性,而且也破壞了資料的完整性和一致性,我正在寫的時候,不允許其他執行緒同時也在寫或者讀,即1寫入的時候,必須要滿足后一條就是1寫入完成,
3.用讀寫鎖的案例
class MyCache{
//volalite保證資料再執行緒間的可見性和一定的有序性
private volatile Map<String,Object> map=new HashMap<>();
private ReadWriteLock readwritelock=new ReentrantReadWriteLock();
public void put(String key,Object value){
readwritelock.writeLock().lock();
try {
System.out.println(Thread.currentThread().getName()+"\t ---寫入資料"+key);
map.put(key,value);
try {TimeUnit.SECONDS.sleep(3);} catch (InterruptedException e) {e.printStackTrace();}
System.out.println(Thread.currentThread().getName()+"\t ---寫入完成");
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
readwritelock.writeLock().unlock();
}
}
public void get(String key){
readwritelock.readLock().lock();
try {
System.out.println(Thread.currentThread().getName()+"\t 讀取資料");
Object result=map.get(key);
System.out.println(Thread.currentThread().getName()+"\t 讀取完成"+result);
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
readwritelock.readLock().unlock();
}
}
}
public class ReadWriteLockDemo {
public static void main(String[] args) {
// TODO Auto-generated method stub
MyCache myCache=new MyCache();
for(int i=1;i<=5;i++){
final int tempInt=i;
new Thread(()->{
myCache.put(tempInt+"",tempInt+"");
},String.valueOf(i)).start();
}
for(int i=1;i<=5;i++){
final int tempInt=i;
new Thread(()->{
myCache.get(tempInt+"");
},String.valueOf(i)).start();
}
}
}

轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/254067.html
標籤:java
上一篇:Java面試知識點(2021)
下一篇:Python 復制檔案和目錄
