JUC包下定義了一個接口：BlockingQueue。其實現類有ArrayBlockingQueue等。本文先來介紹一下ArrayBlockingQueue。從字面可以看出，ArrayBlockingQueue是一種基于數組的阻塞隊列，阻塞隊列在線程池中會經常使用到。

首先來看看ArrayBlockingQueue的類圖，如下所示。從類圖可以看出，ArrayBlockingQueue繼承自AbstractQueue，實現了BlockingQueue接口。

在ArrayBlockingQueue內部有一個數組items，同時定義了takeIndex和putIndex變量。由于是隊列，因此一端入隊操作，另一端進行出隊操作。另外，內部定義了ReentrantLock作為獨占鎖。

1、構造函數

先來看看其構造函數。其有三給構造函數，不過都是調用這個構造函數。

構造函數的參數需要指定初始容量，同時指定采用公平鎖還是非公平鎖。從這一點可以看出，ArrayBlockingQueue是一個有界隊列。

2、offer函數

offer操作用于向隊列尾部插入一個元素，如果空閑則插入元素，如果非空閑，返回true。如果隊列滿，則返回false。下面讓我們來看看offer操作的源碼。

從上面的源碼可以看出，不管插入成功與否，都會立即返回結果，因此這個方法是非阻塞的，但是也不能保證一定插入元素成功。

3、put函數

從源碼中可以看出，put操作首先檢查元素是否位空，如果為空，則拋異常。然后進行加鎖，然后判斷當前隊列是否滿了，如果滿了就阻塞當前線程，然后掛起放入條件隊列。當然，這個方式是相應中斷的(因為上面lockInterruptibly方法可以響應中斷)。如果隊列沒滿，則入隊。最后釋放鎖。

4、poll操作

poll是從隊列頭部取走元素，其源碼如下：

首先進行加鎖操作，然后判斷當前隊列元素是否為0，如果是返回空。否則返回隊列頭元素。這個方法是不支持響應中斷的。至于deque操作，就是去數組中取元素，和普通隊列處理邏輯沒有區別。

5、take操作

take操作也是從隊列頭取元素。其源碼如下所示：

從源碼上可以看出，take也是支持響應中斷的。如果隊列元素為空，則會阻塞掛起，除非隊列有元素被喚醒。也就是這個方法一定要保證取到元素，如果取不到元素，會等到有元素才返回。不像上面的poll方法，取不到就返回null。

6、peek操作

peek操作時查看隊列首部的元素，但是不移除。源碼如下：

從源碼上可以看出，此方法也是非阻塞的。即使隊列沒有元素也就是會立即返回的(返回null)。不像上面的take操作，沒有元素就等到有元素再返回。

7、size操作

此方法是獲取隊列元素個數的方法，源碼如下：

從源碼可以看出，size操作時加鎖的，因為在定義count變量的時候沒有使用volitate修飾，這樣通過加鎖保證了內存的可見性。這里其實也可以通過putIndex和takeIndex來得到隊列元素長度。在Netty框架中的Bytebuf就是這樣計算的。

總結

以上是生活随笔為你收集整理的java queue源码_Java高并发系列之ArrayBlockingQueue源码解析的全部內容，希望文章能夠幫你解決所遇到的問題。

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