構造方法

ArrayBlockingQueue提供了三個構造方法，分別如下。

capacity：?表示數組的長度，也就是隊列的長度

fair：表示是否為公平的阻塞隊列，默認情況下構造的是非公平的阻塞隊列。

其中第三個構造方法就不解釋了，它提供了接收一個幾個作為數據初始化的方法

public ArrayBlockingQueue(int capacity) { this(capacity, false); } public ArrayBlockingQueue(int capacity,boolean fair) { if (capacity <= 0) throw new IllegalArgumentException(); this.items = new Object[capacity]; lock = new ReentrantLock(fair); //重入鎖，出隊和入隊持有這一把鎖 notEmpty = lock.newCondition(); //初始化非空等待隊列 notFull = lock.newCondition(); //初始化非滿等待隊列 }

關于鎖的用途，大家在沒有看接下來的源碼之前，可以先思考一下他的作用。

items構造以后，大概是一個這樣的數組結構

Add方法

以add方法作為入口，在add方法中會調用父類的add方法，也就是AbstractQueue.如果看源碼看得比較多的話，一般這種寫法都是調用父類的模版方法來解決通用性問題

public boolean add(E e) { return super.add(e); }

從父類的add方法可以看到，這里做了一個隊列是否滿了的判斷，如果隊列滿了直接拋出一個異常

public boolean add(E e) { if (offer(e)) return true; else throw new IllegalStateException("Queue full"); }

offer方法

add方法最終還是調用offer方法來添加數據，返回一個添加成功或者失敗的布爾值反饋

這段代碼做了幾個事情

1. 判斷添加的數據是否為空

2. 添加重入鎖

3. 判斷隊列長度，如果隊列長度等于數組長度，表示滿了直接返回false

4. 否則，直接調用enqueue將元素添加到隊列中

public boolean offer(E e) { checkNotNull(e); //對請求數據做判斷 final ReentrantLock lock = this.lock; lock.lock(); try { if (count == items.length) return false; else { enqueue(e); return true; } } finally { lock.unlock(); } }

?

總結

以上是生活随笔為你收集整理的ArrayBlockingQueue原理分析的全部內容，希望文章能夠幫你解決所遇到的問題。

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