17370845950

LinkedBlockingQueue是Java并发包中线程安全的链表阻塞队列，适用于生产者-消费者模型；支持有界/无界构造，提供put/take等阻塞操作及offer/poll等非阻塞操作，不支持null元素。

LinkedBlockingQueue 是 Java 并发包（java.util.concurrent）中一个线程安全的、基于链表实现的阻塞队列。它常用于生产者-消费者模型，支持多线程环境下高效、安全的数据传递。

基本用法：创建与添加元素

可以指定容量（有界）或不指定（默认为 Integer.MAX_VALUE，即近似无界）。常用构造方式：

• new LinkedBlockingQueue() —— 默认容量为最大整数，几乎无界
• new LinkedBlockingQueue(10) —— 明确指定容量为 10，满时阻塞插入

添加元素常用方法：

• put(E e)：阻塞式插入，队列满时线程等待，直到有空间
• offer(E e)：非阻塞插入，成功返回 true，失败（如已满）返回 false
• offer(E e, long timeout, TimeUnit unit)：带超时的插入，超时前未插入成功则返回 false

获取与移除元素

消费端常用操作：

• take()：阻塞式获取并移除头元素，队列空时等待，直到有元素可用
• poll()：非阻塞获取并移除头元素，为空时返回 null
• poll(long timeout, TimeUnit unit)：带超时的获取，超时未取到则返回 null

注意：element() 和 peek() 只查看不移除，但 element() 在队列为空时抛出异常，peek() 返回 null，一般推荐用 peek() 避免异常。

典型生产者-消费者场景示例

两个线程协作：一个生产数据放入队列，一个从队列取出处理：

LinkedBlockingQueue queue = new LinkedBlockingQueue<>(5);

// 生产者线程
new Thread(() -> {
    try {
        for (int i = 0; i < 10; i++) {
            queue.put("item-" + i); // 自动阻塞等待空位
            System.out.println("Produced: item-" + i);
            Thread.sleep(100);
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}).start();

// 消费者线程
new Thread(() -> {
    try {
        while (true) {
            String item = queue.take(); // 自动阻塞等待元素
            System.out.println("Consumed: " + item);
            Thread.sleep(200);
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}).start();

该例子体现了 put/take 的天然阻塞协调能力，无需额外加锁或 wait/notify。

注意事项与常见误区

使用时需留意以下几点：

• 容量设置要合理：无界队列（默认）可能导致内存溢出，尤其在生产快于消费时
• 队列本身线程安全，但其中存储的对象若被多线程共享修改，仍需自行保证其线程安全性
• size() 方法返回当前元素个数，但并发环境下该值可能瞬间过期，**不适合用作条件判断依据**（比如 if (queue.size() 不安全）
• 不支持 null 元素，插入 null 会直接抛出 NullPointerException

基本上就这些。掌握 put/take 的阻塞语义，就能稳稳用好它。