Java中BlockingDeque接口使用方法

P粉602998670

发布时间：2025-10-06 11:15:02

927人浏览过

来源于php中文网

原创

BlockingDeque是Java中支持双端插入和删除的阻塞队列接口，适用于多线程下生产者-消费者等需双向操作的场景。它结合了Deque的双端操作与BlockingQueue的阻塞特性，常见实现为LinkedBlockingDeque。其方法分为四类：抛出异常、返回特殊值、阻塞、超时阻塞，分别用于插入（addFirst/offerFirst/putFirst/offerFirst with timeout）、移除（removeFirst/pollFirst/takeFirst/pollFirst with timeout）和查看（getFirst/peekFirst）操作。示例中生产者调用putLast向尾部插入，消费者通过takeFirst从头部取出，自动实现队列满或空时的阻塞等待。使用时应选择合适实现类、设置合理容量，并注意处理线程中断。若无需阻塞，可选用ArrayDeque等普通双端队列。

java中blockingdeque接口使用方法

BlockingDeque是Java并发包java.util.concurrent中的一个双端阻塞队列接口，它结合了Deque和BlockingQueue的特性，支持在两端进行插入和删除操作，并且在队列满或空时提供阻塞功能。这个接口适用于多线程环境下需要高效、线程安全地处理两端数据的操作场景。

基本特性与使用场景

BlockingDeque允许从队列的头部和尾部插入、取出元素，同时具备阻塞能力：

当队列为空时，获取元素的操作会等待直到有元素可用
当队列满时，插入元素的操作会等待直到有空间可用
适合生产者-消费者模型中需要双向操作的场景

常见实现类是LinkedBlockingDeque，它是基于链表结构的可选容量限制的双端阻塞队列。

常用方法分类说明

BlockingDeque提供了四组操作方法，分别对应不同行为：抛出异常、返回特殊值（null或false）、阻塞、超时阻塞。

立即学习“Java免费学习笔记（深入）”；

BJXSHOP网上开店专家

BJXShop网上购物系统是一个高效、稳定、安全的电子商店销售平台，经过近三年市场的考验，在中国网购系统中属领先水平；完善的订单管理、销售统计系统；网站模版可DIY、亦可导入导出；会员、商品种类和价格均实现无限等级；管理员权限可细分；整合了多种在线支付接口；强有力搜索引擎支持... 程序更新：此版本是伴江行官方商业版程序，已经终止销售，现于免费给大家使用。比其以前的免费版功能增加了：1，整合了论坛

下载

1. 插入操作

addFirst(e) / addLast(e)：在队头/队尾插入元素，失败时抛出异常
offerFirst(e) / offerLast(e)：成功返回true，否则返回false
putFirst(e) / putLast(e)：如果队列满则阻塞，直到有空间
offerFirst(e, timeout, unit) / offerLast(e, timeout, unit)：最多等待指定时间，超时返回false

2. 移除操作

removeFirst() / removeLast()：获取并移除元素，无元素时抛异常
pollFirst() / pollLast()：无元素时返回null
takeFirst() / takeLast()：无元素时阻塞，直到有元素可用
pollFirst(timeout, unit) / pollLast(timeout, unit)：最多等待指定时间

3. 查看操作（不移除）

getFirst() / getLast()：查看首尾元素，无元素抛异常
peekFirst() / peekLast()：无元素返回null

实际使用示例

下面是一个简单的多线程示例，展示如何使用BlockingDeque实现生产者从尾部放入数据，消费者从头部取出数据：

BlockingDeque deque = new LinkedBlockingDeque<>(5); // 容量为5

// 生产者线程
new Thread(() -> {
    try {
        for (int i = 1; i <= 10; i++) {
            String item = "item-" + i;
            deque.putLast(item);
            System.out.println("生产：" + item);
            Thread.sleep(200);
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}).start();

// 消费者线程
new Thread(() -> {
    try {
        while (!Thread.interrupted()) {
            String item = deque.takeFirst();
            System.out.println("消费：" + item);
            Thread.sleep(500);
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}).start();

上面代码中，putLast和takeFirst保证了线程安全和阻塞等待。当队列满时，生产者自动暂停；当队列空时，消费者等待新数据。