linkedblockingqueue是java中实现生产者消费者模型的核心工具，1.它基于链表结构实现线程安全的阻塞队列，2.通过put/take方法在队列满或空时自动阻塞线程，3.支持可选容量限制以防止内存溢出，4.利用reentrantlock保证并发操作的安全性，5.广泛应用于任务调度和消息传递等场景。
在Java中，LinkedBlockingQueue 是并发编程中实现生产者消费者模型的常用工具。它是一个线程安全的阻塞队列，底层基于链表结构，支持可选的容量限制。当队列满时，生产者线程会被阻塞；当队列空时，消费者线程也会被阻塞，直到有新元素加入。这种机制天然契合生产者消费者模式的需求。
LinkedBlockingQueue 的基本特性
LinkedBlockingQueue 是 java.util.concurrent 包中的一个实现类，具备以下关键特性：
- 线程安全：内部使用 ReentrantLock 和 Condition 实现线程同步，多个线程可安全地进行 put/take 操作。
- 阻塞性操作：put() 方法在队列满时阻塞，take() 方法在队列空时阻塞。
- 可选容量：构造时可指定最大容量，若不指定则默认为 Integer.MAX_VALUE，相当于无界队列。
- 先进先出（FIFO）：元素按插入顺序被取出，保证顺序性。
生产者消费者的实现步骤
使用 LinkedBlockingQueue 实现生产者消费者模型非常简洁，核心在于共享同一个队列实例，通过 put 和 take 方法自动处理线程等待与唤醒。
以下是具体实现示例：
立即学习“Java免费学习笔记（深入）”；
// 共享队列
private final LinkedBlockingQueue
// 生产者线程
class Producer implements Runnable {
@Override
public void run() {
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();
}
}
}
// 消费者线程
class Consumer implements Runnable {
@Override
public void run() {
try {
while (true) {
String data = queue.take(); // 阻塞式出队
System.out.println("消费：" + data);
Thread.sleep(800); // 模拟消费耗时
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}
// 启动测试
public static void main(String[] args) {
ProducerConsumerExample example = new ProducerConsumerExample();
new Thread(example.new Producer()).start();
new Thread(example.new Consumer()).start();
}
关键方法说明
LinkedBlockingQueue 提供了几组不同的添加和获取方法，适用于不同场景：
- put(E e)：将元素插入队列，如果队列满则阻塞，直到有空间。
- take()：从队列头部取出元素，如果队列为空则阻塞，直到有元素可用。
- offer(E e, long timeout, TimeUnit unit)：尝试在指定时间内插入元素，超时返回 false。
- poll(long timeout, TimeUnit unit)：尝试在指定时间内获取元素，超时返回 null。
在生产者消费者模型中，通常使用 put 和 take，因其阻塞语义更符合模型逻辑，减少轮询开销。
应用场景与注意事项
该模型广泛应用于任务调度、消息中间件、线程池工作队列等场景。使用 LinkedBlockingQueue 时需注意：
- 若未设置容量，队列为无界，可能导致内存溢出，建议根据业务设定合理上限。
- 生产者和消费者数量可灵活配置，多个线程可同时操作同一队列，无需额外同步。
- 中断处理要正确响应 InterruptedException，避免线程无法退出。
基本上就这些。LinkedBlockingQueue 简化了传统 wait/notify 的复杂锁控制，让生产者消费者模型的实现变得直观高效。合理使用其阻塞特性，能有效平衡生产与消费速度，提升系统稳定性。
