ArrayBlockingQueue 和 LinkedBlockingQueue 有什么区别?

简介: ArrayBlockingQueue 和 LinkedBlockingQueue 有什么区别?

!! 有的时候博客内容会有变动,首发博客是最新的,其他博客地址可能会未同步,认准https://blog.zysicyj.top

首发博客地址[1]

面试题手册[2]

系列文章地址[3]


1. 什么是 ArrayBlockingQueue 和 LinkedBlockingQueue?

  • ArrayBlockingQueue:是一个基于数组实现的有界阻塞队列,它按照先进先出(FIFO)的原则对元素进行排序。
  • LinkedBlockingQueue:是一个基于链表实现的可选有界或无界阻塞队列,它也按照先进先出(FIFO)的原则对元素进行排序。

2. 为什么需要 ArrayBlockingQueue 和 LinkedBlockingQueue?

在多线程编程中,我们经常需要使用队列来实现线程间的数据共享。而阻塞队列是一种特殊的队列,当队列为空时,从队列中获取元素的操作会被阻塞;当队列满时,往队列中添加元素的操作会被阻塞。这样可以有效地控制线程之间的协作和同步。

ArrayBlockingQueue 和 LinkedBlockingQueue 都是 Java 并发包提供的线程安全的阻塞队列实现,它们提供了不同的特性和适用场景。

3. ArrayBlockingQueue 和 LinkedBlockingQueue 的实现原理?

ArrayBlockingQueue

  • ArrayBlockingQueue 内部使用一个定长数组来存储元素,通过两个指针分别指向队头和队尾。
  • 当往队列中添加元素时,如果队列已满,则添加操作会被阻塞,直到有空闲位置。
  • 当从队列中获取元素时,如果队列为空,则获取操作会被阻塞,直到有可用元素。
  • ArrayBlockingQueue 使用 ReentrantLock 来保证线程安全,并通过 Condition 实现阻塞和唤醒机制。

LinkedBlockingQueue

  • LinkedBlockingQueue 内部使用一个链表来存储元素,每个节点包含一个元素和指向下一个节点的引用。
  • 当往队列中添加元素时,如果队列已满(对于有界队列),则添加操作会被阻塞,直到有空闲位置。
  • 当从队列中获取元素时,如果队列为空,则获取操作会被阻塞,直到有可用元素。
  • LinkedBlockingQueue 使用两把锁分别控制队头和队尾的访问,以提高并发性能。

4. ArrayBlockingQueue 和 LinkedBlockingQueue 的使用示例

ArrayBlockingQueue 示例:

import java.util.concurrent.ArrayBlockingQueue;
public class ArrayBlockingQueueExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个容量为3的ArrayBlockingQueue
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(3);
        // 往队列中添加元素
        queue.put(1);
        queue.put(2);
        queue.put(3);
        // 队列已满,添加操作会被阻塞
        queue.put(4);
        // 从队列中获取元素
        int element = queue.take();
        System.out.println("取出元素:" + element);
        // 队列已空,获取操作会被阻塞
        int element2 = queue.take();
    }
}

LinkedBlockingQueue 示例:

import java.util.concurrent.LinkedBlockingQueue;
public class LinkedBlockingQueueExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个容量为3的LinkedBlockingQueue
        LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<>(3);
        // 往队列中添加元素
        queue.put(1);
        queue.put(2);
        queue.put(3);
        // 队列已满,添加操作会被阻塞
        queue.put(4);
        // 从队列中获取元素
        int element = queue.take();
        System.out.println("取出元素:" + element);
        // 队列已空,获取操作会被阻塞
        int element2 = queue.take();
    }
}

5. ArrayBlockingQueue 和 LinkedBlockingQueue 的优点

  • ArrayBlockingQueue:
  • 内部使用数组实现,读写性能较高。
  • 支持有界队列,可以限制队列的大小。
  • LinkedBlockingQueue:
  • 内部使用链表实现,插入和删除性能较高。
  • 支持可选的有界或无界队列。

6. ArrayBlockingQueue 和 LinkedBlockingQueue 的缺点

  • ArrayBlockingQueue:
  • 容量固定,不支持动态扩容。
  • 在并发情况下,可能存在线程饥饿问题(某些线程一直无法获取到锁)。
  • LinkedBlockingQueue:
  • 内存消耗较大,因为每个节点都需要额外的空间来存储引用。
  • 在并发情况下,可能存在线程饥饿问题(某些线程一直无法获取到锁)。

7. ArrayBlockingQueue 和 LinkedBlockingQueue 的使用注意事项

  • ArrayBlockingQueue:
  • 需要指定队列的容量大小。
  • 当队列已满时,添加操作会被阻塞。
  • 当队列为空时,获取操作会被阻塞。
  • LinkedBlockingQueue:
  • 可以选择有界或无界队列。
  • 当队列已满时(对于有界队列),添加操作会被阻塞。
  • 当队列为空时,获取操作会被阻塞。

