当前位置：首页 > 文章列表 > 文章 > java教程 > 如何在Java中使用BlockingDeque实现双端队列

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

2026-02-06 10:16:10 0浏览收藏

有志者，事竟成！如果你在学习文章，那么本文《如何在Java中使用BlockingDeque实现双端队列》，就很适合你！文章讲解的知识点主要包括，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

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

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

以 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 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 deque;

    public Producer(BlockingDeque 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 deque;

    public Consumer(BlockingDeque 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 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();
        }
    }
}