JDK 集合框架：Queue 接口體系全景圖與核心契約解析

引言：隊列是異步處理的骨架

Java 集合框架中，Queue 及其子接口定義了「先進先出」「延遲調度」「阻塞協調」「雙端操作」「生產消費移交」等核心語義。本文系統梳理接口層次、方法契約、線程安全規範與典型應用模式，為選型與實現提供參考。

一、接口繼承體系總覽

Collection
  └─ Queue          // 基礎隊列：offer/poll/peek + add/remove/element
       ├─ BlockingQueue     // 阻塞隊列：put/take + 超時版
       ├─ Deque             // 雙端隊列：首尾對稱操作
       │    └─ BlockingDeque // 阻塞雙端隊列
       └─ TransferQueue     // 移交隊列：transfer() 生產者等待消費者

二、核心接口契約詳解

2.1 Queue —— 基礎隊列語義

兩組等效方法（異常 vs 特殊值）：

最佳實踐：生產代碼優先使用 offer/poll/peek，避免異常控制流；add/remove/element 適合測試/斷言場景。

2.2 隊列順序分類

共同點：remove()/poll() 始終返回「隊首」元素（FIFO 對應頭，LIFO 對應棧頂，優先級對應最高優先級）。

2.3 不實現 equals/hashCode 的設計決策

隊列中允許重複元素，且「順序」是核心屬性。基於內容的 equals 會導致兩個順序不同但元素相同的隊列被判定相等，違背語義。故繼承 Object 的身份相等。

2.4 BlockingQueue —— 生產者-消費者協調核心

四組操作形式：

關鍵規範：

• 線程安全：所有方法原子性（批量操作 addAll 等除非文檔聲明否則不保證原子）
• 不接受 null 元素：入隊 null 拋 NullPointerException，poll() 返回 null 表示空
• 容量查詢：remainingCapacity()，無界返回 Integer.MAX_VALUE
• 內存一致性：入隊 happens-before 出隊，保證元素發布可見性

經典生產消費模式：

class Producer implements Runnable {
    private final BlockingQueue q;
    public void run() { try { while (true) q.put(produce()); } catch (InterruptedException e) { ... } }
}
class Consumer implements Runnable {
    private final BlockingQueue q;
    public void run() { try { while (true) consume(q.take()); } catch (InterruptedException e) { ... } }
}
// 啟動多生產多消費
BlockingQueue q = new LinkedBlockingQueue<>();
new Thread(new Producer(q)).start();
new Thread(new Consumer(q)).start();
new Thread(new Consumer(q)).start();

2.5 Deque —— 雙端隊列：棧、隊列、雙端操作三合一

不支持隨機訪問（無 get(index)），不建議存 null，繼承 Object 相等語義。

自有方法（首/尾對稱）：

作 FIFO 隊列等效映射：

作 LIFO 棧等效映射：

推薦：棧場景請用 ArrayDeque 替代舊 Stack 類（非線程安全、繼承 Vector、同步開銷大）。

2.6 BlockingDeque —— 阻塞 + 雙端

組合 BlockingQueue 四組阻塞方法與 Deque 首尾對稱方法，共 20+ 方法。內存一致性同 BlockingQueue：入隊 happens-before 出隊。

典型實現：LinkedBlockingDeque（可選有界）。

2.7 TransferQueue —— 移交隊列：生產者等待消費者「接手」

核心方法：

• transfer(E e)：阻塞直到消費者調用 take()/poll() 移走元素（同步移交）
• tryTransfer(E e)：非阻塞嘗試，有消費者等待則移交並返回 true
• tryTransfer(E e, timeout, unit)：超時版
• hasWaitingConsumer()：是否有消費者正在等待
• getWaitingConsumerCount()：等待消費者數量

典型實現：LinkedTransferQueue（無界、高性能、JDK 7+）。適用於「需要確認任務被接收」的場景，如線程池提交任務、RPC 請求等待處理。

三、選型決策表

四、總結

1. Queue 定義基礎語義，offer/poll/peek 為主力方法。
2. BlockingQueue 增加阻塞協調，put/take 構建生產消費骨架，null 禁用。
3. Deque 雙端對稱，ArrayDeque 同時替代 Stack 與 Queue。
4. BlockingDeque = Blocking + Deque，LinkedBlockingDeque 唯一實現。
5. TransferQueue 引入 transfer() 同步移交語義，LinkedTransferQueue 高性能實現。
6. 選型核心維度：線程安全性、有界/無界、順序語義、阻塞/非阻塞、移交確認。