BlockingQueue最終會有四種狀況,拋出異常、返回特殊值、阻塞、超時,下表總結瞭這些方法:
拋出異常 特殊值 阻塞 超時
插入 add(e) offer(e) put(e) offer(e, time, unit)
移除 remove() poll() take() poll(time, unit)
檢查 element() peek() 不可用 不可用
BlockingQueue是個接口,有如下實現類:
1. ArrayBlockQueue:一個由數組支持的有界阻塞隊列。此隊列按 FIFO(先進先出)原則對元素進行排序。創建其對象必須明確大小,像數組一樣。
2. LinkedBlockQueue:一個可改變大小的阻塞隊列。此隊列按 FIFO(先進先出)原則對元素進行排序。創建其對象如果沒有明確大小,默認值是Integer.MAX_VALUE。鏈接隊列的吞吐量通常要高於基於數組的隊列,但是在大多數並發應用程序中,其可預知的性能要低。
3. PriorityBlockingQueue:類似於LinkedBlockingQueue,但其所含對象的排序不是FIFO,而是依據對象的自然排序順序或者是構造函數所帶的Comparator決定的順序。
4. SynchronousQueue:同步隊列。同步隊列沒有任何容量,每個插入必須等待另一個線程移除,反之亦然。
下面使用ArrayBlockQueue來實現之前實現過的生產者消/費者模式,代碼如下:
[java]
/** 定義一個盤子類,可以放雞蛋和取雞蛋 */
public class BigPlate {
/** 裝雞蛋的盤子,大小為5 */
private BlockingQueue<Object> eggs = new ArrayBlockingQueue<Object>(5);
/** 放雞蛋 */
public void putEgg(Object egg) {
try {
eggs.put(egg);// 向盤子末尾放一個雞蛋,如果盤子滿瞭,當前線程阻塞
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("放入雞蛋");
}
/** 取雞蛋 */
public Object getEgg() {
Object egg = null;
try {
egg = eggs.take();// 從盤子開始取一個雞蛋,如果盤子空瞭,當前線程阻塞
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("拿到雞蛋");
return egg;
}
/** 放雞蛋線程 */
static class AddThread extends Thread {
private BigPlate plate;
private Object egg = new Object();
public AddThread(BigPlate plate) {
this.plate = plate;
}
public void run() {
plate.putEgg(egg);
}
}
/** 取雞蛋線程 */
static class GetThread extends Thread {
private BigPlate plate;
public GetThread(BigPlate plate) {
this.plate = plate;
}
public void run() {
plate.getEgg();
}
}
public static void main(String[] args) {
BigPlate plate = new BigPlate();
// 先啟動10個放雞蛋線程
for(int i = 0; i < 10; i++) {
new Thread(new AddThread(plate)).start();
}
// 再啟動10個取雞蛋線程
for(int i = 0; i < 10; i++) {
new Thread(new GetThread(plate)).start();
}
}
}
執行結果:
[plain]
放入雞蛋
放入雞蛋
放入雞蛋
放入雞蛋
放入雞蛋
拿到雞蛋
放入雞蛋
拿到雞蛋
拿到雞蛋
拿到雞蛋
放入雞蛋
放入雞蛋
放入雞蛋
拿到雞蛋
放入雞蛋
拿到雞蛋
拿到雞蛋
拿到雞蛋
拿到雞蛋
拿到雞蛋
從結果看,啟動10個放雞蛋線程和10個取雞蛋線程,錢5個放入雞蛋的線程成功執行,到第6個,發現盤子滿瞭,阻塞住,這時切換到取雞蛋線程執行,成功實現瞭生產者/消費者模式