Java并發(fā)——AQS

AQS通铲,即AbstractQuenedSynchronizer毕莱,顧名思義為抽象的隊(duì)列式同步器。AQS定義了一套多線程訪問共享資源的的同步器框架颅夺,許多同步類的實(shí)現(xiàn)都是依靠這個(gè)框架朋截,比如談并發(fā)就一定會(huì)談的ReentrantLock、Semaphore吧黄、CountDownLatch等质和。它是Java并發(fā)包(java.util.concurrent)里實(shí)現(xiàn)鎖、同步的一個(gè)重要基礎(chǔ)框架稚字。


AQS類維護(hù)了一個(gè)wait quene饲宿,這個(gè)FIFO的等待隊(duì)列是CLH鎖隊(duì)列的變體(a variant of a "CLH" lock queue)。CLH鎖通常用于自旋鎖(spinlocks)胆描。而在AQS中瘫想,CLH鎖被用來阻塞同步器。但是呢昌讲,即使作用有變国夜,其基本的策略(tactic)是相同的,即在節(jié)點(diǎn)(Node)的前驅(qū)節(jié)點(diǎn)(predecessor)中保存一些關(guān)于線程的控制信息短绸。每個(gè)節(jié)點(diǎn)中的 status 字段跟蹤(trace)線程是否應(yīng)該被阻塞车吹。當(dāng)一個(gè)節(jié)點(diǎn)的前驅(qū)節(jié)點(diǎn)被釋放時(shí),前驅(qū)節(jié)點(diǎn)會(huì)通知(signal)當(dāng)前節(jié)點(diǎn)醋闭。

AQS 中的隊(duì)列是由 Node 節(jié)點(diǎn)組成的雙向鏈表實(shí)現(xiàn)的窄驹,那 Node 到達(dá)是什么呢?其實(shí) Node 是 AQS的一個(gè)內(nèi)部類证逻,它是對(duì)訪問同步資源的線程的封裝乐埠,可以簡單理解為一個(gè) Node 代表一個(gè)需要同步的線程及其狀態(tài)。

AQS定義了兩種資源共享的方式:獨(dú)占式( Exclusive ,只能一個(gè)線程獨(dú)享丈咐,如 ReentrantLock )和共享式( Shared 瑞眼,多個(gè)線程可同時(shí)執(zhí)行,如 Semaphore / CountDownLatch )棵逊。

兩種資源共享方式

每個(gè) Node 都有其線程等待狀態(tài)伤疙, Node 類維護(hù)一個(gè) waitStatus 變量來表明這些狀態(tài):


waitStatus的取值
  • CANCELLED:值為1,在同步隊(duì)列中等待的線程等待超時(shí)或被中斷辆影,需要從同步隊(duì)列中取消該Node的結(jié)點(diǎn)徒像,其結(jié)點(diǎn)的waitStatus為CANCELLED,即結(jié)束狀態(tài)秸歧,進(jìn)入該狀態(tài)后的結(jié)點(diǎn)將不會(huì)再變化厨姚。

  • SIGNAL:值為-1衅澈,被標(biāo)識(shí)為該等待喚醒狀態(tài)的后繼結(jié)點(diǎn)键菱,當(dāng)其前繼結(jié)點(diǎn)的線程釋放了同步鎖或被取消,將會(huì)通知該后繼結(jié)點(diǎn)的線程執(zhí)行今布。說白了经备,就是處于喚醒狀態(tài),只要前繼結(jié)點(diǎn)釋放鎖部默,就會(huì)通知標(biāo)識(shí)為SIGNAL狀態(tài)的后繼結(jié)點(diǎn)的線程執(zhí)行侵蒙。

  • CONDITION:值為-2,與Condition相關(guān)傅蹂,該標(biāo)識(shí)的結(jié)點(diǎn)處于等待隊(duì)列中纷闺,結(jié)點(diǎn)的線程等待在Condition上,當(dāng)其他線程調(diào)用了Condition的signal()方法后份蝴,CONDITION狀態(tài)的結(jié)點(diǎn)將從等待隊(duì)列轉(zhuǎn)移到同步隊(duì)列中犁功,等待獲取同步鎖。

  • PROPAGATE:值為-3婚夫,與共享模式相關(guān)浸卦,在共享模式中,該狀態(tài)標(biāo)識(shí)結(jié)點(diǎn)的線程處于可運(yùn)行狀態(tài)案糙。

  • 0狀態(tài):值為0限嫌,代表初始化狀態(tài)。

