日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
查漏補(bǔ)缺synchronized和ReentrantLock的基本原理

一、java鎖的類型

創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設(shè),平桂企業(yè)網(wǎng)站建設(shè),平桂品牌網(wǎng)站建設(shè),網(wǎng)站定制,平桂網(wǎng)站建設(shè)報價,網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,平桂網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè),幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競爭力??沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿,時刻以成就客戶成長自我,堅持不斷學(xué)習(xí)、思考、沉淀、凈化自己,讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

java的鎖有這么幾類。

樂觀鎖和悲觀鎖

  • 樂觀鎖就是JVM認(rèn)為不通過加鎖也能保證并發(fā)的正確性。典型實現(xiàn)是諸如AtomicInteger的實現(xiàn)。
  • 悲觀鎖就是需要加鎖互斥。典型實現(xiàn)是Synchronized(Synchronized屬于樂觀鎖還是悲觀鎖其實跟具體實現(xiàn)有關(guān),大部分場景下都是悲觀鎖)和ReentrantLock。

可重入和不可重入

  • 可重入是指當(dāng)一個線程獲取了鎖,但是沒有釋放,這個線程又要獲取這個鎖,仍然能獲取成功。Synchronized和ReentrantLock都是可重入鎖。
  • 不可重入是可重入的否命題,這樣自己會把自己死鎖。應(yīng)該沒有這樣的實現(xiàn)。

公平鎖和非公平鎖

  • 公平鎖是先請求鎖的線程肯定先獲得鎖,也就是FIFO。公平說是不是就是合理的?可能也不一定,因為這會造成上下文的切換。ReentrantLock默認(rèn)是非公平鎖,但是可以通過構(gòu)造方法構(gòu)造公平鎖實例。
  • 非公平鎖是新來的線程有優(yōu)先獲得鎖的機(jī)會,也就是可以插隊。合理嗎?可能也不合理,因為這可能造成“餓死”現(xiàn)象:在排隊的舊的線程總是獲取不到鎖。Sysnchronized其實就是非公平鎖。

排他鎖和共享鎖

  • 排他鎖是一個線程獲得鎖之后,其他線程不能再獲得鎖。大多數(shù)場景下都是排他鎖。
  • 共享鎖是指多個線程可以同時獲得鎖。常見的是多個線程可以同時獲得讀鎖。

二、synchronized

synchronized基本原理是通過CPU指令實現(xiàn)的。在jdk1.6之前是很重的鎖。因為java的多線程與操作系統(tǒng)的線程是一一對應(yīng)的。當(dāng)java線程阻塞的時候需要切換到內(nèi)核態(tài)的線程進(jìn)行阻塞,喚醒的時候又要從內(nèi)核態(tài)切換到用戶態(tài),進(jìn)行了很重的上下文切換。那么能不能當(dāng)一個線程獲取不到鎖的時候不阻塞呢?自旋可以嗎?這樣就有了synchronized的四種實現(xiàn):無鎖、偏向鎖、輕量鎖、重量鎖。

synchronized鎖的是java的對象頭,再詳細(xì)點是mark word。

無鎖

這個沒有什么好說的。沒有將這個對象通過synchronized包括。

偏向鎖

當(dāng)只有一個線程在訪問鎖的時候,會在mark word中通過CAS的方式設(shè)置當(dāng)前線程的threadId。如果成功的話,加鎖成功(由于只有一個線程,肯定成功)。這樣當(dāng)這個線程再次請求鎖的時候,看mark word的thread id和自己是否相同,如果相同加鎖成功。注意,它是沒有解鎖操作的。如果是另一個線程也來了,由于上一個線程沒有解鎖操作,這個新線程的CAS肯定失敗。這時當(dāng)JVM沒有字節(jié)碼要執(zhí)行的時候(全局安全點),會檢查上一個線程有沒有結(jié)束,如果結(jié)束,則通過CAS將mark word中的thread id字段更新為新線程的threadId。如果上一個線程沒有結(jié)束,這就存在并發(fā)了。偏向鎖無法完成使命,需要升級為輕量鎖。

輕量鎖

接著上面偏向鎖的上一個線程A和新的線程B的例子。JVM此時進(jìn)行一下線程A對mark word的操作。將mark word拷貝到當(dāng)前線程的棧空間中,CAS操作mark word的指針指向這個??臻g的地址,CAS操作當(dāng)前線程的??臻g再加一個指向mark word的指針,這兩個操作成功后,其實第一個CAS成功就是成功,這樣線程A就獲得了鎖,升級成為了輕量鎖。線程B會自旋等待線程A的釋放。線程A怎么釋放鎖呢?只要將第一個CAS操作的指針(mark word指向線程棧的指針)釋放了就可以了,線程B自旋檢測mark word的指向,去搶占鎖。如果此時又來一個線程C呢?是不是也自旋?可以同時有幾個線程自旋?線程B能自旋多少次?這些都是有JVM參數(shù)可配置的。

