Java BlockingQueue接口及常用实现类介绍-java教程-PHP中文网

Java BlockingQueue接口及常用实现类介绍

P粉602998670

发布： 2025-10-07 23:14:01

原创

316人浏览过

BlockingQueue是Java中用于生产者-消费者模式的线程安全队列，提供阻塞插入与获取功能。其四组方法分别处理异常、返回特殊值、阻塞等待和超时；常用实现包括有界FIFO的ArrayBlockingQueue、可选边界的LinkedBlockingQueue、支持优先级的PriorityBlockingQueue、基于延迟的DelayQueue，以及不存储元素的SynchronousQueue，适用于不同并发场景。

java blockingqueue接口及常用实现类介绍

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），若启用公平性，则等待最久的线程优先获取访问权限
适用于高吞吐量场景，但因底层为数组，增删效率受限于容量限制

示例：

BlockingQueue<String> queue = new ArrayBlockingQueue<>(10);
queue.put("item"); // 若队列满则阻塞
String item = queue.take(); // 若队列空则阻塞

登录后复制

2. LinkedBlockingQueue

基于链表结构实现的可选有界阻塞队列，默认容量为 Integer.MAX_VALUE，因此通常表现为无界队列（但也可构造为有界）。

特点：

支持可选的容量限制
读写操作分别由两个独立的锁控制（takeLock 和 putLock），提高了并发性能
适合吞吐量要求较高的异步处理场景，如线程池中的任务队列

常见用法：

BlockingQueue<Runnable> workQueue = 
    new LinkedBlockingQueue<>(100);

登录后复制

3. PriorityBlockingQueue

一个支持优先级排序的无界阻塞队列，元素按照自然顺序或自定义比较器排序。注意：不能插入 null 值。

多个微信小程序源码合集

微信小程序是一种轻量级的应用开发平台，由腾讯公司推出，主要应用于移动端，旨在提供便捷的用户体验，无需下载安装即可在微信内使用。本压缩包包含了丰富的源码资源，涵盖了多个领域的应用场景，下面将逐一介绍其中涉及的知识点。1. 图片展示：这部分源码可能涉及了微信小程序中的``组件的使用，用于显示图片，以及`wx.getSystemInfo`接口获取屏幕尺寸，实现图片的适配和响应式布局。可能还包括了图片懒加

查看详情

特点：

无界队列，自动扩容
内部使用堆结构维护顺序，保证每次取出的是优先级最高的元素
适用于需要按优先级处理任务的场景，如定时任务调度

示例：

BlockingQueue<Task> queue = 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;
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">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<ExpiryTask> queue = new DelayQueue<>(); queue.put(new ExpiryTask(5000)); ExpiryTask task = queue.take(); // 5秒后才返回

5. SynchronousQueue

一种特殊的阻塞队列，不存储元素。每个插入操作必须等待另一个线程的对应移除操作，反之亦然。

特点：

容量为 0，不保留数据
支持公平模式（FIFO）和非公平模式（LIFO）
非常适合传递性场景，比如一个线程的结果直接交给另一个线程处理
常用于 CPU 密集型任务的线程池（如 Executors.newCachedThreadPool()）

示例行为：

BlockingQueue<String> queue = new SynchronousQueue<>();
// 以下 put 将一直阻塞，直到有其他线程执行 take
new Thread(() -> {
    try {
        queue.put("data");
        System.out.println("数据已放入");
    } catch (InterruptedException e) { /* handle */ }
}).start();
<p>new Thread(() -> {
try {
String data = queue.take();
System.out.println("接收到：" + data);
} catch (InterruptedException e) { /<em> handle </em>/ }
}).start();

登录后复制

基本上就这些。BlockingQueue 的设计简化了多线程编程中对共享资源的管理，合理选择其实现类能有效提升程序的稳定性与性能。根据具体业务需求选择合适的队列类型是关键。不复杂但容易忽略细节，比如有界与无界的区别、是否支持优先级、是否有容量限制等。使用时注意异常处理和线程中断响应。

以上就是Java BlockingQueue接口及常用实现类介绍的详细内容，更多请关注php中文网其它相关文章！