2019獨角獸企業(yè)重金招聘Python工程師標準>>>

學(xué)習(xí)了AbstractQueuedSynchronizer 之后(Condition沒有在上文做筆記，當應(yīng)該不難理解)，接下來筆者就嘗試著分析在JUC包中的各個同步器，其語義是如何實現(xiàn)的。

ReentrantLock

內(nèi)部類Sync繼承了AbstractQueuedSynchronizer。state表示鎖被重入的次數(shù)。因為其是獨占鎖，所以只實現(xiàn)了tryRelease，isHeldExclusively方法，而tryAcquire則交由子類基于公平和非公平的策略來實現(xiàn)。

公平的ReentrantLock會在每次tryAcquire的時候，都老老實實讓排在隊列前面的線程優(yōu)先拿鎖。而非公平鎖則是發(fā)現(xiàn)state為0后，就馬上去嘗試設(shè)置state，如果不能成功，才進入AQS內(nèi)部的隊列老老實實的排隊。

ReentrantReadWriteLock

此類最為復(fù)雜。內(nèi)部類Sync繼承了AbstractQueuedSynchronizer，同時內(nèi)部類ReadLock和WriteLock內(nèi)部共享了Sync，state這個int被劃分成兩部分，高位16個bit表示共享讀鎖，低位16個bit表示獨占寫鎖。

大概的工作方式是：讀鎖使用shared模式，復(fù)寫tryAcquireShared和tryReleaseShared；寫鎖使用獨占鎖，復(fù)寫tryAcquire和tryRelease。當線程要求鎖住寫鎖的時候，內(nèi)部會檢查state是否為0；如果不為0，則檢查此時是寫狀態(tài)還是讀狀態(tài)；如果是寫狀態(tài)，則檢查持有寫鎖的是否是自己；如果是的話，則進行鎖重入。鎖住讀鎖也是這個道理，只不過是使用的shared的鎖模式而已。

Semaphore

使用state表示信號量。可以想象，使用是的shared模式。在acquire的時候，會去比較state來判斷是否可以成功。

需要注意的是此類如果使用不當，則可能會有線程被掛住的問題，測試代碼可以參見這里：https://gist.github.com/3879133。

CountDownLatch

與Semaphore一樣，都是非常簡單的使用了state。

CyclicBarrier

內(nèi)部使用的是ReentrantLock，利用了Condition來喚醒柵欄前的線程。

FutureTask

使用state來表示任務(wù)的執(zhí)行狀態(tài)。代碼也相對比較簡單。值得注意的是，FutureTask對于任務(wù)執(zhí)行拋出的異常，是會捕捉住的（在get的時候才會給拋給你），如果在編寫任務(wù)時候沒有catch(Exception)，而導(dǎo)致有異常漏過業(yè)務(wù)代碼，則很有可能產(chǎn)生不可預(yù)知的問題。比如，在使用 ScheduledExecutorService分發(fā)定時任務(wù)之后，而又不關(guān)心返回結(jié)果的時候，就可能會出現(xiàn)問題。所以一般對自己的線程，也應(yīng)該處理自己線程的異常，這也是最佳實踐的原則。

原文在我的博客上：http://www.zavakid.com/207

轉(zhuǎn)載于:https://my.oschina.net/zavakid/blog/85008

總結(jié)

以上是生活随笔為你收集整理的Java并发同步器AQS(AbstractQueuedSynchronizer)学习笔记(2)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。