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);
LinkedBlockingQueue<String> queue = 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 能有效简化多线程编程中的数据同步问题。
