Java多線程編程之讀寫鎖ReadWriteLock用法實(shí)例
讀寫鎖:分為讀鎖和寫鎖,多個(gè)讀鎖不互斥,讀鎖與寫鎖互斥,這是由jvm自己控制的,你只要上好相應(yīng)的鎖即可。如果你的代碼只讀數(shù)據(jù),可以很多人同時(shí)讀,但不能同時(shí)寫,那就上讀鎖;如果你的代碼修改數(shù)據(jù),只能有一個(gè)人在寫,且不能同時(shí)讀取,那就上寫鎖??傊?,讀的時(shí)候上讀鎖,寫的時(shí)候上寫鎖!
三個(gè)線程讀數(shù)據(jù),三個(gè)線程寫數(shù)據(jù)示例:
可以同時(shí)讀,讀的時(shí)候不能寫,不能同時(shí)寫,寫的時(shí)候不能讀。
讀的時(shí)候上讀鎖,讀完解鎖;寫的時(shí)候上寫鎖,寫完解鎖。
注意finally解鎖。
package com.ljq.test.thread; import java.util.Random; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; /** * 讀寫鎖 * * @author Administrator * */ public class ReadWriteLockTest { public static void main(String[] args) { final ReadWrite rw = new ReadWrite(); for (int i = 0; i < 3; i++) { new Thread() { public void run() { while (true) { rw.read(); } } }.start(); new Thread() { public void run() { while (true) { rw.write(new Random().nextInt(10000)); } } }.start(); } } } /** * 讀和寫要互斥,因此要把它們放在同一個(gè)類中 * * @author Administrator * */ class ReadWrite { private Object data = null;//共享數(shù)據(jù),只能有一個(gè)線程寫該數(shù)據(jù),但可以有多個(gè)線程同時(shí)讀該數(shù)據(jù)。 ReadWriteLock rwl = new ReentrantReadWriteLock(); /** * 讀數(shù)據(jù) */ public void read() { rwl.readLock().lock(); try { System.out.println(Thread.currentThread().getName() + " be ready to read data!"); Thread.sleep((long) (Math.random() * 1000)); System.out.println(Thread.currentThread().getName() + "have read data :" + data); } catch (InterruptedException e) { e.printStackTrace(); } finally { rwl.readLock().unlock(); } } /** * 寫數(shù)據(jù) * * @param data */ public void write(Object data) { rwl.writeLock().lock(); try { System.out.println(Thread.currentThread().getName() + " be ready to write data!"); Thread.sleep((long) (Math.random() * 1000)); this.data = data; System.out.println(Thread.currentThread().getName() + " have write data: " + data); } catch (InterruptedException e) { e.printStackTrace(); } finally { rwl.writeLock().unlock(); } } }
設(shè)計(jì)一個(gè)緩存系統(tǒng)
緩存系統(tǒng):你要取數(shù)據(jù),需調(diào)用我的public Object getData(String key)方法,我要檢查我內(nèi)部有沒有這個(gè)數(shù)據(jù),如果有就直接返回,如果沒有,就從數(shù)據(jù)庫中查找這個(gè)數(shù),查到后將這個(gè)數(shù)據(jù)存入我內(nèi)部的存儲(chǔ)器中,下次再有人來要這個(gè)數(shù)據(jù),我就直接返回這個(gè)數(shù)不用再到數(shù)據(jù)庫中找了。你要取數(shù)據(jù)不要找數(shù)據(jù)庫,來找我。
package com.ljq.test.thread; import java.util.HashMap; import java.util.Map; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; /** * 設(shè)計(jì)一個(gè)緩存系統(tǒng) * * * @author Administrator * */ public class CacheDemo { private Map<String, Object> cache = new HashMap<String, Object>(); public static void main(String[] args) { String key = "name"; CacheDemo cacheDemo = new CacheDemo(); System.out.println(cacheDemo.getData(key)); //從數(shù)據(jù)庫獲取數(shù)據(jù) System.out.println(cacheDemo.getData(key)); //從緩存獲取數(shù)據(jù) System.out.println(cacheDemo.getData(key)); //從緩存獲取數(shù)據(jù) } private ReadWriteLock rwl = new ReentrantReadWriteLock(); public Object getData(String key) { rwl.readLock().lock(); //上讀鎖 Object value = null; try { value = cache.get(key); //先查詢內(nèi)部存儲(chǔ)器中有沒有要的值 if (value == null) { //如果沒有,就去數(shù)據(jù)庫中查詢,并將查到的結(jié)果存入內(nèi)部存儲(chǔ)器中 //釋放讀鎖、上寫鎖 rwl.readLock().unlock(); rwl.writeLock().lock(); try { if (value == null) { //再次進(jìn)行判斷,防止多個(gè)寫線程堵在這個(gè)地方重復(fù)寫 System.out.println("read data from database"); value = "張三"; cache.put(key, value); } } finally { //設(shè)置完成 釋放寫鎖 rwl.writeLock().unlock(); } //恢復(fù)讀寫狀態(tài) rwl.readLock().lock(); }else{ System.out.println("read data from cache"); } } finally { rwl.readLock().unlock(); //釋放讀鎖 } return value; } }
返回結(jié)果:
相關(guān)文章
Java 中 synchronized的用法詳解(四種用法)
Java語言的關(guān)鍵字,當(dāng)它用來修飾一個(gè)方法或者一個(gè)代碼塊的時(shí)候,能夠保證在同一時(shí)刻最多只有一個(gè)線程執(zhí)行該段代碼。本文給大家介紹java中 synchronized的用法,對(duì)本文感興趣的朋友一起看看吧2015-11-11springboot結(jié)合maven實(shí)現(xiàn)多模塊打包
本文主要介紹了springboot借助maven完成多模塊打包,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04淺談Spring AOP中args()和argNames的含義
這篇文章主要介紹了Spring AOP中args()和argNames的含義,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-07-07SpringBoot集成ip2region實(shí)現(xiàn)ip白名單的代碼示例
ip2region v2.0 - 是一個(gè)離線IP地址定位庫和IP定位數(shù)據(jù)管理框架,10微秒級(jí)別的查詢效率,提供了眾多主流編程語言的 xdb 數(shù)據(jù)生成和查詢客戶端實(shí)現(xiàn),本文介紹了SpringBoot集成ip2region實(shí)現(xiàn)ip白名單的代碼工程,需要的朋友可以參考下2024-08-08Spring boot JPA實(shí)現(xiàn)分頁和枚舉轉(zhuǎn)換代碼示例
這篇文章主要介紹了Spring boot JPA實(shí)現(xiàn)分頁和枚舉轉(zhuǎn)換代碼示例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09