LinkedBlockingQueue是基于链表的线程安全阻塞队列,支持可选容量限制,默认为无界队列;1. 使用ReentrantLock保证线程安全;2. 提供put/take等阻塞方法实现生产者-消费者模式;3. 常用于多线程任务解耦与协作,需注意设置合理容量避免内存溢出,并正确处理中断。

LinkedBlockingQueue 是 Java 并发包 java.util.concurrent 中的一个线程安全的阻塞队列实现,基于链表结构。它常用于生产者-消费者模式中,支持可选的容量限制,若不指定容量,默认为 Integer.MAX_VALUE。
基本特性
线程安全:内部使用 ReentrantLock 锁机制保证多线程环境下的安全操作。
阻塞操作:当队列为空时,从队列获取元素的线程会被阻塞;当队列满时,插入元素的线程也会被阻塞。
先进先出(FIFO):元素按插入顺序取出。
常用构造方法
• LinkedBlockingQueue():创建一个无界队列(默认容量为 Integer.MAX_VALUE)。• LinkedBlockingQueue(int capacity):创建一个指定容量的有界队列。
示例:
LinkedBlockingQueueLinkedBlockingQueue
核心方法使用说明
添加元素
• add(E e):成功返回 true,队列满时抛出 IllegalStateException。• offer(E e):立即返回 true(成功)或 false(失败),非阻塞。
• offer(E e, long timeout, TimeUnit unit):在指定时间内尝试插入,超时返回 false。
• put(E e):阻塞直到有空间可用(适合生产者)。
移除元素
立即学习“Java免费学习笔记(深入)”;
Zoomify 是一款基于的简单带缩放效果的 jQuery lightbox 插件,它使用简单,出来提供基本的属性外,还提供了自动事件和自定义方法,能够满足大多数需求。
• poll():返回队首元素或 null(如果队列为空),非阻塞。
• poll(long timeout, TimeUnit unit):在指定时间内等待元素,超时返回 null。
• take():阻塞直到有元素可用(适合消费者)。
查看元素
• peek():返回但不移除队首元素,队列空时返回 null。实际应用场景示例
模拟一个简单的生产者-消费者模型:
import java.util.concurrent.LinkedBlockingQueue;public class ProducerConsumer {
public static void main(String[] args) {
LinkedBlockingQueue
// 生产者线程
new Thread(() -> {
try {
for (int i = 1; i queue.put("任务" + i);
System.out.println("生产:" + "任务" + i);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
// 消费者线程
new Thread(() -> {
try {
while (true) {
String task = queue.take();
System.out.println("消费:" + task);
Thread.sleep(500); // 模拟处理时间
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
}
}
该例子中,生产者不断向队列 put 元素,消费者通过 take 阻塞等待新任务,实现了线程间的解耦与协作。
注意事项
• 若使用无界队列(不设容量),可能导致内存溢出(OutOfMemoryError),应根据业务场景合理设置上限。• put/take 方法会响应中断,编写循环时注意捕获 InterruptedException 并处理中断状态。
• offer/poll 的超时版本适用于需要控制等待时间的场景。
基本上就这些。LinkedBlockingQueue 使用简单,性能良好,是并发编程中非常实用的工具类。掌握其核心方法和阻塞机制,能有效支撑多线程任务调度与数据传递。不复杂但容易忽略细节,比如中断处理和容量控制。









