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

本文涉及的产品
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介: 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中提供的那些基础工具类!

相关文章
|
23天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
61 2
|
8天前
|
存储 算法 Java
Java内存管理深度解析####
本文深入探讨了Java虚拟机(JVM)中的内存分配与垃圾回收机制,揭示了其高效管理内存的奥秘。文章首先概述了JVM内存模型,随后详细阐述了堆、栈、方法区等关键区域的作用及管理策略。在垃圾回收部分,重点介绍了标记-清除、复制算法、标记-整理等多种回收算法的工作原理及其适用场景,并通过实际案例分析了不同GC策略对应用性能的影响。对于开发者而言,理解这些原理有助于编写出更加高效、稳定的Java应用程序。 ####
|
10天前
|
Java 数据库连接 开发者
Java中的异常处理机制:深入解析与最佳实践####
本文旨在为Java开发者提供一份关于异常处理机制的全面指南,从基础概念到高级技巧,涵盖try-catch结构、自定义异常、异常链分析以及最佳实践策略。不同于传统的摘要概述,本文将以一个实际项目案例为线索,逐步揭示如何高效地管理运行时错误,提升代码的健壮性和可维护性。通过对比常见误区与优化方案,读者将获得编写更加健壮Java应用程序的实用知识。 --- ####
|
14天前
|
数据采集 存储 Web App开发
Java爬虫:深入解析商品详情的利器
在数字化时代,信息处理能力成为企业竞争的关键。本文探讨如何利用Java编写高效、准确的商品详情爬虫,涵盖爬虫技术概述、Java爬虫优势、开发步骤、法律法规遵守及数据处理分析等内容,助力电商领域市场趋势把握与决策支持。
|
19天前
|
存储 安全 Java
Java多线程编程中的并发容器:深入解析与实战应用####
在本文中,我们将探讨Java多线程编程中的一个核心话题——并发容器。不同于传统单一线程环境下的数据结构,并发容器专为多线程场景设计,确保数据访问的线程安全性和高效性。我们将从基础概念出发,逐步深入到`java.util.concurrent`包下的核心并发容器实现,如`ConcurrentHashMap`、`CopyOnWriteArrayList`以及`BlockingQueue`等,通过实例代码演示其使用方法,并分析它们背后的设计原理与适用场景。无论你是Java并发编程的初学者还是希望深化理解的开发者,本文都将为你提供有价值的见解与实践指导。 --- ####
|
19天前
|
Java 测试技术 API
Java 反射机制:深入解析与应用实践
《Java反射机制:深入解析与应用实践》全面解析Java反射API,探讨其内部运作原理、应用场景及最佳实践,帮助开发者掌握利用反射增强程序灵活性与可扩展性的技巧。
50 4
|
24天前
|
存储 算法 Java
Java Set深度解析:为何它能成为“无重复”的代名词?
Java的集合框架中,Set接口以其“无重复”特性著称。本文解析了Set的实现原理,包括HashSet和TreeSet的不同数据结构和算法,以及如何通过示例代码实现最佳实践。选择合适的Set实现类和正确实现自定义对象的hashCode()和equals()方法是关键。
26 4
|
2月前
|
缓存 Java 程序员
Map - LinkedHashSet&Map源码解析
Map - LinkedHashSet&Map源码解析
72 0
|
2月前
|
算法 Java 容器
Map - HashSet & HashMap 源码解析
Map - HashSet & HashMap 源码解析
57 0
|
2月前
|
存储 Java C++
Collection-PriorityQueue源码解析
Collection-PriorityQueue源码解析
64 0

推荐镜像

更多