您好,登錄后才能下訂單哦!
這期內容當中小編將會給大家帶來有關并發編程之Semaphore的使用方法,文章內容豐富且以專業的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
線程去獲取鎖首先查看線程是否有中斷標志,有就拋異常,沒有就嘗試去獲取鎖,代碼如下:
如果隊列是空的,獲取當前抽象隊列的state,當前的state-資源數的差值大于0(說明嘗試獲取鎖成功),cas將當前state改成差值,并返回(整個過程自旋+cas保證了嘗試獲取鎖成功并修改state的原子性。);如果隊列有排隊的節點(嘗試獲取鎖失敗返回-1)或者隊列沒有排隊節點但是差值小于0(嘗試獲取鎖失敗,資源數太多)就要入隊,代碼如下:
這里和排他鎖的區別是參數為共享模式,同樣隊列為空就初始化隊列(自旋+cas保證了初始化隊列的原子性),不為空就入隊。判斷當前節點的前節點是否是head節點,如果是,再次嘗試獲取鎖,如果失敗,或者當前節點的前節點不是head就將前節點的ws改為-1,阻塞當前線程park。
如果有線程釋放鎖,代碼如下:
嘗試釋放共享鎖,代碼如下:
獲取抽象隊列的state,將state+1(不一定為+1)的和,cas將state修改成和,嘗試釋放鎖成功。喚醒后續節點,代碼如下:
喚醒頭節點把頭節點的ws=-1,將其修改為0,然后喚醒,代碼如下:
如果頭節點的ws=-1<0將其cas為0,下一個節點不為空,unpark(下一節點的線程),線程在阻塞的位置被喚醒,嘗試獲取鎖,代碼如下:
在循環中被喚醒,繼續嘗試獲取鎖,如果和上一次一樣失敗,則繼續park阻塞。嘗試獲取鎖成功int r = tryAcquireShared(arg)>=0,代碼如下:
將當前節點設置為head(head=當前節點,當前節點的pre=null,thread=null)意味著前節點要被踢出隊列(差一步修改前節點的next=null),當前節點下一節點為空,將前節點的next=null,前節點出隊完成,獲取鎖成功;
反之下一節點不為空(下一節點會在阻塞park前將前節點的ws=-1)并且為共享模式釋放鎖,代碼如下:
這里會將新的頭節點的ws=-1改為0,喚醒下一節點,代碼如下:
喚醒下一線程,下一線程在阻塞的循環中被喚醒,嘗試獲取鎖,失敗再次阻塞park,成功就繼續這一步驟,一直傳播下去,也就是喚醒多個節點
上述就是小編為大家分享的并發編程之Semaphore的使用方法了,如果剛好有類似的疑惑,不妨參照上述分析進行理解。如果想知道更多相關知識,歡迎關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。