一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - Java教程 - Java中的15種鎖

Java中的15種鎖

2022-01-07 13:12IT老哥 Java教程

在讀很多并發文章中,會提及各種各樣鎖如公平鎖,樂觀鎖等等,這篇文章小編將向大家介紹是各種鎖的分類,感興趣的小伙伴可以參考下面文章的具體內容

在讀很多并發文章中,會提及各種各樣鎖如公平鎖,樂觀鎖等等,這篇文章介紹各種鎖的分類。介紹的內容如下:

  • 公平鎖 / 非公平鎖
  • 可重入鎖 / 不可重入鎖
  • 獨享鎖 / 共享鎖
  • 互斥鎖 / 讀寫鎖
  • 樂觀鎖 / 悲觀鎖
  • 分段鎖
  • 偏向鎖 / 輕量級鎖 / 重量級鎖
  • 自旋鎖

上面是很多鎖的名詞,這些分類并不是全是指鎖的狀態,有的指鎖的特性,有的指鎖的設計,下面總結的內容是對每個鎖的名詞進行一定的解釋。

一、公平鎖 / 非公平鎖

1、公平鎖

公平鎖是指多個線程按照申請鎖的順序來獲取鎖。

2、非公平鎖

非公平鎖是指多個線程獲取鎖的順序并不是按照申請鎖的順序,有可能后申請的線程比先申請的線程優先獲取鎖。有可能,會造成優先級反轉或者饑餓現象。

對于Java ReentrantLock而言,通過構造函數指定該鎖是否是公平鎖,默認是非公平鎖。非公平鎖的優點在于吞吐量比公平鎖大。
對于Synchronized而言,也是一種非公平鎖。由于其并不像ReentrantLock是通過AQS的來實現線程調度,所以并沒有任何辦法使其變成公平鎖。

二、可重入鎖 / 不可重入鎖

1、可重入鎖

廣義上的可重入鎖指的是可重復可遞歸調用的鎖,在外層使用鎖之后,在內層仍然可以使用,并且不發生死鎖(前提得是同一個對象或者class),這樣的鎖就叫做可重入鎖。ReentrantLocksynchronized都是可重入鎖

?
1
2
3
4
5
6
7
synchronized void setA() throws Exception{
   Thread.sleep(1000);
   setB();
}
synchronized void setB() throws Exception{
   Thread.sleep(1000);
}

上面的代碼就是一個可重入鎖的一個特點,如果不是可重入鎖的話,setB可能不會被當前線程執行,可能造成死鎖。

2、不可重入鎖

不可重入鎖,與可重入鎖相反,不可遞歸調用,遞歸調用就發生死鎖。看到一個經典的講解,使用自旋鎖來模擬一個不可重入鎖,代碼如下

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import java.util.concurrent.atomic.AtomicReference;
 
public class UnreentrantLock {
 
   private AtomicReference<Thread> owner = new AtomicReference<Thread>();
 
   public void lock() {
       Thread current = Thread.currentThread();
       //這句是很經典的“自旋”語法,AtomicInteger中也有
       for (;;) {
           if (!owner.compareAndSet(null, current)) {
               return;
           }
       }
   }
 
   public void unlock() {
       Thread current = Thread.currentThread();
       owner.compareAndSet(current, null);
   }
}

代碼也比較簡單,使用原子引用來存放線程,同一線程兩次調用lock()方法,如果不執行unlock()釋放鎖的話,第二次調用自旋的時候就會產生死鎖,這個鎖就不是可重入的,而實際上同一個線程不必每次都去釋放鎖再來獲取鎖,這樣的調度切換是很耗資源的。

把它變成一個可重入鎖:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
import java.util.concurrent.atomic.AtomicReference;
 
public class UnreentrantLock {
 
   private AtomicReference<Thread> owner = new AtomicReference<Thread>();
   private int state = 0;
 
   public void lock() {
       Thread current = Thread.currentThread();
       if (current == owner.get()) {
           state++;
           return;
       }
       //這句是很經典的“自旋”式語法,AtomicInteger中也有
       for (;;) {
           if (!owner.compareAndSet(null, current)) {
               return;
           }
       }
   }
 
   public void unlock() {
       Thread current = Thread.currentThread();
       if (current == owner.get()) {
           if (state != 0) {
               state--;
           } else {
               owner.compareAndSet(current, null);
           }
       }
   }
}

在執行每次操作之前,判斷當前鎖持有者是否是當前對象,采用state計數,不用每次去釋放鎖。

