Java 並發隊列深度解析：ArrayBlockingQueue 核心原理與源碼級實現詳解

隊列體系概覽

Java 集合框架提供豐富的隊列實現，按特性分類：

ArrayBlockingQueue 核心設計

數據結構

• final E[] items：固定大小數組，存儲元素；
• int takeIndex：出隊索引（頭部）；
• int putIndex：入隊索引（尾部）；
• int count：當前元素數量；
• ReentrantLock lock：獨佔鎖，保證線程安全；
• Condition notEmpty, notFull：等待/通知機制，分別對應消費者、生產者條件。

環形數組邏輯

final int inc(int i) {
    return (++i == items.length) ? 0 : i; // 索引環繞
}

核心操作源碼解析

入隊

private void insert(E x) {
    items[putIndex] = x;
    putIndex = inc(putIndex);
    ++count;
    notEmpty.signal(); // 喚醒消費者
}

出隊

private E extract() {
    E x = items[takeIndex];
    items[takeIndex] = null; // 幫助 GC
    takeIndex = inc(takeIndex);
    --count;
    notFull.signal(); // 喚醒生產者
    return x;
}

公平性策略

構造函數 ArrayBlockingQueue(int capacity, boolean fair) 通過 ReentrantLock(fair) 控制：

• fair=false（預設）：非公平鎖，吞吐量高但可能導致線程飢餓；
• fair=true：公平鎖，FIFO 獲取鎖，降低吞吐量但避免飢餓。

主要公共方法語義

典型應用場景

• 生產者-消費者模型：固定緩衝區大小，背壓控制；
• 任務調度緩衝：線程池任務隊列（如 ThreadPoolExecutor 默認使用）；
• 流量削峰填谷：有界隊列防止 OOM，配合拒絕策略保護系統。

性能優化建議

1. 根據業務峰值預估容量，避免頻繁阻塞或過大浪費內存；
2. 高併發讀多寫少場景考慮 ConcurrentLinkedQueue（無界、無鎖）；
3. 需優先級處理時改用 PriorityBlockingQueue；
4. 避免在鎖內執行耗時操作（如 I/O），縮小臨界區。

掌握 ArrayBlockingQueue 的鎖機制、條件變量協作與環形數組設計，能為高併發系統的穩定性與性能調優提供堅實基礎。