您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 相關知識

Java 5 線程新特性：BlockingQueue 阻塞隊列實戰

編輯：Java 相關知識

阻塞隊列核心特性

BlockingQueue 繼承 Queue，提供阻塞語義：

put(e)：隊列滿時阻塞，直到有空位
take()：隊列空時阻塞，直到有元素
offer(e, timeout) / poll(timeout)：帶超時版本

天然適合「生產者-消費者」模式，無需手動 wait/notify。

常見實現類

實現類	特點	適用場景
ArrayBlockingQueue	有界數組，FIFO	固定大小緩存、任務隊列
LinkedBlockingQueue	可選有界鏈表，FIFO	高吞吐生產消費、無界緩存
PriorityBlockingQueue	優先級排序，無界	優先級任務調度
DelayQueue	延遲執行，無界	定時任務、緩存過期清理
SynchronousQueue	無容量，直接移交	線程間直接傳遞、CachedThreadPool

代碼示例：ArrayBlockingQueue 基本操作

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;

public class Test {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue bqueue = new ArrayBlockingQueue<>(20);
        for (int i = 0; i < 30; i++) {
            bqueue.put(i); // 滿後阻塞
            System.out.println("向阻塞隊列中添加了元素:" + i);
        }
        System.out.println("程序到此運行結束，即將退出----");
    }
}

運行結果

向阻塞隊列中添加了元素:0
...
向阻塞隊列中添加了元素:19
// 程序阻塞於 put(20)，因隊列已滿無消費者

第20個元素 (索引19) 入隊後，隊列滿 (容量20)，第21次 put() 永久阻塞。

生產者-消費者完整模式

BlockingQueue queue = new LinkedBlockingQueue<>(100);

// 生產者
new Thread(() -> {
    while (running) {
        Task task = produce();
        queue.put(task); // 自動阻塞等待空位
    }
}).start();

// 消費者
new Thread(() -> {
    while (running) {
        Task task = queue.take(); // 自動阻塞等待任務
        consume(task);
    }
}).start();