重量鎖

這個其實也沒什么好說的。存在并發(fā)訪問時,直接將線程切換到內(nèi)核態(tài)阻塞。

三、ReentrantLock

ReentrantLock是通過AQS(AbstractQueuedSynchronizer)實現(xiàn)的。需要解決的問題:

需要有個狀態(tài)表示這個lock對象是不是被搶占了,如果可重入的話,被這個線程搶占了多少次。這個狀態(tài)標(biāo)識其實就是AQS的state成員變量。對state的操作肯定要線程安全??梢酝ㄟ^CAS解決。

 
 
 
 
  1. protected final boolean tryAcquire(int acquires) { 
  2.     final Thread current = Thread.currentThread(); 
  3.     int c = getState(); 
  4.     if (c == 0) { 
  5.         // 這個是公平鎖的實現(xiàn)。需要判斷隊列中有沒有等待的線程, 
  6.         // 如果沒有才進(jìn)行CAS搶占     
  7.         if (!hasQueuedPredecessors() && 
  8.             compareAndSetState(0, acquires)) { 
  9.             setExclusiveOwnerThread(current); 
  10.             return true; 
  11.         } 
  12.     } 
  13.     // 這里就是可重入邏輯 
  14.     else if (current == getExclusiveOwnerThread()) { 
  15.         int nextc = c + acquires; 
  16.         if (nextc < 0) 
  17.             throw new Error("Maximum lock count exceeded"); 
  18.         setState(nextc); 
  19.         return true; 
  20.     } 
  21.     return false; 

 多個線程同時搶占lock,只有一個線程能成功,其他線程怎么排隊呢?排隊的線程怎么搶占鎖呢?這就用到了一個隊列。這個隊列的插入是通過自旋和CAS實現(xiàn)的。

 
 
 
 
  1. private Node addWaiter(Node mode) { 
  2.     Node node = new Node(mode); 
  3.     // 循環(huán)嘗試 
  4.     for (;;) { 
  5.         Node oldTail = tail; 
  6.         if (oldTail != null) { 
  7.             // 無鎖修改前驅(qū)指針 
  8.             node.setPrevRelaxed(oldTail); 
  9.             // CAS修改tail 
  10.             if (compareAndSetTail(oldTail, node)) { 
  11.                 // 修改后續(xù)指針 
  12.                 oldTail.next = node; 
  13.                 return node; 
  14.             } 
  15.         } else { 
  16.             initializeSyncQueue(); 
  17.         } 
  18.     } 

 排隊的線程搶占lock呢?

 
 
 
 
  1. final boolean acquireQueued(final Node node, int arg) { 
  2.     boolean interrupted = false; 
  3.     try { 
  4.         for (;;) { 
  5.             final Node p = node.predecessor(); 
  6.             // 如果前驅(qū)節(jié)點是頭節(jié)點,并且獲取鎖成功,直接返回。 
  7.             // 但是大多數(shù)情況,可能運氣沒這么好 
  8.             if (p == head && tryAcquire(arg)) { 
  9.                 setHead(node); 
  10.                 p.next = null; // help GC 
  11.                 return interrupted; 
  12.             } 
  13.             // 是否需要阻塞 
  14.             if (shouldParkAfterFailedAcquire(p, node)) 
  15.                 // 這里阻塞 
  16.                 interrupted |= parkAndCheckInterrupt(); 
  17.         } 
  18.     } catch (Throwable t) { 
  19.         cancelAcquire(node); 
  20.         if (interrupted) 
  21.             selfInterrupt(); 
  22.         throw t; 
  23.     } 

 怎么喚醒上面阻塞的線程呢?這就要看下釋放邏輯。

 
 
 
 
  1. public final boolean release(int arg) { 
  2.     // 釋放lock 
  3.     if (tryRelease(arg)) { 
  4.         Node h = head; 
  5.         if (h != null && h.waitStatus != 0) 
  6.             unparkSuccessor(h);  // 喚醒頭結(jié)點的后續(xù)節(jié)點。注意頭結(jié)點是虛節(jié)點,沒有實在意義 
  7.         return true; 
  8.     } 
  9.     return false; 

 【編輯推薦】

  1. Windows10這功能已如同殘廢!教你如何徹底關(guān)閉它
  2. C++和C++程序員誰先完蛋?
  3. 2021年值得關(guān)注的人工智能趨勢
  4. RAID磁盤陣列到底適不適合你?一文讀懂
  5. Windows 10是絕唱!微軟新系統(tǒng)開始換版本號了

當(dāng)前題目:查漏補(bǔ)缺synchronized和ReentrantLock的基本原理
轉(zhuǎn)載來于:http://www.5511xx.com/article/dhdeijj.html