阻塞佇列BlockingQueue使用

blockingqueue的原理及方法：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來實現生產者消/費者模式，**如下：

/** 定義乙個盤子類，可以放雞蛋和取雞蛋 */
public class bigplate catch (interruptedexception e) 
// 下面輸出有時不準確，因為與put操作不是乙個原子操作
system.out.println("放入雞蛋"); } 
/** 取雞蛋 */
public object getegg() catch (interruptedexception e) 
// 下面輸出有時不準確，因為與take操作不是乙個原子操作
system.out.println("拿到雞蛋");
return egg; } 
/** 放雞蛋執行緒 */
static class addthread extends thread 
public void run() 
} /** 取雞蛋執行緒 */
static class getthread extends thread 
public void run() } 
public static void main(string args) 
// 再啟動10個取雞蛋執行緒
for(int i = 0; i < 10; i++) 
}}

執行結果：

放入雞蛋放入雞蛋放入雞蛋拿到雞蛋拿到雞蛋拿到雞蛋放入雞蛋拿到雞蛋放入雞蛋拿到雞蛋放入雞蛋放入雞蛋拿到雞蛋放入雞蛋拿到雞蛋放入雞蛋拿到雞蛋放入雞蛋拿到雞蛋

拿到雞蛋

阻塞佇列BlockingQueue使用

併發工具包阻塞佇列BlockingQueue

等待佇列阻塞非阻塞

阻塞佇列BlockingQueue

阻塞佇列BlockingQueue使用

併發工具包 阻塞佇列BlockingQueue

等待佇列 阻塞非阻塞

阻塞佇列BlockingQueue

相關推薦

併發工具包阻塞佇列BlockingQueue

等待佇列阻塞非阻塞