您好,登錄后才能下訂單哦!
本篇內(nèi)容介紹了“為什么ReenTrantLock鎖可以替代synchronized鎖”的有關(guān)知識,在實(shí)際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
ReenTrantLock可以替代synchronized鎖,并且比synchronized鎖更靈活
synchronized鎖是自動(dòng)上鎖、自動(dòng)解鎖,而ReenTrantLock需要手動(dòng)上鎖、手動(dòng)解鎖
synchronized鎖在程序運(yùn)行時(shí),如果拋異常,jvm會自動(dòng)釋放鎖,而ReenTrantLock還是得自己手動(dòng)釋放鎖,所以,釋放鎖一般都是寫在finally中
**ReentrantLock的tryLock方法,是嘗試獲取鎖。**就是去嘗試獲取鎖,獲取不到就繼續(xù)往下執(zhí)行,不想synchronized鎖,獲取不到鎖,就在那死等,該方法有一個(gè)boolean類型的返回值,你可以根據(jù)這個(gè)返回值,執(zhí)行你的邏輯。并且可以指定嘗試獲取鎖的時(shí)間,相當(dāng)于等待獲取鎖的時(shí)間。
ReentrantLock的lockInterruptibly獲取鎖,除了tryLock,通過lockInterruptibly方法也可以獲取鎖,可以對線程的interrupt方法作出響應(yīng)。這個(gè)方法的意義有點(diǎn)類似于tryLock使用超時(shí)的時(shí)候的場景。:兩個(gè)線程,T1獲取鎖,T2線程啟動(dòng),獲取不到鎖,然后你不想讓T2等了,如果用lock、tryLock是沒法打斷的,如果用lockInterruptibly是可以打斷的。
ReentrantLock可以是一個(gè)公平鎖,公平鎖就是,哪個(gè)線程等鎖等的時(shí)間長,就先執(zhí)行哪個(gè)。而synchronized鎖是非公平鎖。
public class ReentrantLockTest { public static void main(String[] args) { Lock rtLock = /*new ReentrantLock(true) 公平鎖*/ new ReentrantLock(); Thread t1 = new Thread(()->{ try { rtLock.lock(); // rtLock.tryLock();嘗試獲取鎖 // rtLock.tryLock(2,TimeUnit.SECONDS);嘗試獲取鎖,超時(shí)設(shè)置 TimeUnit.SECONDS.sleep(Integer.MAX_VALUE); } catch (InterruptedException e) { e.printStackTrace(); }finally { rtLock.unlock(); } }); t1.start(); Thread t2 = new Thread(()->{ try { // rtLock.lock(); rtLock.lockInterruptibly(); TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); }finally { rtLock.unlock(); } }); t2.start(); try { TimeUnit.SECONDS.sleep(2); t2.interrupt(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
ReentrantLock還可以綁定conditon,看代碼你就懂了
public class ConditionTest { //使用condition來完成這個(gè)操作:有2個(gè)生產(chǎn)者線程、10個(gè)消費(fèi)者線程,如果容器滿了,則生產(chǎn)者暫停,如果容器空了,則消費(fèi)者暫停 final private LinkedList list = new LinkedList(); final private int maxValue = 10; Lock lock = new ReentrantLock(); private Condition producerCondition = lock.newCondition();//生產(chǎn)者 private Condition consumerCondition = lock.newCondition();//消費(fèi)者 /** * 生產(chǎn)者,按照要求:當(dāng)容器滿了,就停止。 */ public void producer(Object o) { while(list.size()==maxValue) { try { // this.wait(); wait 是配合synchronized鎖用的 producerCondition.await(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } list.add(o); consumerCondition.signalAll();//只喚醒了消費(fèi)者線程 } /** * 消費(fèi)者 */ public Object consumer() { while(list.size()==0) { try { consumerCondition.await(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } Object o = list.removeFirst(); producerCondition.signalAll(); return o; } public static void main(String[] args) { ConditionTest conditionTest = new ConditionTest(); //啟動(dòng)消費(fèi)者線程 for(int i=0;i<10;i++) { new Thread(()->{ for(int j=0;j<10;j++) { System.out.println(conditionTest.consumer()+"aa"); } },"c"+i) .start(); } try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } //啟動(dòng)生產(chǎn)者線程 for(int i=0;i<2;i++) { new Thread(()->{ for(int j=0;j<30;j++) { conditionTest.producer(Thread.currentThread().getName()); } },"p"+i) .start(); } } }
“為什么ReenTrantLock鎖可以替代synchronized鎖”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。