舉例說(shuō)明Java多線程編程中讀寫鎖的使用
以下示例為 java api并發(fā)庫(kù)中 ReentrantReadWriteLock自帶的實(shí)例,下面進(jìn)行解讀
class CachedData { Object data; volatile boolean cacheValid; ReentrantReadWriteLock rwl = new ReentrantReadWriteLock(); void processCachedData() { rwl.readLock().lock();//@1 if (!cacheValid) { // Must release read lock before acquiring write lock rwl.readLock().unlock();//@4 rwl.writeLock().lock();//@2 // Recheck state because another thread might have acquired // write lock and changed state before we did. if (!cacheValid) {//@3 data = ... cacheValid = true; } // Downgrade by acquiring read lock before releasing write lock rwl.readLock().lock(); rwl.writeLock().unlock(); // Unlock write, still hold read } use(data); rwl.readLock().unlock(); } }
當(dāng)有n多線程 使用同一CachedData 實(shí)例對(duì)象 調(diào)用processCachedData方法時(shí),就會(huì)產(chǎn)生線程的并發(fā)問(wèn)題.
@1行,當(dāng)有線程正在對(duì)數(shù)據(jù)進(jìn)行 寫操作的時(shí)候,運(yùn)行到@1行的線程要等待 寫操作的完成,因?yàn)榈谝粋€(gè)運(yùn)行到@2的線程會(huì)加上鎖,然后對(duì)數(shù)據(jù)進(jìn)行需該,期間不允許任何線程進(jìn)行讀或者是寫的操作,
當(dāng)寫完后,在該線程上加上讀鎖操作,以防止解寫鎖后,別的線程對(duì)數(shù)據(jù)再次進(jìn)行寫時(shí)出錯(cuò).在第一個(gè)運(yùn)行到@2的線程之后的很多線程,
可能已經(jīng)運(yùn)行到了@4,當(dāng)對(duì)數(shù)據(jù)修改好之后,解除掉寫鎖,別的線程就會(huì)執(zhí)行到@2,這時(shí)第一個(gè)線程已經(jīng)經(jīng)數(shù)據(jù)修改好了,所以有了@3的判斷。
在編寫多線程程序的時(shí)候,要置于并發(fā)線程的環(huán)境下考慮,巧妙的運(yùn)用ReentrantReadWriteLock,在運(yùn)用時(shí),注意鎖的降級(jí),寫入鎖可以獲得讀鎖,讀鎖不可以獲得寫入鎖,所以在上寫入鎖時(shí),必須先將讀鎖進(jìn)行解除,然后上讀鎖。
使用時(shí)注意的幾個(gè)方面:
讀鎖是排寫鎖操作的,讀鎖不排讀鎖操作,多個(gè)讀鎖可以并發(fā)不阻塞。即在讀鎖獲取后和讀鎖釋放之前,寫鎖并不能被任何線程獲得,
多個(gè)讀鎖同時(shí)作用期間,試圖獲取寫鎖的線程都處于等待狀態(tài),當(dāng)最后一個(gè)讀鎖釋放后,試圖獲取寫鎖的線程才有機(jī)會(huì)獲取寫鎖。
寫鎖是排寫鎖、排讀鎖操作的。當(dāng)一個(gè)線程獲取到寫鎖之后,其他試圖獲取寫鎖和試圖獲取讀鎖的線程都處于等待狀態(tài),直到寫鎖被釋放。
寫鎖是可以獲得讀鎖的,即:
rwl.writeLock().lock(); //在寫鎖狀態(tài)中,可以獲取讀鎖 rwl.readLock().lock(); rwl.writeLock().unlock();
讀鎖是不能夠獲得寫鎖的,如果要加寫鎖,本線程必須釋放所持有的讀鎖,即:
rwl.readLock().lock(); //...... //必須釋放掉讀鎖,才能夠加寫鎖 rwl.readLock().unlock(); rwl.writeLock().lock();
讀寫鎖是線程讀寫同一文件所需要用到的,讀寫鎖是什么東西在這里不做過(guò)多的解釋,可以自己去百度或谷歌去搜一下。
謹(jǐn)在此附上我自己寫的緩存系統(tǒng)的簡(jiǎn)單實(shí)現(xiàn),你從中也能悟出緩存實(shí)現(xiàn)的基本思想
緩存里面有數(shù)據(jù)就從緩存中取,沒(méi)有就給你從其他地方得到。
package cn.com.scl.cache import java.util.HashMap; import java.util.Map; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; /** * 緩存的實(shí)現(xiàn),每個(gè)線程只能獲得他自己的緩存,也應(yīng)該是單例的 * 本類沒(méi)有去實(shí)現(xiàn)單例,如果需要的話可以自行去實(shí)現(xiàn) * @author scl * */ public class CacheSystem { private Map<String, Object> cache = new HashMap<String,Object>(); private ReadWriteLock rwl = new ReentrantReadWriteLock(); public Object getData(String key){ //先從緩存中去取數(shù)據(jù),先加上讀鎖 rwl.readLock().lock(); Object obj = null; try{ obj = cache.get(key); if(obj == null){ //先解除讀鎖,在上寫鎖(必須先解除讀鎖才能成功上寫鎖) rwl.readLock().unlock(); rwl.writeLock().lock(); //去數(shù)據(jù)庫(kù)取數(shù)據(jù),再判斷一次是否為null,因?yàn)橛锌赡芏鄠€(gè)線程獲得寫鎖 try{ if(obj == null){ obj = new String("obj is get from db"); } }finally{ //先上讀鎖,然后再解除寫鎖(這樣可以成功完成,在解除寫鎖前獲得讀鎖,寫鎖被降級(jí)--這翻譯的api上的) rwl.readLock().lock(); rwl.writeLock().unlock();//解除寫鎖,讀鎖仍然持有 } } }finally{ rwl.readLock().unlock(); } return obj; } }
上一篇:簡(jiǎn)單實(shí)現(xiàn)C#異步操作
欄 目:C#教程
下一篇:dotNet中的反射用法入門教程
本文標(biāo)題:舉例說(shuō)明Java多線程編程中讀寫鎖的使用
本文地址:http://mengdiqiu.com.cn/a1/C_jiaocheng/6701.html
您可能感興趣的文章
- 01-10C#實(shí)現(xiàn)多線程下載文件的方法
- 01-10C#實(shí)現(xiàn)多線程寫入同一個(gè)文件的方法
- 01-10String.Format大全(C# Java)
- 01-10C#實(shí)現(xiàn)ComboBox控件顯示出多個(gè)數(shù)據(jù)源屬性的方法
- 01-10淺析JAVA中過(guò)濾器、監(jiān)聽(tīng)器、攔截器的區(qū)別
- 01-10C#中實(shí)現(xiàn)一次執(zhí)行多條帶GO的sql語(yǔ)句實(shí)例
- 01-10C#類的多態(tài)性詳解
- 01-10C#中Equals方法的常見(jiàn)誤解
- 01-10C#實(shí)現(xiàn)向多線程傳參的三種方式實(shí)例分析
- 01-10C#基于委托實(shí)現(xiàn)多線程之間操作的方法


閱讀排行
- 1C語(yǔ)言 while語(yǔ)句的用法詳解
- 2java 實(shí)現(xiàn)簡(jiǎn)單圣誕樹(shù)的示例代碼(圣誕
- 3利用C語(yǔ)言實(shí)現(xiàn)“百馬百擔(dān)”問(wèn)題方法
- 4C語(yǔ)言中計(jì)算正弦的相關(guān)函數(shù)總結(jié)
- 5c語(yǔ)言計(jì)算三角形面積代碼
- 6什么是 WSH(腳本宿主)的詳細(xì)解釋
- 7C++ 中隨機(jī)函數(shù)random函數(shù)的使用方法
- 8正則表達(dá)式匹配各種特殊字符
- 9C語(yǔ)言十進(jìn)制轉(zhuǎn)二進(jìn)制代碼實(shí)例
- 10C語(yǔ)言查找數(shù)組里數(shù)字重復(fù)次數(shù)的方法
本欄相關(guān)
- 01-10C#通過(guò)反射獲取當(dāng)前工程中所有窗體并
- 01-10關(guān)于ASP網(wǎng)頁(yè)無(wú)法打開(kāi)的解決方案
- 01-10WinForm限制窗體不能移到屏幕外的方法
- 01-10WinForm繪制圓角的方法
- 01-10C#實(shí)現(xiàn)txt定位指定行完整實(shí)例
- 01-10WinForm實(shí)現(xiàn)仿視頻 器左下角滾動(dòng)新
- 01-10C#停止線程的方法
- 01-10C#實(shí)現(xiàn)清空回收站的方法
- 01-10C#通過(guò)重寫Panel改變邊框顏色與寬度的
- 01-10C#實(shí)現(xiàn)讀取注冊(cè)表監(jiān)控當(dāng)前操作系統(tǒng)已
隨機(jī)閱讀
- 01-10使用C語(yǔ)言求解撲克牌的順子及n個(gè)骰子
- 08-05DEDE織夢(mèng)data目錄下的sessions文件夾有什
- 01-10C#中split用法實(shí)例總結(jié)
- 08-05織夢(mèng)dedecms什么時(shí)候用欄目交叉功能?
- 01-11ajax實(shí)現(xiàn)頁(yè)面的局部加載
- 01-11Mac OSX 打開(kāi)原生自帶讀寫NTFS功能(圖文
- 08-05dedecms(織夢(mèng))副欄目數(shù)量限制代碼修改
- 04-02jquery與jsp,用jquery
- 01-10delphi制作wav文件的方法
- 01-10SublimeText編譯C開(kāi)發(fā)環(huán)境設(shè)置