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

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

ReentrantLock

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

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

ReentrantReadWriteLock

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

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

Semaphore

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

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

CountDownLatch

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

CyclicBarrier

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

FutureTask

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

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

轉載于:https://my.oschina.net/zavakid/blog/85008

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。