waitStatus

寫入等待隊(duì)列 addWaiter()

  • 為當(dāng)前的線程以及傳入的資源共享方式(mode)構(gòu)建一個(gè) Node 對(duì)象 node 时捌;
  • 如果當(dāng)前隊(duì)列不為空怒医,那么就將當(dāng)前線程對(duì)應(yīng)節(jié)點(diǎn)的前驅(qū)節(jié)點(diǎn)設(shè)為當(dāng)前尾節(jié)點(diǎn) pred(try the fast path of enq);
  • 使用 CAS 設(shè)置 node 為隊(duì)列尾節(jié)點(diǎn)奢讨,如果設(shè)置成功裆熙,就把之前的尾節(jié)點(diǎn) pred 指向當(dāng)前尾節(jié)點(diǎn) node,并將 node 返回;
  • 如果當(dāng)前隊(duì)列為空入录,調(diào)用 enq() 將 node 入隊(duì)蛤奥,并返回 node 。(backup to full enq on failure)

入隊(duì) enq( Node )

  • 如果隊(duì)列為空僚稿,使用 CAS 將隊(duì)列初始化凡桥;
  • 如果隊(duì)列不為空,將傳入節(jié)點(diǎn) node 的前驅(qū)節(jié)點(diǎn)設(shè)置為當(dāng)前尾節(jié)點(diǎn)蚀同,然后將 node 設(shè)置為新的尾節(jié)點(diǎn)缅刽,并使之前尾節(jié)點(diǎn)指向當(dāng)前尾節(jié)點(diǎn),最后返回 node 的前驅(qū)節(jié)點(diǎn)(node's predecessor)蠢络。

aquire( int )

獨(dú)占模式下獲取資源

這個(gè)方法是在獨(dú)占模式下線程獲取共享資源的頂級(jí)入口衰猛,如果獲取到資源,則返回刹孔,否則線程進(jìn)入等待隊(duì)列啡省,知道獲取到資源為止。這個(gè)方法忽略中斷髓霞,可以用來實(shí)現(xiàn) Lock 接口的 lock 方法卦睹。

這個(gè)方法的流程如下:

  1. tryAcquire()嘗試直接去獲取資源,如果成功則直接返回方库;

  2. addWaiter()將該線程加入等待隊(duì)列的尾部结序,并標(biāo)記為獨(dú)占模式;

  3. acquireQueued()使線程在等待隊(duì)列中獲取資源纵潦,一直獲取到資源后才返回徐鹤。如果在整個(gè)等待過程中被中斷過,則返回true邀层,否則返回false返敬。

  4. 如果線程在等待過程中被中斷過,它是不響應(yīng)的被济。只是獲取資源后才再進(jìn)行自我中斷selfInterrupt()救赐,將中斷補(bǔ)上。


aquire() 方法的傳入?yún)?shù)先輩傳給 tryAcquire( int ) 方法只磷,這個(gè)方法如下:

tryAcquire( int )

tryAcquire( int )

這個(gè)方法體其實(shí)沒有提供實(shí)現(xiàn)经磅,只是給出了一異常,這也是 AQS 被當(dāng)做一個(gè)框架的原因钮追,具體的資源獲取方式交給自定義的同步器去實(shí)現(xiàn)≡ぱ幔現(xiàn)在我們只需知道這個(gè)方式是在嘗試獲取資源。

acquireQuened( Node, int )

acquireQuened( Node, int )

