如何在Java中使用LinkedBlockingDeque-java教程-PHP中文网

如何在Java中使用LinkedBlockingDeque

P粉602998670

发布： 2025-09-24 19:34:02

原创

583人浏览过

LinkedBlockingDeque是线程安全的双端阻塞队列，基于链表实现，支持两端插入和删除，适用于多线程生产者-消费者场景。1. 可通过无参构造函数创建默认容量为Integer.MAX_VALUE的实例，或指定最大容量。2. 提供三类操作：抛出异常（addFirst/removeFirst）、返回特殊值（offerFirst/pollFirst）、阻塞等待（putFirst/takeFirst）。3. 示例中生产者调用putLast添加元素，消费者调用takeFirst取出元素，实现线程间协作。4. 注意事项：使用ReentrantLock保证线程安全，但同一时刻仅一个线程可修改；高并发下性能可能低于ConcurrentLinkedDeque；建议合理设置容量避免内存问题；阻塞方法需处理中断。正确理解其方法分类与线程行为是关键。

如何在java中使用linkedblockingdeque

在Java中，LinkedBlockingDeque 是一个线程安全的双端队列实现，基于链表结构，支持从队列两端进行插入和删除操作。它适合用于多线程环境下的生产者-消费者场景，尤其当你需要双向操作队列时。

1. 创建 LinkedBlockingDeque 实例

你可以通过无参构造函数创建一个默认容量为 Integer.MAX_VALUE 的双端阻塞队列，也可以指定最大容量。

LinkedBlockingDeque<String> deque = new LinkedBlockingDeque<>(); // 容量无限
LinkedBlockingDeque<Integer> deque = new LinkedBlockingDeque<>(10); // 最多容纳10个元素

2. 常用添加与移除方法

LinkedBlockingDeque 支持多种插入和取出方式，分为抛出异常、返回特殊值（null/boolean）、阻塞等待三类。

插入操作：

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

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

addFirst(e) / addLast(e)：在队首或队尾插入元素，失败时抛出异常。
offerFirst(e) / offerLast(e)：成功返回 true，否则 false。
putFirst(e) / putLast(e)：如果队列满，会阻塞直到有空间可用。

移除操作：

removeFirst() / removeLast()：获取并移除元素，为空时抛异常。
pollFirst() / pollLast()：为空时返回 null。
takeFirst() / takeLast()：如果队列为空，会阻塞直到有元素可用。

3. 实际使用示例

下面是一个简单的多线程示例，演示生产者从队尾放入数据，消费者从队首取出数据：

LinkedBlockingDeque<String> deque = new LinkedBlockingDeque<>(5);

// 生产者线程
Thread producer = new Thread(() -> {
    try {
        deque.putLast("item-1");
        System.out.println("生产: item-1");
        Thread.sleep(1000);
        deque.putLast("item-2");
        System.out.println("生产: item-2");
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
});

// 消费者线程
Thread consumer = new Thread(() -> {
    try {
        String item = deque.takeFirst();
        System.out.println("消费: " + item);
        item = deque.takeFirst();
        System.out.println("消费: " + item);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
});

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

登录后复制