3、ReentrantLock中可重入鎖實現

這里看非公平鎖的鎖獲取方法:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
final boolean nonfairTryAcquire(int acquires) {
   final Thread current = Thread.currentThread();
   int c = getState();
   if (c == 0) {
       if (compareAndSetState(0, acquires)) {
           setExclusiveOwnerThread(current);
           return true;
       }
   }
   //就是這里
   else if (current == getExclusiveOwnerThread()) {
       int nextc = c + acquires;
       if (nextc < 0) // overflow
           throw new Error("Maximum lock count exceeded");
       setState(nextc);
       return true;
   }
   return false;
}

在AQS中維護了一個private volatile int state來計數重入次數,避免了頻繁的持有釋放操作,這樣既提升了效率,又避免了死鎖。

三、獨享鎖 / 共享鎖

獨享鎖和共享鎖在你去讀C.U.T包下的ReeReentrantLockReentrantReadWriteLock你就會發現,它倆一個是獨享一個是共享鎖。

  • 獨享鎖:該鎖每一次只能被一個線程所持有。
  • 共享鎖:該鎖可被多個線程共有,典型的就是ReentrantReadWriteLock里的讀鎖,它的讀鎖是可以被共享的,但是它的寫鎖確每次只能被獨占。

另外讀鎖的共享可保證并發讀是非常高效的,但是讀寫和寫寫,寫讀都是互斥的。

獨享鎖與共享鎖也是通過AQS來實現的,通過實現不同的方法,來實現獨享或者共享。
對于Synchronized而言,當然是獨享鎖。

四、互斥鎖 / 讀寫鎖

1、互斥鎖

在訪問共享資源之前對進行加鎖操作,在訪問完成之后進行解鎖操作。加鎖后,任何其他試圖再次加鎖的線程會被阻塞,直到當前進程解鎖。

如果解鎖時有一個以上的線程阻塞,那么所有該鎖上的線程都被編程就緒狀態, 第一個變為就緒狀態的線程又執行加鎖操作,那么其他的線程又會進入等待。在這種方式下,只有一個線程能夠訪問被互斥鎖保護的資源

2、讀寫鎖

讀寫鎖既是互斥鎖,又是共享鎖,read模式是共享,write是互斥(排它鎖)的。

讀寫鎖有三種狀態:讀加鎖狀態、寫加鎖狀態和不加鎖狀態

讀寫鎖在Java中的具體實現就是ReadWriteLock

一次只有一個線程可以占有寫模式的讀寫鎖,但是多個線程可以同時占有讀模式的讀寫鎖。
只有一個線程可以占有寫狀態的鎖,但可以有多個線程同時占有讀狀態鎖,這也是它可以實現高并發的原因。當其處于寫狀態鎖下,任何想要嘗試獲得鎖的線程都會被阻塞,直到寫狀態鎖被釋放;如果是處于讀狀態鎖下,允許其它線程獲得它的讀狀態鎖,但是不允許獲得它的寫狀態鎖,直到所有線程的讀狀態鎖被釋放;為了避免想要嘗試寫操作的線程一直得不到寫狀態鎖,當讀寫鎖感知到有線程想要獲得寫狀態鎖時,便會阻塞其后所有想要獲得讀狀態鎖的線程。所以讀寫鎖非常適合資源的讀操作遠多于寫操作的情況。

五、樂觀鎖 / 悲觀鎖

1、悲觀鎖

總是假設最壞的情況,每次去拿數據的時候都認為別人會修改,所以每次在拿數據的時候都會上鎖,這樣別人想拿這個數據就會阻塞直到它拿到鎖(共享資源每次只給一個線程使用,其它線程阻塞,用完后再把資源轉讓給其它線程)。傳統的關系型數據庫里邊就用到了很多這種鎖機制,比如行鎖,表鎖等,讀鎖,寫鎖等,都是在做操作之前先上鎖。Java中synchronizedReentrantLock等獨占鎖就是悲觀鎖思想的實現。

2、樂觀鎖

總是假設最好的情況,每次去拿數據的時候都認為別人不會修改,所以不會上鎖,但是在更新的時候會判斷一下在此期間別人有沒有去更新這個數據,可以使用版本號機制和CAS算法實現。樂觀鎖適用于多讀的應用類型,這樣可以提高吞吐量,像數據庫提供的類似于write_condition機制,其實都是提供的樂觀鎖。在Java中java.util.concurrent.atomic包下面的原子變量類就是使用了樂觀鎖的一種實現方式CAS實現的。

