如何在Java中使用BlockingDeque实现双端队列-java教程-PHP中文网

如何在Java中使用BlockingDeque实现双端队列

P粉602998670

发布： 2025-10-16 15:45:01

原创

323人浏览过

BlockingDeque是Java中支持双端阻塞操作的队列接口，常用实现为LinkedBlockingDeque，适用于多线程环境下的生产者-消费者模型。1. 它提供add、offer、put等插入方法，对应异常、返回false和阻塞等待三种失败处理方式；移除和检查操作也遵循类似命名规则。2. 基本使用示例展示了从头部和尾部添加与取出元素的过程。3. 多线程示例中，生产者通过putLast向尾部添加任务，消费者用takeFirst从头部获取并处理，实现线程间安全协作。4. 使用建议包括设置合理容量防内存溢出，优先使用阻塞方法如put/poll，正确处理中断异常，并根据LIFO或FIFO需求设计数据流向。BlockingDeque具备线程安全、阻塞等待和双向操作优势，适合复杂并发场景的数据缓冲与调度。

如何在java中使用blockingdeque实现双端队列

在Java中，BlockingDeque 是一个支持两端插入和移除操作的阻塞双端队列接口。它适用于多线程环境，当队列满或空时，插入或移除操作会自动阻塞，直到可以继续操作。它是 java.util.concurrent 包的一部分，常用于生产者-消费者模型中需要从两端操作数据的场景。

1. BlockingDeque 接口与实现类

BlockingDeque 是一个接口，最常用的实现类是 LinkedBlockingDeque。它基于链表结构实现，支持可选的容量限制（如果不设置则为无界）。

常见方法分类如下：

插入操作：addFirst(e), addLast(e), offerFirst(e), offerLast(e), putFirst(e), putLast(e)
移除操作：removeFirst(), removeLast(), pollFirst(), pollLast(), takeFirst(), takeLast()
检查操作：peekFirst(), peekLast()

这些方法的行为略有不同：

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

Motiff

Motiff是由猿辅导旗下的一款界面设计工具，定位为“AI时代设计工具”

148

查看详情

以 add 开头的方法：失败时抛出异常
以 offer 开头的方法：失败时返回 false
以 put 开头的方法：阻塞直到成功（适合并发环境）

2. 基本使用示例

下面是一个简单的例子，展示如何创建并使用 LinkedBlockingDeque：

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

public class BlockingDequeExample {
    public static void main(String[] args) {
        // 创建一个可选容量的双端阻塞队列
        BlockingDeque<String> deque = new LinkedBlockingDeque<>(5);

        // 从尾部添加元素（不会阻塞，除非队列满）
        deque.addLast("item1");
        deque.addLast("item2");

        // 从头部添加
        deque.addFirst("front-item");

        // 从尾部取出
        System.out.println(deque.pollLast()); // 输出: item2

        // 从头部取出
        System.out.println(deque.pollFirst()); // 输出: front-item
    }
}

登录后复制

3. 多线程环境下的使用

BlockingDeque 的最大优势在于多线程安全和阻塞特性。以下是一个生产者-消费者示例，展示线程间的协作：

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

class Producer implements Runnable {
    private final BlockingDeque<String> deque;

    public Producer(BlockingDeque<String> deque) {
        this.deque = deque;
    }

    @Override
    public void run() {
        try {
            for (int i = 1; i <= 5; i++) {
                String item = "Task-" + i;
                deque.putLast(item); // 阻塞式插入尾部
                System.out.println("生产者添加: " + item);
                Thread.sleep(500);
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

class Consumer implements Runnable {
    private final BlockingDeque<String> deque;

    public Consumer(BlockingDeque<String> deque) {
        this.deque = deque;
    }

    @Override
    public void run() {
        try {
            while (true) {
                String item = deque.takeFirst(); // 阻塞式从头部取出
                System.out.println("消费者处理: " + item);
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

public class ProducerConsumerExample {
    public static void main(String[] args) {
        BlockingDeque<String> deque = new LinkedBlockingDeque<>(3);
        Thread producer = new Thread(new Producer(deque));
        Thread consumer = new Thread(new Consumer(deque));

        producer.start();
        consumer.start();

        try {
            producer.join();
            consumer.interrupt(); // 生产结束，中断消费者
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

登录后复制