AQS 同步佇列共享模式

首先來看看acquireshared()**，

public final void acquireshared(int arg)

tryacquireshared()方法同樣由自定義同步器實現，用來給state原子的加一些操作。如果tryacquireshared()<0說明當前執行緒嘗試獲取資源失敗需要進入同步佇列，來看看doacquireshared()**，

private void doacquireshared(int arg) 
}// 與獨享模式一樣，前乙個節點是signal時
// 進行park掛起當前執行緒等待喚醒
// 如果前乙個節點不是signal或者前乙個節點被取消
// 需要從尾部找到前乙個非null節點
// 最後將前乙個節點置為signal狀態並繼續執行for迴圈
if (shouldparkafte***iledacquire(p, node) &&
parkandcheckinterrupt())
interrupted = true;
}} finally 
}

共享模式較之獨享模式的setheadandpropagate()，

private void setheadandpropagate(node node, int propagate) 
}

與獨享模式不一樣的是，當前節點獲取到資源後還會喚醒下乙個節點進行資源的獲取。

再來看看releaseshared()方法，

public final boolean releaseshared(int arg) 
return false;
}

首先嘗試釋放資源方法，如果前乙個或幾個執行緒已經釋放了共享資源（與獨享模式不一樣的是，獨享模式保證當state最初設定的值時才會喚醒下乙個節點），那麼tryreleaseshared()方法會返回true，然後執行doreleaseshared()方法喚醒下乙個節點，被喚醒的節點會嘗試tryacquireshared()方法。

private void doreleaseshared() 
else if (ws == 0 &&
!compareandsetwaitstatus(h, 0, node.propagate))
continue;               
}// 如果喚醒的後繼節點獲取到資源將頭節點改變
// 退出迴圈
if (h == head)                   
break;}}

假定我們有10個資源，a執行緒正在占用7個，b執行緒正在占用2個，剩餘1個資源

這時c執行緒需要獲取資源，但是需要4個資源才能繼續執行，所以c執行緒到來時初始化同步佇列並將c執行緒加入到同步佇列

此時a執行緒釋放掉乙個資源，喚醒頭節點的下乙個節點嘗試資源的獲取，此時共有2個資源可以獲取，所以c獲取資源失敗

同時又來了乙個執行緒d嘗試獲取資源，d需要3個資源才能繼續執行，d加入同步佇列進行掛起等待資源獲取

此時a再次釋放了乙個資源，喚醒頭節點下乙個節點，失敗（注意！！！這裡體現共享鎖的公平性與非公平性，a再次釋放資源後空閒3個資源，而d正好需要3個資源就可以繼續執行，如果是公平的共享鎖則只會按照佇列順序進行排隊獲取資源；如果是非共享鎖，則d此時可以獲取資源進行下一步操作）

a再次釋放2個資源，b釋放2個資源，嘗試喚醒c，成功，並且c成為頭節點後再次喚醒d也成功（體現共享的一步），頭節點執行的節點是獲取到資源的節點

AQS 同步佇列共享模式

同步器AQS中的同步佇列與等待佇列

CLH同步佇列

執行緒程式設計同步佇列

AQS 同步佇列共享模式

同步器AQS中的同步佇列與等待佇列

CLH同步佇列

執行緒程式設計 同步佇列

相關推薦

執行緒程式設計同步佇列