BlockingDeque是线程安全的双端阻塞队列，支持头尾插入和移除，适用于工作窃取、双向消息通道等场景，其核心特性包括阻塞操作、双端访问和多线程安全性。
在Java并发编程中，BlockingDeque 是一个支持两端插入和移除操作的线程安全双端阻塞队列。它继承自 BlockingQueue，但提供了更灵活的操作方式，适用于多个生产者和消费者场景下的高效数据交换。
BlockingDeque 简介与核心特性
BlockingDeque 是 java.util.concurrent 包中的接口，常见实现类是 LinkedBlockingDeque。它允许从队列的头部和尾部同时进行元素的插入、获取和移除，并在操作时支持阻塞行为。
主要特点包括：
- 线程安全：所有操作都保证多线程环境下的安全性
- 双端操作：可在队头和队尾执行插入、取出
- 阻塞能力：当队列为空或满时，可选择等待直到条件满足
- 支持公平性（部分实现）：减少线程饥饿问题
常用方法说明与使用示例
BlockingDeque 提供了四组方法来处理插入、移除和检查元素，对应不同失败策略：
立即学习“Java免费学习笔记（深入）”；
- addFirst(e)/addLast(e)：立即添加元素，失败抛出异常
- offerFirst(e)/offerLast(e)：立即添加，成功返回 true，否则 false
- putFirst(e)/putLast(e)：阻塞直到可以插入（适合容量受限队列）
- pollFirst()/pollLast()：立即取并删除元素，无元素则返回 null
- takeFirst()/takeLast()：阻塞直到获取到元素
- peekFirst()/peekLast()：仅查看不移除，支持非阻塞访问
下面是一个简单示例，展示如何使用 BlockingDeque 实现多线程双端操作：
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;
public class BlockingDequeExample {
private static final BlockingDeque deque = new LinkedBlockingDeque<>(5);
public static void main(String[] args) throws InterruptedException {
Thread producer = new Thread(() -> {
try {
deque.putFirst("任务1");
System.out.println("生产者在队首放入: 任务1");
Thread.sleep(1000);
deque.putLast("任务2");
System.out.println("生产者在队尾放入: 任务2");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
Thread consumer = new Thread(() -> {
try {
String task1 = deque.takeLast(); // 从尾部取
System.out.println("消费者从队尾取出: " + task1);
String task2 = deque.takeFirst(); // 从头部取
System.out.println("消费者从队首取出: " + task2);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
producer.start();
consumer.start();
producer.join();
consumer.join();
}
}
适用场景与并发技巧
BlockingDeque 特别适用于以下场景：
- 工作窃取（Work Stealing）：每个线程维护自己的双端队列，优先处理本地任务。当空闲时，从其他线程的队列尾部“窃取”任务。这种设计广泛用于 Fork/Join 框架。
- 双向消息通道：某些系统需要一端高频写入，另一端快速清理过期消息，可通过不同端口控制生命周期。
- 缓存淘汰辅助结构：结合 LRU 或滑动窗口机制，利用双端操作快速移动或移除元素。
使用建议：
- 若不需要容量限制，可使用无参构造函数创建不限容量的 LinkedBlockingDeque
- 注意 put/take 方法会无限阻塞，确保有对应的消费者或生产者配对运行
- 合理选择从哪一端读写，避免逻辑混乱。例如约定“头入尾出”为栈行为，“头入头出”为队列行为
- 监控队列状态时，使用 peek 而非 take，防止意外移除元素
基本上就这些。BlockingDeque 在保持线程安全的同时提供了极大的灵活性，掌握其操作模式有助于构建高性能并发结构。实际使用中应根据业务需求选择合适的插入和提取策略，避免死锁或资源浪费。
