LinkedBlockingQueue是Java中基于链表的线程安全阻塞队列，支持有界或无界模式，使用ReentrantLock实现入队出队并发控制，提供put/take阻塞操作及offer/poll超时机制，适用于生产者-消费者模型，常与线程池结合使用，建议合理设置容量以避免内存溢出，并根据场景选择合适的方法。
在多线程编程中，安全地共享数据结构是关键。Java 提供了多种线程安全的集合类，其中 LinkedBlockingQueue 是一个常用且高效的阻塞队列实现。它基于链表结构，支持高并发环境下的入队和出队操作，非常适合生产者-消费者模型。
理解 LinkedBlockingQueue 的基本特性
LinkedBlockingQueue 是 java.util.concurrent 包中的一个线程安全队列，其主要特点包括：
- 基于链表结构，可选有界或无界队列（默认无界）
- 使用独占锁（ReentrantLock）分别控制入队和出队操作，提高并发性能
- 支持阻塞式操作，如 put() 和 take()，在队列满或空时自动等待
- 实现了 BlockingQueue 接口，提供 poll(timeout)、offer(timeout) 等超时方法
创建方式示例如下：
// 无界队列LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>();
// 有界队列，容量为10
LinkedBlockingQueue<Integer> boundedQueue = new LinkedBlockingQueue<>(10);
在生产者-消费者模式中正确使用
这是 LinkedBlockingQueue 最常见的应用场景。多个生产者线程向队列添加任务，多个消费者线程从队列取出并处理任务。
立即学习“Java免费学习笔记（深入）”；
示例代码：
LinkedBlockingQueue<Runnable> taskQueue = new LinkedBlockingQueue<>(100);// 生产者线程
new Thread(() -> {
try {
for (int i = 0; i < 10; i++) {
taskQueue.put(new Task(i)); // 阻塞直到有空间
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
// 消费者线程
new Thread(() -> {
try {
while (true) {
Runnable task = taskQueue.take(); // 阻塞直到有任务
task.run();
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
注意：take() 和 put() 方法会响应中断，务必处理 InterruptedException，并考虑是否需要恢复中断状态。
选择合适的操作方法以适应业务场景
LinkedBlockingQueue 提供了多组方法来完成添加和移除操作，应根据实际需求选择：
- add(e)：成功返回 true，队列满时抛出 IllegalStateException
- offer(e)：立即返回 boolean，false 表示队列满，不阻塞
- offer(e, timeout, unit)：尝试在指定时间内插入，适合对响应时间敏感的场景
- put(e)：阻塞直到成功插入，适用于必须保证入队的场景
- poll()：立即获取并移除头元素，为空时返回 null
- poll(timeout, unit)：最多等待指定时间，超时返回 null
- take()：阻塞直到取到元素，常用于消费者循环
例如，在 Web 请求队列中，可以使用 offer(timeout) 避免用户长时间等待：
if (!requestQueue.offer(request, 1, TimeUnit.SECONDS)) {log.warn("请求队列已满，拒绝新请求");
return Response.error("服务繁忙");
}
监控与资源管理建议
在实际应用中，应注意以下几点：
- 有界队列有助于防止内存溢出，建议在明确负载上限时设定容量
- 定期检查队列长度（size()），可用于监控系统压力
- 避免在高频率场景中频繁调用 size()，因其需要加锁统计
- 消费者线程应妥善处理异常，避免因单个任务失败导致线程退出
- 结合线程池使用时，可将 LinkedBlockingQueue 作为工作队列
比如搭配 ThreadPoolExecutor 使用：
new ThreadPoolExecutor(2, 4, 30, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(50)
);
基本上就这些。LinkedBlockingQueue 使用简单但功能强大，关键是根据业务需求选择合适的方法和配置参数，才能发挥其最大价值。
