Java并发基础:LinkedBlockingDeque全面解析!

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
全局流量管理 GTM,标准版 1个月
云解析 DNS,旗舰版 1个月
简介: LinkedBlockingDeque提供了线程安全的双端队列实现,它支持在队列两端高效地进行插入和移除操作,同时具备阻塞功能,能够很好地协调生产者与消费者之间的速度差异,其内部基于链表结构,使得并发性能优异,是处理多线程间数据传递的理想选择。

Java并发基础:LinkedBlockingDeque全面解析! - 程序员古德

内容概要

LinkedBlockingDeque提供了线程安全的双端队列实现,它支持在队列两端高效地进行插入和移除操作,同时具备阻塞功能,能够很好地协调生产者与消费者之间的速度差异,其内部基于链表结构,使得并发性能优异,是处理多线程间数据传递的理想选择。

核心概念

LinkedBlockingDeque 实现了一个线程安全的双端队列(Deque,即 double-ended queue),这个队列在两端都可以添加和移除元素,而且它是阻塞的,意味着当队列为空时,如果线程尝试从队列中取元素,线程会被阻塞,直到队列中有元素可供取出;同样地,如果队列已满,尝试添加元素的线程也会被阻塞,直到队列中有空间可供添加新元素。

举一个生活中的实际案例,比如一个面包店,面包师傅负责生产面包(生产者),顾客来店里买面包(消费者),面包师傅做好面包后,会把它们放在一个展示架上供顾客挑选;顾客则从这个展示架上取走他们想要的面包,这里使用LinkedBlockingDeque 来模拟这个场景。面包师傅(生产者线程)在队列的一端放入新做好的面包(添加元素到队列),而顾客(消费者线程)从队列的另一端取走面包(从队列中移除元素):

  1. 阻塞特性:如果展示架上没有面包(队列为空),顾客就会被阻塞,直到面包师傅做好新的面包并放到展示架上,同样,如果展示架满了(队列已满),面包师傅就会被阻塞,直到有顾客取走一些面包,腾出空间来放新的面包。
  2. 双端操作:在这个场景中,虽然通常面包师傅只在一端放面包,顾客在另一端取面包,但双端队列的灵活性意味着也可以轻松改变这个行为,比如,如果有特殊情况,面包师傅可以从展示架上取回一些面包(从队列的另一端移除元素),或者顾客可以预先把他们的面包订单放到展示架上(在队列的另一端添加元素)。

LinkedBlockingDeque 是一个线程安全的双端队列,允许从队列的两端添加和移除元素,并且它是阻塞的,他通常用来解决以下问题:

  1. 线程安全:在多线程环境中,当多个线程需要访问和修改共享数据时,LinkedBlockingDeque 提供了一种线程安全的方式来存储和检索这些数据,它内部的同步机制确保了数据的一致性和完整性。
  2. 阻塞操作:当队列为空时,消费者线程调用 take() 方法会被阻塞,直到生产者线程向队列中添加元素,同样,当队列已满时,生产者线程调用 put() 方法也会被阻塞,直到消费者线程从队列中移除元素,这种阻塞行为有助于防止线程在不必要的情况下空转或浪费CPU资源。
  3. 容量限制LinkedBlockingDeque 可以在创建时指定一个最大容量,这个容量限制了队列中可以存储的元素数量,有助于防止内存溢出,当队列达到最大容量时,生产者线程会被阻塞,直到队列中有空间可用。
  4. 双端操作:与普通的 BlockingQueue 接口实现相比,LinkedBlockingDeque 提供了双端队列的功能,允许从队列的两端添加和移除元素,这为某些特定的应用场景提供了更大的灵活性。
  5. 高效的并发性能:由于其内部使用链表数据结构,LinkedBlockingDeque 在处理大量并发操作时通常具有较好的性能,它适用于需要高吞吐量和低延迟的生产者-消费者场景。

代码案例

下面是一个简单的例子,演示了如何使用 LinkedBlockingDeque 类,如下代码:

import java.util.concurrent.BlockingQueue;  
import java.util.concurrent.LinkedBlockingDeque;  

public class LinkedBlockingDequeExample {
   
     

    public static void main(String[] args) throws InterruptedException {
   
     
        // 创建一个容量为 5 的 LinkedBlockingDeque  
        BlockingQueue<String> deque = new LinkedBlockingDeque<>(5);  

        // 启动一个生产者线程,向队列中添加元素  
        Thread producer = new Thread(() -> {
   
     
            try {
   
     
                for (int i = 0; i < 10; i++) {
   
     
                    String item = "Item-" + i;  
                    deque.put(item); // 当队列满时,该方法会阻塞  
                    System.out.println("Produced: " + item);  
                    Thread.sleep(200); // 模拟生产延迟  
                }  
            } catch (InterruptedException e) {
   
     
                e.printStackTrace();  
            }  
        });  

        // 启动一个消费者线程,从队列中移除元素  
        Thread consumer = new Thread(() -> {
   
     
            try {
   
     
                for (int i = 0; i < 10; i++) {
   
     
                    String item = deque.take(); // 当队列空时,该方法会阻塞  
                    System.out.println("Consumed: " + item);  
                    Thread.sleep(300); // 模拟消费延迟  
                }  
            } catch (InterruptedException e) {
   
     
                e.printStackTrace();  
            }  
        });  

        // 启动生产者和消费者线程  
        producer.start();  
        consumer.start();  

        // 等待两个线程执行完成  
        producer.join();  
        consumer.join();  

        System.out.println("Producer and Consumer threads have finished.");  
    }  
}

在上面代码中,创建了一个 LinkedBlockingDeque 实例,并指定了它的最大容量为 5,然后创建了一个生产者线程和一个消费者线程,生产者线程将循环 10 次,每次生产一个字符串并将其放入队列中,如果队列已满,put 方法将会阻塞直到队列中有空间可用,消费者线程也将循环 10 次,每次从队列中取出一个元素并打印它,如果队列为空,take 方法将会阻塞直到队列中有元素可取。

由于生产者和消费者线程的速度可能不同,LinkedBlockingDeque 作为一个阻塞队列,能够协调这两个线程之间的速度差异,确保它们可以协同工作,而不会因为队列为空或满而导致任何一方停滞不前。

核心API

