linkedblockingqueue是java并发包中线程安全的链表阻塞队列，适用于生产者-消费者模型；支持有界/无界构造，提供put/take等阻塞操作及offer/poll等非阻塞操作，不支持null元素。
LinkedBlockingQueue 是 Java 并发包（java.util.concurrent）中一个线程安全的、基于链表实现的阻塞队列。它常用于生产者-消费者模型，支持多线程环境下高效、安全的数据传递。
基本用法：创建与添加元素
可以指定容量（有界）或不指定（默认为 Integer.MAX_VALUE，即近似无界）。常用构造方式：
-
new LinkedBlockingQueue<string>()</string>—— 默认容量为最大整数，几乎无界 -
new LinkedBlockingQueue<integer>(10)</integer>—— 明确指定容量为 10，满时阻塞插入
添加元素常用方法：
-
put(E e)：阻塞式插入，队列满时线程等待，直到有空间 -
offer(E e)：非阻塞插入，成功返回true，失败（如已满）返回false -
offer(E e, long timeout, TimeUnit unit)：带超时的插入，超时前未插入成功则返回false
获取与移除元素
消费端常用操作：
立即学习“Java免费学习笔记（深入）”；
-
take()：阻塞式获取并移除头元素，队列空时等待，直到有元素可用 -
poll()：非阻塞获取并移除头元素，为空时返回null -
poll(long timeout, TimeUnit unit)：带超时的获取，超时未取到则返回null
注意：element() 和 peek() 只查看不移除，但 element() 在队列为空时抛出异常，peek() 返回 null，一般推荐用 peek() 避免异常。
典型生产者-消费者场景示例
两个线程协作：一个生产数据放入队列，一个从队列取出处理：
LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>(5);
// 生产者线程
new Thread(() -> {
try {
for (int i = 0; i < 10; i++) {
queue.put("item-" + i); // 自动阻塞等待空位
System.out.println("Produced: item-" + i);
Thread.sleep(100);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
// 消费者线程
new Thread(() -> {
try {
while (true) {
String item = queue.take(); // 自动阻塞等待元素
System.out.println("Consumed: " + item);
Thread.sleep(200);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
该例子体现了 put/take 的天然阻塞协调能力，无需额外加锁或 wait/notify。
注意事项与常见误区
使用时需留意以下几点：
- 容量设置要合理：无界队列（默认）可能导致内存溢出，尤其在生产快于消费时
- 队列本身线程安全，但其中存储的对象若被多线程共享修改，仍需自行保证其线程安全性
-
size()方法返回当前元素个数，但并发环境下该值可能瞬间过期，**不适合用作条件判断依据**（比如if (queue.size() 不安全） - 不支持
null元素，插入null会直接抛出NullPointerException
基本上就这些。掌握 put/take 的阻塞语义，就能稳稳用好它。
