LinkedBlockingQueue是Java中基于链表的阻塞队列，支持有界和无界模式，常用put/take实现生产者-消费者模型，适用于线程池任务队列及多线程解耦通信。
在Java中，LinkedBlockingQueue 是一个基于链表结构的阻塞队列，常用于多线程环境下的任务调度或生产者-消费者模型。它实现了 BlockingQueue 接口，支持在插入和移除操作时进行阻塞，非常适合线程安全的数据传递。
创建 LinkedBlockingQueue 实例
你可以创建无界或有界的 LinkedBlockingQueue：
- 无界队列：不指定容量，理论上可无限添加元素（受限于内存）
- 有界队列：指定最大容量，防止资源耗尽
// 创建无界队列 LinkedBlockingQueueunboundedQueue = new LinkedBlockingQueue<>(); // 创建有界队列，最多容纳10个元素 LinkedBlockingQueue boundedQueue = new LinkedBlockingQueue<>(10);
常用方法及使用场景
LinkedBlockingQueue 提供了多种线程安全的操作方法，适合不同需求：
插入元素
立即学习“Java免费学习笔记（深入）”；
Shopxp网上购物系统
下载
Shopxp购物系统历经多年的考验，并在推出shopxp免费购物系统下载之后，收到用户反馈的各种安全、漏洞、BUG、使用问题进行多次修补，已经从成熟迈向经典，再好的系统也会有问题，在完善的系统也从在安全漏洞，该系统完全开源可编辑，当您下载这套商城系统之后，可以结合自身的技术情况，进行开发完善，当然您如果有更好的建议可从官方网站提交给我们。Shopxp网上购物系统完整可用，无任何收费项目。该系统经过
-
put(e)：将元素插入队列，如果队列满则阻塞等待 -
offer(e)：立即返回 true/false，不会阻塞 -
offer(e, timeout, unit)：等待指定时间尝试插入
获取并移除元素
-
take()：取出队首元素，队列为空时阻塞等待 -
poll()：立即返回元素或 null（如果为空） -
poll(timeout, unit)：最多等待指定时间
// 生产者线程示例
new Thread(() -> {
try {
for (int i = 1; i <= 5; i++) {
boundedQueue.put(i);
System.out.println("生产: " + i);
Thread.sleep(500);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
// 消费者线程示例
new Thread(() -> {
try {
while (true) {
Integer num = boundedQueue.take();
System.out.println("消费: " + num);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
实际应用场景建议
LinkedBlockingQueue 特别适用于以下情况：
- 实现线程池中的任务队列（如 Executors.newFixedThreadPool 内部使用）
- 多个生产者与多个消费者之间的解耦通信
- 需要控制内存使用的有界缓冲场景
注意：若使用无界队列，要警惕内存溢出风险；选择有界队列能更好控制系统资源。
基本上就这些，用好 put/take 方法就能构建稳定的生产者-消费者系统。