六、分段鎖

分段鎖其實是一種鎖的設計,并不是具體的一種鎖,對于ConcurrentHashMap而言,其并發的實現就是通過分段鎖的形式來實現高效的并發操作。

并發容器類的加鎖機制是基于粒度更小的分段鎖,分段鎖也是提升多并發程序性能的重要手段之一。

在并發程序中,串行操作是會降低可伸縮性,并且上下文切換也會減低性能。在鎖上發生競爭時將通水導致這兩種問題,使用獨占鎖時保護受限資源的時候,基本上是采用串行方式—-每次只能有一個線程能訪問它。所以對于可伸縮性來說最大的威脅就是獨占鎖。

我們一般有三種方式降低鎖的競爭程度:

  • 減少鎖的持有時間
  • 降低鎖的請求頻率
  • 使用帶有協調機制的獨占鎖,這些機制允許更高的并發性。

在某些情況下我們可以將鎖分解技術進一步擴展為一組獨立對象上的鎖進行分解,這成為分段鎖。

其實說的簡單一點就是:

容器里有多把鎖,每一把鎖用于鎖容器其中一部分數據,那么當多線程訪問容器里不同數據段的數據時,線程間就不會存在鎖競爭,從而可以有效的提高并發訪問效率,這就是ConcurrentHashMap所使用的鎖分段技術,首先將數據分成一段一段的存儲,然后給每一段數據配一把鎖,當一個線程占用鎖訪問其中一個段數據的時候,其他段的數據也能被其他線程訪問。

比如:ConcurrentHashMap中使用了一個包含16個鎖的數組,每個鎖保護所有散列桶的1/16,其中第N個散列桶由第(N mod 16)個鎖來保護。假設使用合理的散列算法使關鍵字能夠均勻的分部,那么這大約能使對鎖的請求減少到越來的1/16。也正是這項技術使得ConcurrentHashMap支持多達16個并發的寫入線程。

七、偏向鎖 / 輕量級鎖 / 重量級鎖

1、鎖的狀態

  • 無鎖狀態
  • 偏向鎖狀態
  • 輕量級鎖狀態
  • 重量級鎖狀態

鎖的狀態是通過對象監視器在對象頭中的字段來表明的。
四種狀態會隨著競爭的情況逐漸升級,而且是不可逆的過程,即不可降級。
這四種狀態都不是Java語言中的鎖,而是Jvm為了提高鎖的獲取與釋放效率而做的優化(使用synchronized時)。

2、偏向鎖

偏向鎖是指一段同步代碼一直被一個線程所訪問,那么該線程會自動獲取鎖。降低獲取鎖的代價。

3、輕量級

輕量級鎖是指當鎖是偏向鎖的時候,被另一個線程所訪問,偏向鎖就會升級為輕量級鎖,其他線程會通過自旋的形式嘗試獲取鎖,不會阻塞,提高性能。

4、重量級鎖

重量級鎖是指當鎖為輕量級鎖的時候,另一個線程雖然是自旋,但自旋不會一直持續下去,當自旋一定次數的時候,還沒有獲取到鎖,就會進入阻塞,該鎖膨脹為重量級鎖。重量級鎖會讓其他申請的線程進入阻塞,性能降低。

八、自旋鎖

我們知道CAS算法是樂觀鎖的一種實現方式,CAS算法中又涉及到自旋鎖,所以這里給大家講一下什么是自旋鎖。

簡單回顧一下CAS算法:

CAS是英文單詞Compare and Swap(比較并交換),是一種有名的無鎖算法。無鎖編程,即不使用鎖的情況下實現多線程之間的變量同步,也就是在沒有線程被阻塞的情況下實現變量的同步,所以也叫非阻塞同步(Non-blocking Synchronization)。CAS算法涉及到三個操作數

  • 需要讀寫的內存值 V
  • 進行比較的值 A
  • 擬寫入的新值 B

更新一個變量的時候,只有當變量的預期值A和內存地址V當中的實際值相同時,才會將內存地址V對應的值修改為B,否則不會執行任何操作。一般情況下是一個自旋操作,即不斷的重試。

1、什么是自旋鎖?

自旋鎖(spinlock):是指當一個線程在獲取鎖的時候,如果鎖已經被其它線程獲取,那么該線程將循環等待,然后不斷的判斷鎖是否能夠被成功獲取,直到獲取到鎖才會退出循環。

