BlockingQueue是Java中用于生产者-消费者模式的线程安全队列，提供阻塞插入与获取功能。其四组方法分别处理异常、返回特殊值、阻塞等待和超时；常用实现包括有界FIFO的ArrayBlockingQueue、可选边界的LinkedBlockingQueue、支持优先级的PriorityBlockingQueue、基于延迟的DelayQueue，以及不存储元素的SynchronousQueue，适用于不同并发场景。
Java中的BlockingQueue接口是java.util.concurrent包中一个重要的线程安全队列接口，主要用于实现生产者-消费者模式。它支持在插入或获取元素时进行阻塞操作：当队列满时，尝试插入元素的线程会被阻塞；当队列为空时，尝试获取元素的线程也会被阻塞。
BlockingQueue 核心方法说明
BlockingQueue 提供了四组不同的方法用于插入、移除和检查元素，每种方法在操作失败时的行为不同：
- throws exception：add(e), remove(), element()
- special value：offer(e), poll(), peek() — 返回 false 或 null
- blocks：put(e), take() — 阻塞直到可用
- times out：offer(e, time, unit), poll(time, unit) — 最多等待指定时间
这些特性使得 BlockingQueue 非常适合用于多线程环境下的任务调度与数据传递。
常用实现类介绍
1. ArrayBlockingQueue
立即学习“Java免费学习笔记（深入）”；
基于数组实现的有界阻塞队列，创建时必须指定容量大小，且不可更改。该队列按照 FIFO（先进先出）原则对元素进行排序。
特点：
- 有界队列，容量固定
- 构造时可选择是否使用公平策略（fair policy），若启用公平性，则等待最久的线程优先获取访问权限
- 适用于高吞吐量场景，但因底层为数组，增删效率受限于容量限制
示例：
BlockingQueuequeue = new ArrayBlockingQueue<>(10); queue.put("item"); // 若队列满则阻塞 String item = queue.take(); // 若队列空则阻塞
2. LinkedBlockingQueue
基于链表结构实现的可选有界阻塞队列，默认容量为 Integer.MAX_VALUE，因此通常表现为无界队列（但也可构造为有界）。
特点：
- 支持可选的容量限制
- 读写操作分别由两个独立的锁控制（takeLock 和 putLock），提高了并发性能
- 适合吞吐量要求较高的异步处理场景，如线程池中的任务队列
常见用法：
BlockingQueueworkQueue = new LinkedBlockingQueue<>(100);
3. PriorityBlockingQueue
一个支持优先级排序的无界阻塞队列，元素按照自然顺序或自定义比较器排序。注意：不能插入 null 值。
微信小程序是一种轻量级的应用开发平台，由腾讯公司推出，主要应用于移动端，旨在提供便捷的用户体验，无需下载安装即可在微信内使用。本压缩包包含了丰富的源码资源，涵盖了多个领域的应用场景，下面将逐一介绍其中涉及的知识点。1. 图片展示：这部分源码可能涉及了微信小程序中的``组件的使用，用于显示图片，以及`wx.getSystemInfo`接口获取屏幕尺寸，实现图片的适配和响应式布局。可能还包括了图片懒加
特点：
- 无界队列，自动扩容
- 内部使用堆结构维护顺序，保证每次取出的是优先级最高的元素
- 适用于需要按优先级处理任务的场景，如定时任务调度
示例：
BlockingQueuequeue = new PriorityBlockingQueue<>( 11, Comparator.comparing(Task::getPriority) ); queue.put(new Task(1)); queue.put(new Task(3)); Task highest = queue.take(); // 返回 priority=1 的任务
4. DelayQueue
元素必须实现 Delayed 接口，只有当指定的延迟时间到期后，才能从队列中取走元素。
特点：
- 无界队列
- 常用于缓存系统中过期清理、定时任务触发等场景
- 内部基于
PriorityQueue实现，最小堆结构按剩余时间排序
典型应用：
public class ExpiryTask implements Delayed {
private long executeTime;
public ExpiryTask(long delayInMs) {
this.executeTime = System.currentTimeMillis() + delayInMs;
}
@Override
public long getDelay(TimeUnit unit) {
return unit.convert(executeTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
}
@Override
public int compareTo(Delayed o) {
return Long.compare(this.executeTime, ((ExpiryTask)o).executeTime);
}}
// 使用
DelayQueue queue = new DelayQueue();
queue.put(new ExpiryTask(5000));
ExpiryTask task = queue.take(); // 5秒后才返回
5. SynchronousQueue
一种特殊的阻塞队列，不存储元素。每个插入操作必须等待另一个线程的对应移除操作，反之亦然。
特点：
- 容量为 0，不保留数据
- 支持公平模式（FIFO）和非公平模式（LIFO）
- 非常适合传递性场景，比如一个线程的结果直接交给另一个线程处理
- 常用于 CPU 密集型任务的线程池（如 Executors.newCachedThreadPool()）
示例行为：
BlockingQueuequeue = new SynchronousQueue<>(); // 以下 put 将一直阻塞，直到有其他线程执行 take new Thread(() -> { try { queue.put("data"); System.out.println("数据已放入"); } catch (InterruptedException e) { /* handle */ } }).start(); new Thread(() -> { try { String data = queue.take(); System.out.println("接收到：" + data); } catch (InterruptedException e) { / handle / } }).start();
基本上就这些。BlockingQueue 的设计简化了多线程编程中对共享资源的管理，合理选择其实现类能有效提升程序的稳定性与性能。根据具体业务需求选择合适的队列类型是关键。不复杂但容易忽略细节，比如有界与无界的区别、是否支持优先级、是否有容量限制等。使用时注意异常处理和线程中断响应。
