LinkedBlockingQueue是Java中基于链表的可选有界阻塞队列,实现BlockingQueue接口,通过ReentrantLock保证线程安全,支持put/take等阻塞操作,适用于生产者-消费者模型;其构造可指定容量(有界)或默认近似无界(Integer.MAX_VALUE),建议在资源受限场景使用有界队列以防内存溢出;提供add/offer/put、poll/take/peek等三类方法,其中put和take为阻塞式,适合线程间协作;内部采用两把锁(入队与出队分离),提升并发性能,示例中通过固定线程池模拟生产者不断提交任务、消费者循环take处理,自动实现线程等待与唤醒;需注意不可插入null元素,否则抛NullPointerException,且应正确处理InterruptedException以避免中断丢失;总体上适用于高并发读写场景,能有效简化多线程数据同步。

在Java中,LinkedBlockingQueue 是一个基于链表结构的可选有界阻塞队列,常用于多线程环境下实现安全的数据传递。它实现了 BlockingQueue 接口,内部通过独占锁(ReentrantLock)保证线程安全,适合生产者-消费者模型中的任务队列管理。
创建与初始化 LinkedBlockingQueue
LinkedBlockingQueue 可以设置容量,也可以使用无界模式。默认构造函数创建的是一个近似无界的队列(上限为 Integer.MAX_VALUE)。
- 无界队列:
new LinkedBlockingQueue() - 有界队列:
new LinkedBlockingQueue(100),限制最多存放100个元素
建议在资源有限的场景下使用有界队列,避免内存溢出。
核心操作方法及线程安全特性
LinkedBlockingQueue 提供了多种插入、获取和检查方法,根据行为不同可分为三类:
立即学习“Java免费学习笔记(深入)”;
- add(e):成功返回 true,队列满时抛出异常
- offer(e):成功返回 true,失败返回 false(非阻塞)
- put(e):将元素放入队列,如果队列满则阻塞等待空间
- poll():取出并移除头元素,为空时返回 null
- take():取出头元素,如果队列空则阻塞直到有元素可用
- peek():查看头元素但不移除,为空返回 null
其中 put() 和 take() 是阻塞方法,非常适合在线程协作中使用,比如消费者线程可以一直调用 take() 等待新任务。
实际应用场景示例
以下是一个简单的生产者-消费者模型演示:
ExecutorService executor = Executors.newFixedThreadPool(2); LinkedBlockingQueuequeue = new LinkedBlockingQueue<>(5); // 生产者 executor.submit(() -> { for (int i = 1; i <= 10; i++) { try { queue.put("任务-" + i); System.out.println("生产:" + "任务-" + i); Thread.sleep(300); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }); // 消费者 executor.submit(() -> { while (!Thread.currentThread().isInterrupted()) { try { String task = queue.take(); System.out.println("消费:" + task); Thread.sleep(500); } catch (InterruptedException e) { Thread.currentThread().interrupt(); break; } } }); executor.shutdown();
该例子中,生产者向队列添加任务,消费者从队列取出处理。由于 put 和 take 的阻塞性质,线程之间自动协调,无需额外同步控制。
性能与注意事项
LinkedBlockingQueue 内部使用两个锁(读锁和写锁),分别控制出队和入队操作,相比 synchronized 容器具有更高的并发性能。
- 适合高并发读写场景
- 有界队列有助于防止资源耗尽
- 注意处理 InterruptedException,避免线程中断被忽略
- 不支持 null 元素,插入 null 会抛出 NullPointerException
基本上就这些。合理使用 LinkedBlockingQueue 能有效简化多线程编程中的数据同步问题。