它是為實現保護共享資源而提出一種鎖機制。其實,自旋鎖與互斥鎖比較類似,它們都是為了解決對某項資源的互斥使用。無論是互斥鎖,還是自旋鎖,在任何時刻,最多只能有一個保持者,也就說,在任何時刻最多只能有一個執行單元獲得鎖。但是兩者在調度機制上略有不同。對于互斥鎖,如果資源已經被占用,資源申請者只能進入睡眠狀態。但是自旋鎖不會引起調用者睡眠,如果自旋鎖已經被別的執行單元保持,調用者就一直循環在那里看是否該自旋鎖的保持者已經釋放了鎖,”自旋”一詞就是因此而得名。

2、Java如何實現自旋鎖?

下面是個簡單的例子:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
public class SpinLock {
   private AtomicReference<Thread> cas = new AtomicReference<Thread>();
   public void lock() {
       Thread current = Thread.currentThread();
       // 利用CAS
       while (!cas.compareAndSet(null, current)) {
           // DO nothing
       }
   }
   public void unlock() {
       Thread current = Thread.currentThread();
       cas.compareAndSet(current, null);
   }
}

lock()方法利用的CAS,當第一個線程A獲取鎖的時候,能夠成功獲取到,不會進入while循環,如果此時線程A沒有釋放鎖,另一個線程B又來獲取鎖,此時由于不滿足CAS,所以就會進入while循環,不斷判斷是否滿足CAS,直到A線程調用unlock方法釋放了該鎖。

3、自旋鎖存在的問題

  • 如果某個線程持有鎖的時間過長,就會導致其它等待獲取鎖的線程進入循環等待,消耗CPU。使用不當會造成CPU使用率極高。
  • 上面Java實現的自旋鎖不是公平的,即無法滿足等待時間最長的線程優先獲取鎖。不公平的鎖就會存在“線程饑餓”問題。

4、自旋鎖的優點

  • 自旋鎖不會使線程狀態發生切換,一直處于用戶態,即線程一直都是active的;不會使線程進入阻塞狀態,減少了不必要的上下文切換,執行速度快
  • 非自旋鎖在獲取不到鎖的時候會進入阻塞狀態,從而進入內核態,當獲取到鎖的時候需要從內核態恢復,需要線程上下文切換。(線程被阻塞后便進入內核(Linux)調度狀態,這個會導致系統在用戶態與內核態之間來回切換,嚴重影響鎖的性能)

可重入的自旋鎖和不可重入的自旋鎖:

文章開始的時候的那段代碼,仔細分析一下就可以看出,它是不支持重入的,即當一個線程第一次已經獲取到了該鎖,在鎖釋放之前又一次重新獲取該鎖,第二次就不能成功獲取到。由于不滿足CAS,所以第二次獲取會進入while循環等待,而如果是可重入鎖,第二次也是應該能夠成功獲取到的。

而且,即使第二次能夠成功獲取,那么當第一次釋放鎖的時候,第二次獲取到的鎖也會被釋放,而這是不合理的。

為了實現可重入鎖,我們需要引入一個計數器,用來記錄獲取鎖的線程數。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
public class ReentrantSpinLock {
   private AtomicReference<Thread> cas = new AtomicReference<Thread>();
   private int count;
   public void lock() {
       Thread current = Thread.currentThread();
       if (current == cas.get()) { // 如果當前線程已經獲取到了鎖,線程數增加一,然后返回
           count++;
           return;
       }
       // 如果沒獲取到鎖,則通過CAS自旋
       while (!cas.compareAndSet(null, current)) {
           // DO nothing
       }
   }
   public void unlock() {
       Thread cur = Thread.currentThread();
       if (cur == cas.get()) {
           if (count > 0) {// 如果大于0,表示當前線程多次獲取了該鎖,釋放鎖通過count減一來模擬
               count--;
           } else {// 如果count==0,可以將鎖釋放,這樣就能保證獲取鎖的次數與釋放鎖的次數是一致的了。
               cas.compareAndSet(cur, null);
           }
       }
   }

5、自旋鎖與互斥鎖

  • 自旋鎖與互斥鎖都是為了實現保護資源共享的機制。
  • 無論是自旋鎖還是互斥鎖,在任意時刻,都最多只能有一個保持者。
  • 獲取互斥鎖的線程,如果鎖已經被占用,則該線程將進入睡眠狀態;獲取自旋鎖的線程則不會睡眠,而是一直循環等待鎖釋放。

自旋鎖總結:

