溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

JAVA并發(fā)工具常用設計的示例分析

發(fā)布時間:2021-07-24 09:40:08 來源:億速云 閱讀:145 作者:小新 欄目:編程語言

這篇文章主要介紹JAVA并發(fā)工具常用設計的示例分析,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!

前言

在學習JAVA并發(fā)工具時,分析JUC下的源碼,發(fā)現(xiàn)有三個利器:狀態(tài)、隊列、CAS。

狀態(tài)

一般是state屬性,如AQS源碼中的狀態(tài),是整個工具的核心,一般操作的執(zhí)行都要看當前狀態(tài)是什么,
由于狀態(tài)是多線程共享的,所以都是volatile修飾,保證線程直接內存可見。

/**
* AbstractQueuedSynchronizer中的狀態(tài)
*/
private volatile int state;

/**
* Status field, taking on only the values:
* SIGNAL: The successor of this node is (or will soon be)
* blocked (via park), so the current node must
* unpark its successor when it releases or
* cancels. To avoid races, acquire methods must
* first indicate they need a signal,
* then retry the atomic acquire, and then,
* on failure, block.
* CANCELLED: This node is cancelled due to timeout or interrupt.
* Nodes never leave this state. In particular,
* a thread with cancelled node never again blocks.
* CONDITION: This node is currently on a condition queue.
* It will not be used as a sync queue node
* until transferred, at which time the status
* will be set to 0. (Use of this value here has
* nothing to do with the other uses of the
* field, but simplifies mechanics.)
* PROPAGATE: A releaseShared should be propagated to other
* nodes. This is set (for head node only) in
* doReleaseShared to ensure propagation
* continues, even if other operations have
* since intervened.
* 0: None of the above
*
* The values are arranged numerically to simplify use.
* Non-negative values mean that a node doesn't need to
* signal. So, most code doesn't need to check for particular
* values, just for sign.
*
* The field is initialized to 0 for normal sync nodes, and
* CONDITION for condition nodes. It is modified using CAS
* (or when possible, unconditional volatile writes).
*/
volatile int waitStatus;

隊列

隊列一般由鏈表實現(xiàn)(單向鏈表,雙向鏈表),在線程獲取不到想要的資源或者狀態(tài)時,將線程封裝成特定節(jié)點,扔到等待隊列中,等待時機成熟,再從隊列中取出,是悲觀鎖思想。
如AQS中的Node節(jié)點,代碼太長就不貼了。

CAS

CAS操作是樂觀鎖思想,是輕量級的并發(fā)處理。一般用于對上述狀態(tài)的修改,而且能保證有且只有一個線程能修改這個狀態(tài)。
一般由Unsafe類中的compareAndSwap之類的方法實現(xiàn)。使用CAS,往往伴隨自旋,如果修改狀態(tài)失敗,則不斷地重試,直到修改狀態(tài)成功。

以上是“JAVA并發(fā)工具常用設計的示例分析”這篇文章的所有內容,感謝各位的閱讀!希望分享的內容對大家有幫助,更多相關知識,歡迎關注億速云行業(yè)資訊頻道!

向AI問一下細節(jié)

免責聲明:本站發(fā)布的內容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內容。

AI