LinkedBlockingDeque 实现了 BlockingDeque 接口,是一个线程安全的双端队列,以下是 LinkedBlockingDeque 类中一些主要方法的含义:

  1. add(E e)
    将指定的元素插入到此双端队列表示的队列中(即在此双端队列的尾部),如果立即可行且不会违反容量限制,则成功时返回 true,如果当前没有可用的空间,则抛出 IllegalStateException,这是 Queue 接口的方法。
  2. offer(E e)
    将指定的元素插入到此双端队列表示的队列中(即在此双端队列的尾部),如果立即可行且不会违反容量限制,则成功时返回 true,如果当前没有可用的空间,则返回 false,这是 Queue 接口的方法。
  3. put(E e) throws InterruptedException
    将指定的元素插入到此双端队列表示的队列中(即在此双端队列的尾部),必要时将等待空间变得可用,这是 BlockingQueue 接口的方法。
  4. offer(E e, long timeout, TimeUnit unit)
    将指定的元素插入到此双端队列表示的队列中,必要时将等待指定的时间以使空间变得可用,这是 BlockingQueue 接口的方法。
  5. remove()
    获取并移除此双端队列表示的队列的头部,如果此双端队列为空,则抛出 NoSuchElementException,这是 Queue 接口的方法。
  6. poll()
    获取并移除此双端队列表示的队列的头部,如果此双端队列为空,则返回 null,这是 Queue 接口的方法。
  7. take() throws InterruptedException
    获取并移除此双端队列表示的队列的头部,在元素变得可用之前一直等待,这是 BlockingQueue 接口的方法。
  8. poll(long timeout, TimeUnit unit)
    获取并移除此双端队列表示的队列的头部,在指定的时间内等待元素变得可用,这是 BlockingQueue 接口的方法。
  9. peek()
    获取但不移除此双端队列表示的队列的头部,如果此双端队列为空,则返回 null,这是 Queue 接口的方法。
  10. element()
    获取但不移除此双端队列表示的队列的头部,这是 Queue 接口的方法。
  11. push(E e)
    将元素推入此双端队列表示的堆栈中(即在此双端队列的头部),如果立即可行且不会违反容量限制,则成功时返回 true,如果当前没有可用的空间,则抛出 IllegalStateException
  12. pop()
    从此双端队列表示的堆栈中弹出一个元素,如果此双端队列为空,则抛出 NoSuchElementException
  13. addFirst(E e), addLast(E e)
    将指定的元素插入此双端队列的开头或结尾。
  14. offerFirst(E e), offerLast(E e)
    将指定的元素插入此双端队列的开头或结尾,如果立即可行且不会违反容量限制,则成功时返回 true,如果当前没有可用的空间,则返回 false
  15. removeFirst(), removeLast()
    获取并移除此双端队列的第一个元素或最后一个元素。
  16. pollFirst(), pollLast()
    获取并移除此双端队列的第一个元素或最后一个元素,如果此双端队列为空,则返回 null
  17. getFirst(), getLast()
    获取但不移除此双端队列的第一个元素或最后一个元素。
  18. peekFirst(), peekLast()
    获取但不移除此双端队列的第一个元素或最后一个元素,如果此双端队列为空,则返回 null

核心总结

Java并发基础:LinkedBlockingDeque全面解析! - 程序员古德

LinkedBlockingDeque类它融合了阻塞队列和双端队列的特性,其优点在于高效的并发性能和灵活的两端操作,适合在生产者-消费者场景中使用,能够很好地处理多线程间的数据共享和传递,缺点在高并发下如果队列大小设置不当,可能会导致过多的线程阻塞,影响系统整体性能,此外,由于是基于链表的实现,其内存占用可能相对较高。

关注我,每天学习互联网编程技术 - 程序员古德

END!

往期回顾

Java并发基础:LinkedBlockingDeque全面解析!

Java并发基础:LinkedTransferQueue全面解析!

Java并发基础:LinkedBlockingQueue全面解析!

Java并发基础:Deque接口和Queue接口的区别?

Spring核心基础:全面总结Spring中提供的那些基础工具类!