  1. 自旋鎖:線程獲取鎖的時候,如果鎖被其他線程持有,則當前線程將循環等待,直到獲取到鎖。
  2. 自旋鎖等待期間,線程的狀態不會改變,線程一直是用戶態并且是活動的(active)。
  3. 自旋鎖如果持有鎖的時間太長,則會導致其它等待獲取鎖的線程耗盡CPU。
  4. 自旋鎖本身無法保證公平性,同時也無法保證可重入性。
  5. 基于自旋鎖,可以實現具備公平性和可重入性質的鎖。

到此這篇關于Java中的15種鎖的文章就介紹到這了,更多相關Java中的鎖內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家!

原文鏈接:https://juejin.cn/post/6966060576489340958

延伸 · 閱讀

精彩推薦
  • Java教程升級IDEA后Lombok不能使用的解決方法

    升級IDEA后Lombok不能使用的解決方法

    最近看到提示IDEA提示升級,尋思已經有好久沒有升過級了。升級完畢重啟之后,突然發現好多錯誤,本文就來介紹一下如何解決,感興趣的可以了解一下...

    程序猿DD9332021-10-08
  • Java教程Java使用SAX解析xml的示例

    Java使用SAX解析xml的示例

    這篇文章主要介紹了Java使用SAX解析xml的示例,幫助大家更好的理解和學習使用Java,感興趣的朋友可以了解下...

    大行者10067412021-08-30
  • Java教程小米推送Java代碼

    小米推送Java代碼

    今天小編就為大家分享一篇關于小米推送Java代碼,小編覺得內容挺不錯的,現在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧...

    富貴穩中求8032021-07-12
  • Java教程Java實現搶紅包功能

    Java實現搶紅包功能

    這篇文章主要為大家詳細介紹了Java實現搶紅包功能,采用多線程模擬多人同時搶紅包,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙...

    littleschemer13532021-05-16
  • Java教程20個非常實用的Java程序代碼片段

    20個非常實用的Java程序代碼片段

    這篇文章主要為大家分享了20個非常實用的Java程序片段,對java開發項目有所幫助,感興趣的小伙伴們可以參考一下 ...

    lijiao5352020-04-06
  • Java教程xml與Java對象的轉換詳解

    xml與Java對象的轉換詳解

    這篇文章主要介紹了xml與Java對象的轉換詳解的相關資料,需要的朋友可以參考下...

    Java教程網2942020-09-17
  • Java教程Java8中Stream使用的一個注意事項

    Java8中Stream使用的一個注意事項

    最近在工作中發現了對于集合操作轉換的神器,java8新特性 stream,但在使用中遇到了一個非常重要的注意點,所以這篇文章主要給大家介紹了關于Java8中S...

    阿杜7482021-02-04
  • Java教程Java BufferWriter寫文件寫不進去或缺失數據的解決

    Java BufferWriter寫文件寫不進去或缺失數據的解決

    這篇文章主要介紹了Java BufferWriter寫文件寫不進去或缺失數據的解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望...

    spcoder14552021-10-18
主站蜘蛛池模板: 欧美洲大黑香蕉在线视频 | 亚洲第一色网站 | 免费看美女被靠到爽 | 草莓在深夜释放自己软件 | 欧美成人免费草草影院视频 | 女人把私密部位张开让男人桶 | 国产精品午夜久久 | 国产真实乱子伦xxxxchina | 精品视频网站 | 国产视频三区 | 亚洲高清成人 | 日本肉体xxxx69xxxx | 视频大全在线观看网址 | 91狠狠 | 小柔的性放荡羞辱日记动漫 | julianann在厨房 | 好姑娘完整版在线观看中文 | 久久午夜夜伦痒痒想咳嗽P 久久无码AV亚洲精品色午夜麻豆 | 成人男女网免费 | 5g影院天天影院天天爽影院网站 | 亚洲国产精品综合久久一线 | 9总探花新品牛仔背带裤 | 好大好硬好长好爽a网站 | 久久伊人久久 | 韩国女主播一区二区视频 | 国产最强大片免费视频 | 99re这里只有精品在线观看 | 日本四虎影视 | 国产黄频 | 亚洲精品综合一二三区在线 | 亚洲色欲色欲综合网站 | 日本天堂视频在线观看 | 亚洲国产99999在线精品一区 | 欧美一区二区不卡视频 | 日本精品久久久久久久久免费 | 成人天堂入口网站 | 午夜国产精品 | 亚洲国产99在线精品一区二区 | 欧美专区综合 | 亚洲成a人不卡在线观看 | 911精品国产亚洲日本美国韩国 |