aquire() 方法中元媚,如果嘗試獲取資源失敗轧叽,那么就將當(dāng)前線程放入隊(duì)列中苗沧。acquireQuened() 的作用就是在隊(duì)列中等待被喚醒,直到被喚醒炭晒,也是在做“自旋”待逞。

  • failed 定義了線程是否獲取資源;
  • interrupted 定義了線程是否被中斷网严;
  • 在自旋中線程做的事:首先獲取 node 的前驅(qū)節(jié)點(diǎn) p 识樱,如果 p 是頭結(jié)點(diǎn),也就是說 node 是第二個(gè)節(jié)點(diǎn)震束,并且嘗試獲取資源成功的話怜庸,將 node 節(jié)點(diǎn)設(shè)置為頭結(jié)點(diǎn),將對(duì)象 p 的后繼節(jié)點(diǎn)垢村,也就是之前的頭結(jié)點(diǎn)置空割疾,方便 GC 回收內(nèi)存空間。
  • 將線程獲取資源失敗置為 false 嘉栓,并返回未被中斷的結(jié)果宏榕;
  • 如果沒有獲取到資源,那就在隊(duì)列里等待胸懈,直到被 unpark() 担扑。

未完待續(xù)

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末恰响,一起剝皮案震驚了整個(gè)濱河市趣钱,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌胚宦,老刑警劉巖首有,帶你破解...
    沈念sama閱讀 216,496評(píng)論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異枢劝,居然都是意外死亡井联,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,407評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門您旁,熙熙樓的掌柜王于貴愁眉苦臉地迎上來烙常,“玉大人,你說我怎么就攤上這事鹤盒〔显啵” “怎么了?”我有些...
    開封第一講書人閱讀 162,632評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵侦锯,是天一觀的道長驼鞭。 經(jīng)常有香客問我,道長尺碰,這世上最難降的妖魔是什么挣棕? 我笑而不...
    開封第一講書人閱讀 58,180評(píng)論 1 292
  • 正文 為了忘掉前任译隘,我火速辦了婚禮,結(jié)果婚禮上洛心,老公的妹妹穿的比我還像新娘固耘。我一直安慰自己,他們只是感情好词身,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,198評(píng)論 6 388
  • 文/花漫 我一把揭開白布玻驻。 她就那樣靜靜地躺著,像睡著了一般偿枕。 火紅的嫁衣襯著肌膚如雪璧瞬。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,165評(píng)論 1 299
  • 那天渐夸,我揣著相機(jī)與錄音嗤锉,去河邊找鬼。 笑死墓塌,一個(gè)胖子當(dāng)著我的面吹牛瘟忱,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播苫幢,決...
    沈念sama閱讀 40,052評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼访诱,長吁一口氣:“原來是場噩夢(mèng)啊……” “哼!你這毒婦竟也來了韩肝?” 一聲冷哼從身側(cè)響起触菜,我...
    開封第一講書人閱讀 38,910評(píng)論 0 274
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎哀峻,沒想到半個(gè)月后涡相,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,324評(píng)論 1 310
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡剩蟀,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,542評(píng)論 2 332
  • 正文 我和宋清朗相戀三年催蝗,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片育特。...
    茶點(diǎn)故事閱讀 39,711評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡丙号,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出缰冤,到底是詐尸還是另有隱情犬缨,我是刑警寧澤,帶...
    沈念sama閱讀 35,424評(píng)論 5 343
  • 正文 年R本政府宣布锋谐,位于F島的核電站遍尺,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏涮拗。R本人自食惡果不足惜乾戏,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,017評(píng)論 3 326
  • 文/蒙蒙 一迂苛、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧鼓择,春花似錦三幻、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,668評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至摆出,卻和暖如春朗徊,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背偎漫。 一陣腳步聲響...
    開封第一講書人閱讀 32,823評(píng)論 1 269
  • 我被黑心中介騙來泰國打工爷恳, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人象踊。 一個(gè)月前我還...
    沈念sama閱讀 47,722評(píng)論 2 368
  • 正文 我出身青樓温亲,卻偏偏與公主長得像,于是被迫代替她去往敵國和親杯矩。 傳聞我的和親對(duì)象是個(gè)殘疾皇子栈虚,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,611評(píng)論 2 353

推薦閱讀更多精彩內(nèi)容