8. 总结

ArrayBlockingQueue 和 LinkedBlockingQueue 是 Java 并发包提供的线程安全的阻塞队列实现。它们分别基于数组和链表来存储元素,并提供了不同的特性和适用场景。ArrayBlockingQueue 适合读写性能较高、固定容量的场景;而 LinkedBlockingQueue 适合插入和删除性能较高、可选有界或无界的场景。在使用时需要根据具体需求选择合适的队列实现。

参考资料

[1]

首发博客地址: https://blog.zysicyj.top/

[2]

面试题手册: https://store.amazingmemo.com/chapterDetail/1685324709017001

[3]

系列文章地址: https://blog.zysicyj.top/categories/技术文章/后端技术/系列文章/面试题精讲/

本文由 mdnice 多平台发布

相关文章
|
消息中间件 存储 运维
Rabbitmq消息大量堆积怎么办?
该文讨论了一个系统架构问题,主要涉及RabbitMQ在处理订单消息时遇到的性能瓶颈。首先,系统使用RabbitMQ是为了解耦和提高性能,前端创建订单后通过RabbitMQ发送消息给订单履约系统消费并执行后续操作。当订单流量激增时,消息堆积导致服务器压力增加。 排查解决方案: 1. 增加消费者以提高消费速度,但发现即使增加消费者,消息堆积问题仍未解决。 2. 分析消费者逻辑,发现调用库存系统接口可能导致处理速度慢。库存系统压力大,接口响应慢,加剧问题。 3. 实施清空堆积消息的策略,新建消费者快速消费消息并存储在表中,减轻服务器压力。待库存服务恢复后,再将消息推回RabbitMQ处理。
1128 1
|
Java Spring 容器
【Java】Spring如何扫描自定义的注解?
【Java】Spring如何扫描自定义的注解?
502 0
|
9月前
|
Arthas 监控 Java
Arthas thread(查看当前JVM的线程堆栈信息)
Arthas thread(查看当前JVM的线程堆栈信息)
1669 10
|
存储 安全 Java
Java线程池ThreadPoolExcutor源码解读详解03-阻塞队列之LinkedBlockingQueue
LinkedBlockingQueue 和 ArrayBlockingQueue 是 Java 中的两种阻塞队列实现,它们的主要区别在于: 1. **数据结构**:ArrayBlockingQueue 采用固定大小的数组实现,而 LinkedBlockingQueue 则使用链表实现。 2. **容量**:ArrayBlockingQueue 在创建时必须指定容量,而 LinkedBlockingQueue 可以在创建时不指定容量,默认容量为 Integer.MAX_VALUE。 总结起来,如果需要高效并发且内存不是主要考虑因素,LinkedBlockingQueue 通常是更好的选择;
498 1
|
存储 监控 Java
JAVA线程池有哪些队列? 以及它们的适用场景案例
不同的线程池队列有着各自的特点和适用场景,在实际使用线程池时,需要根据具体的业务需求、系统资源状况以及对任务执行顺序、响应时间等方面的要求,合理选择相应的队列来构建线程池,以实现高效的任务处理。
749 12
|
存储 Prometheus Cloud Native
分布式系统架构6:链路追踪
本文深入探讨了分布式系统中的链路追踪理论,涵盖追踪与跨度的概念、追踪系统的模块划分及数据收集的三种方式。链路追踪旨在解决复杂分布式系统中请求流转路径不清晰的问题,帮助快速定位故障和性能瓶颈。文中介绍了基于日志、服务探针和边车代理的数据收集方法,并简述了OpenTracing、OpenCensus和OpenTelemetry等链路追踪协议的发展历程及其特点。通过理解这些概念,可以更好地掌握开源链路追踪框架的使用。
1308 41
|
SpringCloudAlibaba 负载均衡 Dubbo
【SpringCloud Alibaba系列】Dubbo高级特性篇
本章我们介绍Dubbo的常用高级特性,包括序列化、地址缓存、超时与重试机制、多版本、负载均衡。集群容错、服务降级等。
1910 6
【SpringCloud Alibaba系列】Dubbo高级特性篇
|
缓存 安全 Java
Spring框架中Bean是如何加载的?从底层源码入手,详细解读Bean的创建流程
从底层源码入手,通过代码示例,追踪AnnotationConfigApplicationContext加载配置类、启动Spring容器的整个流程,并对IOC、BeanDefinition、PostProcesser等相关概念进行解释
2263 25
Spring框架中Bean是如何加载的?从底层源码入手,详细解读Bean的创建流程
|
监控 安全 Java
什么是AOP?如何与Spring Boot一起使用?
什么是AOP?如何与Spring Boot一起使用?
1069 5
|
消息中间件 存储 监控
RocketMQ的性能优势?
【8月更文挑战第29天】RocketMQ的性能优势?
517 2