AQS基本原理

AQS是Abstract Queued Synchronizer的簡稱。AQS提供了一種實現(xiàn)阻塞鎖和一系列依賴FIFO等待隊列的同步器的框架。

從使用層面來說，AQS的功能分為兩種：獨占和共享。

• 獨占鎖，每次只能有一個線程持有鎖，比如前面給大家演示的ReentrantLock就是以獨占方式實現(xiàn)的互斥鎖；
• 共享鎖，允許多個線程同時獲取鎖，并發(fā)訪問共享資源，比如ReentrantReadWriteLock。

AQS內(nèi)部有以下幾個重要的數(shù)據(jù)結(jié)構(gòu)：

• state變量，記錄鎖定狀態(tài)，默認0
• 加鎖線程變量，記錄當前持有鎖的是哪個線程，默認null
• 線程等待隊列

以ReentrantLock為例，加鎖代碼如下：

ReentrantLock lock = new ReentrantLock();
lock.lock();
//------業(yè)務(wù)邏輯-------
.......
//--------------------------
lock.unlock();

例如線程1和線程2進行加鎖操作，線程1先獲得鎖，AQS會將state置為1，并且加鎖線程變量記錄為線程1。線程2由于沒有獲得鎖，會被AQS放到線程等待隊列中進行等待。

ReentrantLock翻譯成中文是可重入鎖，從名字就可知它和synchronized關(guān)鍵字一樣是可重入的。因為有一個加鎖線程變量當前記錄了持有鎖的是哪個線程，ReentrantLock再次加鎖時，是可以成功的，相應(yīng)的state變量也會加1。和synchronized關(guān)鍵字一樣，有一次加鎖操作就必須對應(yīng)一次解鎖操作，解鎖一次，state變量會減1。

當線程1執(zhí)行完成，所有鎖定操作都對應(yīng)執(zhí)行了解鎖操作后，state變量為0，并且加鎖線程變量被置為null。此時會喚醒線程等待隊列中的第一個線程（線程2）去嘗試獲得鎖了。

但是如果此時恰好有一個新的線程3搶在線程2之前獲得了鎖，那么線程2只能繼續(xù)等待，這很不公平呀！而ReentrantLock默認的就是不公平鎖。如果希望獲得的是公平鎖，新來的線程必須在線程等待隊列中排隊等待，也很簡單，只需要構(gòu)造ReentrantLock對象時，指定true的參數(shù)即可。

ReentrantLock lock = new ReentrantLock(true);

到此這篇關(guān)于Java的AQS基本原理詳細分析的文章就介紹到這了,更多相關(guān)AQS基本原理內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論