LinkedBlockingQueue是Java中线程安全的阻塞队列，基于链表实现，支持高并发生产者-消费者模式；它使用put/take方法实现阻塞式数据传递，通过容量控制避免内存溢出，配合超时机制和异常处理可实现高效稳定的线程间通信。
在多线程编程中，线程间安全地传递数据是一个核心问题。Java 提供了多种线程安全的队列实现，其中 LinkedBlockingQueue 是最常用的一种。它基于链表结构实现，支持高并发场景下的高效数据传递，非常适合生产者-消费者模型。
什么是LinkedBlockingQueue？
LinkedBlockingQueue 是 java.util.concurrent 包中的一个线程安全阻塞队列。它的容量可以是有界的，也可以是无界的（默认情况下为 Integer.MAX_VALUE）。当队列为空时，从队列获取元素的操作会被阻塞；当队列满时，插入操作也会被阻塞，直到有空间可用。
它内部使用两个锁：takeLock 用于出队操作，putLock 用于入队操作，这种设计提升了并发性能，允许多个线程同时进行入队和出队操作。
如何用LinkedBlockingQueue实现线程间通信？
最常见的应用场景是生产者-消费者模式。一个或多个线程作为生产者向队列中添加数据，另一个或多个线程作为消费者从队列中取出数据处理。
立即学习“Java免费学习笔记（深入）”；
示例代码：
// 定义共享队列
LinkedBlockingQueue
// 生产者线程
new Thread(() -> {
try {
for (int i = 1; i
String data = "消息-" + i;
queue.put(data); // 阻塞式添加
System.out.println("生产：" + data);
Thread.sleep(500);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
// 消费者线程
new Thread(() -> {
try {
while (true) {
String data = queue.take(); // 阻塞式获取
System.out.println("消费：" + data);
if (data.equals("消息-5")) break; // 结束条件
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
在这个例子中，生产者每 500ms 发送一条消息，消费者同步接收并处理。由于 put 和 take 方法是阻塞的，线程无需手动轮询，节省 CPU 资源。
关键方法与使用建议
理解以下方法有助于更灵活地使用 LinkedBlockingQueue：
- put(E e)：将元素插入队列，如果队列满则阻塞，直到有空间。
- take()：从队列头部取出元素，如果队列空则阻塞，直到有元素可用。
- offer(E e, long timeout, TimeUnit unit)：带超时的插入，避免无限等待。
- poll(long timeout, TimeUnit unit)：带超时的取出，适合需要控制响应时间的场景。
- size()：返回当前队列中的元素数量，可用于监控队列状态。
使用建议：
- 根据实际内存和吞吐量需求设置队列容量，避免使用默认的“无界”队列导致内存溢出。
- 在可能中断的场景中，正确处理 InterruptedException，并恢复线程中断状态。
- 若不需要阻塞行为，可使用 offer/poll 的非阻塞版本，配合业务逻辑做降级或重试。
- 多个消费者时注意任务分配的公平性，必要时结合 synchronized 或其他同步机制处理共享资源。
实际开发中的注意事项
在真实项目中，比如日志收集、异步任务处理、消息中间件简化版等场景，LinkedBlockingQueue 都很实用。但也要注意几点：
- 长时间阻塞可能导致线程积压，建议配合线程池使用，如 ExecutorService。
- 监控队列 size 和增长趋势，有助于发现生产过快或消费过慢的问题。
- 不要在队列中存放大量大对象，避免频繁 GC 或内存压力。
- 关闭应用时，应优雅停止生产者和消费者线程，避免数据丢失或线程泄漏。
基本上就这些。LinkedBlockingQueue 使用简单、性能良好，是 Java 并发编程中实现线程协作的可靠工具。只要合理设置容量、处理异常、控制生命周期，就能稳定支撑大多数数据传递需求。不复杂但容易忽略细节，掌握它对提升系统稳定性很有帮助。