相关文章
|
13天前
|
存储 Java 计算机视觉
Java二维数组的使用技巧与实例解析
本文详细介绍了Java中二维数组的使用方法
30 15
|
13天前
|
算法 搜索推荐 Java
【潜意识Java】深度解析黑马项目《苍穹外卖》与蓝桥杯算法的结合问题
本文探讨了如何将算法学习与实际项目相结合,以提升编程竞赛中的解题能力。通过《苍穹外卖》项目,介绍了订单配送路径规划(基于动态规划解决旅行商问题)和商品推荐系统(基于贪心算法)。这些实例不仅展示了算法在实际业务中的应用,还帮助读者更好地准备蓝桥杯等编程竞赛。结合具体代码实现和解析,文章详细说明了如何运用算法优化项目功能,提高解决问题的能力。
48 6
|
8天前
|
小程序 前端开发 关系型数据库
uniapp跨平台框架,陪玩系统并发性能测试,小程序源码搭建开发解析
多功能一体游戏陪练、语音陪玩系统的开发涉及前期准备、技术选型、系统设计与开发及测试优化。首先,通过目标用户分析和竞品分析明确功能需求,如注册登录、预约匹配、实时语音等。技术选型上,前端采用Uni-app支持多端开发,后端选用PHP框架确保稳定性能,数据库使用MySQL保证数据一致性。系统设计阶段注重UI/UX设计和前后端开发,集成WebSocket实现语音聊天。最后,通过功能、性能和用户体验测试,确保系统的稳定性和用户满意度。
|
13天前
|
存储 算法 搜索推荐
【潜意识Java】期末考试可能考的高质量大题及答案解析
Java 期末考试大题整理:设计一个学生信息管理系统,涵盖面向对象编程、集合类、文件操作、异常处理和多线程等知识点。系统功能包括添加、查询、删除、显示所有学生信息、按成绩排序及文件存储。通过本题,考生可以巩固 Java 基础知识并掌握综合应用技能。代码解析详细,适合复习备考。
16 4
|
13天前
|
Java 编译器 程序员
【潜意识Java】期末考试可能考的简答题及答案解析
为了帮助同学们更好地准备 Java 期末考试,本文列举了一些常见的简答题,并附上详细的答案解析。内容包括类与对象的区别、多态的实现、异常处理、接口与抽象类的区别以及垃圾回收机制。通过这些题目,同学们可以深入理解 Java 的核心概念,从而在考试中更加得心应手。每道题都配有代码示例和详细解释,帮助大家巩固知识点。希望这些内容能助力大家顺利通过考试!
15 0
|
3月前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
121 2
|
4月前
|
缓存 Java 程序员
Map - LinkedHashSet&Map源码解析
Map - LinkedHashSet&Map源码解析
97 1
|
2月前
|
设计模式 存储 安全
【23种设计模式·全精解析 | 创建型模式篇】5种创建型模式的结构概述、实现、优缺点、扩展、使用场景、源码解析
创建型模式的主要关注点是“怎样创建对象?”,它的主要特点是"将对象的创建与使用分离”。这样可以降低系统的耦合度,使用者不需要关注对象的创建细节。创建型模式分为5种:单例模式、工厂方法模式抽象工厂式、原型模式、建造者模式。
【23种设计模式·全精解析 | 创建型模式篇】5种创建型模式的结构概述、实现、优缺点、扩展、使用场景、源码解析
|
2月前
|
存储 设计模式 算法
【23种设计模式·全精解析 | 行为型模式篇】11种行为型模式的结构概述、案例实现、优缺点、扩展对比、使用场景、源码解析
行为型模式用于描述程序在运行时复杂的流程控制,即描述多个类或对象之间怎样相互协作共同完成单个对象都无法单独完成的任务,它涉及算法与对象间职责的分配。行为型模式分为类行为模式和对象行为模式,前者采用继承机制来在类间分派行为,后者采用组合或聚合在对象间分配行为。由于组合关系或聚合关系比继承关系耦合度低,满足“合成复用原则”,所以对象行为模式比类行为模式具有更大的灵活性。 行为型模式分为: • 模板方法模式 • 策略模式 • 命令模式 • 职责链模式 • 状态模式 • 观察者模式 • 中介者模式 • 迭代器模式 • 访问者模式 • 备忘录模式 • 解释器模式
【23种设计模式·全精解析 | 行为型模式篇】11种行为型模式的结构概述、案例实现、优缺点、扩展对比、使用场景、源码解析
|
2月前
|
设计模式 存储 安全
【23种设计模式·全精解析 | 创建型模式篇】5种创建型模式的结构概述、实现、优缺点、扩展、使用场景、源码解析
结构型模式描述如何将类或对象按某种布局组成更大的结构。它分为类结构型模式和对象结构型模式,前者采用继承机制来组织接口和类,后者釆用组合或聚合来组合对象。由于组合关系或聚合关系比继承关系耦合度低,满足“合成复用原则”,所以对象结构型模式比类结构型模式具有更大的灵活性。 结构型模式分为以下 7 种: • 代理模式 • 适配器模式 • 装饰者模式 • 桥接模式 • 外观模式 • 组合模式 • 享元模式
【23种设计模式·全精解析 | 创建型模式篇】5种创建型模式的结构概述、实现、优缺点、扩展、使用场景、源码解析

推荐镜像

更多