ReentrantReadWriteLock是一個(gè)讀寫鎖,與ReentrantLock不同之處在于它提供兩種模式的鎖,一種為讀鎖另一種為寫鎖.讀鎖是一種共享鎖,即當(dāng)一個(gè)線程已經(jīng)擁有了讀鎖,其他線程仍然可以繼續(xù)請(qǐng)求獲取讀鎖,但是不能獲取寫鎖.寫鎖則是一種排他鎖,即當(dāng)一個(gè)線程已經(jīng)擁有了寫鎖,那么其他線程就無法獲取讀鎖或者寫鎖.
例如我們應(yīng)用中的緩存,允許多個(gè)線程同時(shí)讀取數(shù)據(jù),但是對(duì)于寫入數(shù)據(jù)的情況就只能允許一個(gè)線程進(jìn)行.下面我們使用代碼簡(jiǎn)單的實(shí)現(xiàn)一個(gè)緩存.
public class App9 {
public static void main(String[] args) throws InterruptedException {
Cache cache = new Cache();
//更新緩存線程
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+":寫入緩存");
cache.put("info","測(cè)試內(nèi)容");
}
});
t1.setName("t1");
t1.start();
Thread.sleep(500);
Runnable runnable = new Runnable() {
@Override
public void run() {
String info = cache.get("info");
System.out.println(Thread.currentThread().getName() + ":" + info);
}
};
Thread t2 = new Thread(runnable);
t2.setName("t2");
t2.start();
Thread t3 = new Thread(runnable);
t3.setName("t3");
t3.start();
}
}
class Cache{
//讀寫鎖
private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
//存儲(chǔ)緩存數(shù)據(jù)
private Map<String,String> map = new HashMap<>();
/**
* 存入數(shù)據(jù)
* @param key
* @param value
*/
public void put(String key,String value){
//添加寫鎖
lock.writeLock().lock();
//放入數(shù)據(jù)
map.put(key,value);
//2s之后再釋放鎖
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
//解鎖
lock.writeLock().unlock();
}
/**
* 獲取數(shù)據(jù)
* @param key
* @return
*/
public String get(String key){
//獲取讀鎖
lock.readLock().lock();
//獲取數(shù)據(jù)
String value = map.get(key);
//2s之后再釋放鎖
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
lock.readLock().unlock();
return value;
}
}
執(zhí)行結(jié)果如下:
t1:寫入緩存
t2:測(cè)試內(nèi)容
t3:測(cè)試內(nèi)容
上面的代碼中,我們讓寫入緩存線程t1先獲取鎖,而讀取緩存的線程t2和她t3等待寫鎖釋放.當(dāng)寫鎖釋放之后,讀線程t2和t3立馬都打印出緩存數(shù)據(jù).由此可以說明,寫鎖再被當(dāng)前線程獲取之后,其他線程都無法再次獲取到讀鎖或者寫鎖.而讀鎖被獲取后,其他線程是可以獲取到寫鎖的.
除此之外,ReentrantReadWriteLock還有以下幾個(gè)特征:
-
可重入性:這個(gè)跟ReentrantLock一樣也支持重入.即當(dāng)前線程已獲得鎖,接下來它可以再次獲取鎖. -
鎖降級(jí):它在支持重入的情況下,還支持從寫鎖降級(jí)到讀鎖.但是需要注意的是讀鎖是無法降級(jí)成讀鎖的.
public class App10 {
public static void main(String[] args) {
ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
//獲取寫鎖
lock.writeLock().lock();
System.out.println("獲取寫鎖");
//獲取讀鎖
lock.readLock().lock();
System.out.println("獲取讀鎖");
//釋放讀鎖
lock.readLock().unlock();
System.out.println("釋放讀鎖");
//釋放寫鎖
lock.writeLock().unlock();
System.out.println("釋放寫鎖");
}
});
t1.setName("t1");
t1.start();
}
}
上面就是鎖降級(jí)的例子.在上面的例子中,線程先獲取寫鎖,然后再獲取讀鎖.最后程序能順利打印出結(jié)果并結(jié)束.如果先獲取讀鎖再獲取寫鎖,這時(shí)候線程在獲取寫鎖的時(shí)候會(huì)阻塞永遠(yuǎn)無法獲取到寫鎖.
同樣讀寫鎖也支持Condition,讀寫鎖除了鎖區(qū)分讀鎖和寫鎖之外,其他功能跟ReentrantLock基本上就類似了.如果還不了解ReentrantLock如何使用,可以看我之前寫的相關(guān)文章.
