简单易懂的Java Queue入门教程!

news2024/11/13 5:31:47

哈喽,各位小伙伴们,你们好呀,我是喵手。运营社区:C站/掘金/腾讯云;欢迎大家常来逛逛

  今天我要给大家分享一些自己日常学习到的一些知识点,并以文字的形式跟大家一起交流,互相学习,一个人虽可以走的更快,但一群人可以走的更远。

  我是一名后端开发爱好者,工作日常接触到最多的就是Java语言啦,所以我都尽量抽业余时间把自己所学到所会的,通过文章的形式进行输出,希望以这种方式帮助到更多的初学者或者想入门的小伙伴们,同时也能对自己的技术进行沉淀,加以复盘,查缺补漏。

小伙伴们在批阅的过程中,如果觉得文章不错,欢迎点赞、收藏、关注哦。三连即是对作者我写作道路上最好的鼓励与支持!

前言

  在软件开发领域,队列是一种非常重要的数据结构。它被广泛应用于多线程、网络通信、缓存、消息队列等场景。Java语言提供了多种队列实现,其中最常用的是Queue接口及其实现类。下面将详细介绍Java中的Queue及其应用场景。

摘要

  本文将介绍Java中Queue接口及其实现类的概念、源代码解析、应用场景案例、优缺点分析、类代码方法介绍、测试用例等内容。原则上,读者需要掌握Java基础语法及数据结构相关知识。

Queue

简介

  Queue是Java中的一种接口,它继承自Collection接口,并添加了一些队列相关的方法。Queue的实现类有多种,包括LinkedList、ArrayBlockingQueue、PriorityQueue、ConcurrentLinkedQueue等。下面简要介绍一下各个实现类的特点:

  1. LinkedList

  LinkedList是Java中的一个双向链表实现类。LinkedList实现了Deque接口,Deque又是Queue接口的子接口,因此LinkedList可以被视为Queue的一种实现。LinkedList的优点是插入、删除操作效率高,但是随机访问效率低。

  1. ArrayBlockingQueue

  ArrayBlockingQueue是Java中的一个基于数组的有界阻塞队列实现类。它的内部实现类似于一个环形数组,数组的长度是固定的。ArrayBlockingQueue具有先进先出的队列特性,它支持多线程安全访问,可以指定等待时间,当队列满或空时,线程将被阻塞。

  1. PriorityQueue

  PriorityQueue是Java中的一个带优先级的队列实现类。它的内部是一个堆结构,根据元素的排序规则进行排序,每次出队时都会返回当前队列中最小(或最大)的元素。PriorityQueue的特点是插入、删除效率高,但是元素数量较大时遍历效率不高。

  1. ConcurrentLinkedQueue

  ConcurrentLinkedQueue是Java中的一个基于链表的无界并发队列实现类。ConcurrentLinkedQueue的特点是多线程安全,能够高效地处理高并发场景。它不支持阻塞操作,而且不保证元素的排序。

源代码解析

下面我们以ArrayBlockingQueue为例,简单解析一下它的源代码。

public class ArrayBlockingQueue<E> extends AbstractQueue<E>
        implements BlockingQueue<E>, java.io.Serializable {
    /** The queued items */
    final Object[] items;
    /** items index for next take, poll or remove */
    int takeIndex;
    /** items index for next put, offer, or add */
    int putIndex;
    /** Number of elements in the queue */
    int count;
    /** Main lock guarding all access */
    final ReentrantLock lock;
    /** Condition for waiting takes */
    private final Condition notEmpty;
    /** Condition for waiting puts */
    private final Condition notFull;
    // ...
}

  如上所示,ArrayBlockingQueue继承了AbstractQueue类,并实现了BlockingQueue接口和Serializable接口。其内部使用了一个Object数组items用于存储队列中的元素,使用takeIndex和putIndex分别表示下一次取出元素和添加元素的位置,使用count表示队列中当前元素个数,使用lock实现线程同步,使用notEmpty和notFull两个Condition实现阻塞和唤醒操作。

如下是部分源码截图:

在这里插入图片描述

应用场景案例

下面介绍一下Queue在实际开发中的应用场景:

  1. 消息队列

    在分布式系统中,消息队列是一种常用的通信方式。生产者向队列中添加消息,消费者从队列中取出消息进行处理。Java语言中提供的ActiveMQ和RabbitMQ等消息队列服务均使用了队列的相关技术。

  2. 线程池

    在Java中,线程池通常使用BlockingQueue来存储待执行的任务。当线程池中的线程已经全部分配任务时,新的任务将会被阻塞,直到有线程可用为止。Java中的ThreadPoolExecutor就是使用了BlockingQueue来存储待执行的任务。

  3. 缓存

  在Java中,缓存通常使用LinkedList或ConcurrentLinkedQueue来实现。缓存存储的是最近访问过的元素,当缓存已满时,新的元素会将最旧的元素移除。

优缺点分析

Queue的优缺点分析如下:

  1. 优点

    Queue能够高效地实现元素的插入、删除以及元素的存储。Queue还能够在多线程场景中安全地实现元素的读写操作。

  2. 缺点

  在某些场景下,Queue可能会存在性能瓶颈。例如当Queue中元素数量较大时,遍历操作效率较低,此时需要使用其他数据结构来优化性能。另外Queue中元素的顺序是固定的,无法对元素的顺序进行修改。

类代码方法介绍

Queue接口中包含了很多常用的方法,下面介绍一下其中一些常用的方法:

  1. add(E e)

    将元素e添加到队列尾部,如果队列已满,则抛出IllegalStateException异常。

  2. offer(E e)

    将元素e添加到队列尾部,返回值表示添加操作是否成功。

  3. remove()

    移除队列头部的元素并返回该元素,如果队列为空,则抛出NoSuchElementException异常。

  4. poll()

    移除队列头部的元素并返回该元素,如果队列为空,则返回null。

  5. element()

    返回队列头部的元素,如果队列为空,则抛出NoSuchElementException异常。

  6. peek()

    返回队列头部的元素,如果队列为空,则返回null。

测试用例

下面给出ArrayBlockingQueue的测试用例:

测试代码

package com.example.javase.collection;

import java.util.concurrent.*;

/**
 * @Author ms
 * @Date 2023-10-24 23:32
 */
public class QueueTest {

    private static final int BUFFER_SIZE = 10;
    private static final int PRODUCER_COUNT = 5;
    private static final int CONSUMER_COUNT = 5;
    private static final int ITEM_COUNT = 1000;

    private static final ExecutorService pool = Executors.newCachedThreadPool();

    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(BUFFER_SIZE);

        for (int i = 0; i < PRODUCER_COUNT; i++) {
            pool.execute(new Producer(queue, ITEM_COUNT));
        }

        for (int i = 0; i < CONSUMER_COUNT; i++) {
            pool.execute(new Consumer(queue, ITEM_COUNT));
        }

        TimeUnit.SECONDS.sleep(60);

        pool.shutdown();
    }

    static class Producer implements Runnable {
        final BlockingQueue<Integer> queue;
        final int count;

        Producer(BlockingQueue<Integer> queue, int count) {
            this.queue = queue;
            this.count = count;
        }

        public void run() {
            try {
                for (int i = 0; i < count; i++) {
                    queue.put(i);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }

    static class Consumer implements Runnable {
        final BlockingQueue<Integer> queue;
        final int count;

        Consumer(BlockingQueue<Integer> queue, int count) {
            this.queue = queue;
            this.count = count;
        }

        public void run() {
            try {
                for (int i = 0; i < count; i++) {
                    queue.take();
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }
}

  这段代码实现了生产者-消费者模型,使用了Java内置的阻塞队列ArrayBlockingQueue来作为共享的缓冲区。主要包含了三个部分:

  1. 定义了共享缓冲区的大小BUFFER_SIZE、生产者和消费者的数量PRODUCER_COUNT和CONSUMER_COUNT,以及需要生产和消费的数据ITEM_COUNT。

  2. 在main方法中,创建一个ArrayBlockingQueue实例,并分别创建PRODUCER_COUNT个生产者线程和CONSUMER_COUNT个消费者线程,然后分别启动这些线程并等待60秒钟后关闭线程池。

  3. Producer和Consumer类都实现了Runnable接口。在Producer的run方法中,不断向队列中添加数据,直到添加的次数达到ITEM_COUNT;在Consumer的run方法中,不断从队列中取出数据,直到取出的次数达到ITEM_COUNT。由于ArrayBlockingQueue是线程安全的,因此不需要做额外的同步处理。

  总的来说,这段代码展示了如何使用Java内置的阻塞队列来实现生产者-消费者模型,避免了手动实现同步和互斥的复杂性,提高了代码的可读性、可维护性和可复用性。

测试结果

  根据如上测试用例,本地测试结果如下,仅供参考,你们也可以自行修改测试用例或者添加更多的测试数据或测试方法,进行熟练学习以此加深理解。

在这里插入图片描述

代码分析

  根据如上测试用例,本地测试结果如下,仅供参考,你们也可以自行修改测试用例或者添加更多的测试数据或测试方法,进行熟练学习以此加深理解。
  该代码是一个使用 ArrayBlockingQueue 实现的生产者-消费者模型的示例。包含一个主类 ArrayBlockingQueueTest 和两个内部静态类 Producer 和 Consumer。主类中创建一个 ArrayBlockingQueue,然后创建 PRODUCER_COUNTProducer 线程和 CONSUMER_COUNTConsumer 线程,并启动它们。每个 Producer 线程向队列中插入 ITEM_COUNT 个元素,每个 Consumer 线程从队列中取出 ITEM_COUNT 个元素。当所有线程运行完毕后,程序将等待 60 秒钟,然后关闭线程池。

  ProducerConsumer 类实现了 Runnable 接口,分别包含一个 BlockingQueue 对象和一个 count 变量。在 run() 方法中,Producer 线程将元素插入队列中,Consumer 线程从队列中取出元素。如果队列已满(对于 Producer)或者队列为空(对于 Consumer),线程会进入阻塞状态。如果线程被中断,则中断状态会被设置并退出线程。

  该示例使用了线程池来管理并发任务,增加效率。使用 ArrayBlockingQueue 实现了并发访问控制,保证了线程安全。

小结

  Queue是Java中的一个接口,它的实现类包括LinkedListArrayBlockingQueuePriorityQueueConcurrentLinkedQueue等。Queue常用于消息队列、线程池、缓存等场景。在使用Queue时需要注意线程安全性和性能问题。

总结

  本文介绍了Java中Queue接口及其实现类的概念、源代码解析、应用场景案例、优缺点分析、类代码方法介绍、测试用例等内容。Queue是Java中常用的数据结构,能够高效地实现元素的插入、删除及存储,在多线程场景中也能保障线程安全。常用的Queue实现类有LinkedList、ArrayBlockingQueue、PriorityQueue、ConcurrentLinkedQueue等,它们都具有各自的优缺点。Queue的应用场景包括消息队列、线程池、缓存等。在使用Queue时需要注意性能问题和线程安全性。

… …

文末

好啦,以上就是我这期的全部内容,如果有任何疑问,欢迎下方留言哦,咱们下期见。

… …

学习不分先后,知识不分多少;事无巨细,当以虚心求教;三人行,必有我师焉!!!

wished for you successed !!!


⭐️若喜欢我,就请关注我叭。

⭐️若对您有用,就请点赞叭。

⭐️若有疑问,就请评论留言告诉我叭。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1666633.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

7. path路径绘制:使用path绘制曲线

曲线在SVG中通常是通过贝塞尔曲线命令来绘制的&#xff0c;包括二次贝塞尔曲线&#xff08;Q&#xff09;和三次贝塞尔曲线&#xff08;C&#xff09;。这些命令允许我们创建平滑的曲线路径。 贝塞尔曲线的原理 贝塞尔曲线的基本原理是通过控制点和锚点来定义一条曲线的形状。…

微服务下的技术栈架构解析

微服务是一种架构风格&#xff0c;它将一个复杂的应用拆分成多个独立自治的服务&#xff0c;每个服务负责应用程序中的一小部分功能。这些服务通过定义良好的API进行通信&#xff0c;通常是HTTP RESTful API或事件流。微服务架构的主要特点包括单一职责、自治性、可独立部署和扩…

14.跳跃游戏Ⅱ

文章目录 题目简介题目解答解法一&#xff1a;贪心算法动态规划代码&#xff1a;复杂度分析&#xff1a; 题目链接 大家好&#xff0c;我是晓星航。今天为大家带来的是 跳跃游戏Ⅱ 相关的讲解&#xff01;&#x1f600; 题目简介 题目解答 解法一&#xff1a;贪心算法动态规划…

03c++继承与多态

目录&#xff1a; 继承的本质和原理派生类的构造过程重载覆盖 隐藏静态绑定和动态绑定多态 vfptr和vftable抽象类的设计原理多重继承以及问题虚基类 vbptr和vbtableRTTIc四种类强转继承多态常见笔试面试题目分享 1、继承的本质和原理&#xff1a; 继承方式&#xff1a; 基类…

2023愚人杯 )————被遗忘的反序列化

<?php# 当前目录中有一个txt文件哦 error_reporting(0); show_source(__FILE__); include("check.php");class EeE{public $text;public $eeee;public function __wakeup(){if ($this->text "aaaa"){echo lcfirst($this->text);}}public functi…

如何远程操作服务器中的Python编译器并将运行结果返回到Pycharm

文章目录 一、前期准备1. 检查IDE版本是否支持2. 服务器需要开通SSH服务 二、Pycharm本地链接服务器测试1. 配置服务器python解释器 三、使用内网穿透实现异地链接服务器开发1. 服务器安装Cpolar2. 创建远程连接公网地址 四、使用固定TCP地址远程开发 本文主要介绍如何使用Pych…

1065 单身狗

solution “单身狗”&#xff1a;没有搭子或者搭子没来的参与者输出id时按增序输出 #include<iostream> #include<map> #include<algorithm> using namespace std; const int maxn 1e6, maxn1 1e4 10; int flag[maxn] {0}, all[maxn1]; int main(){int…

工程师工具箱系列(2)hasor

文章目录 工程师工具箱系列(2)hasor简介特点环境准备引入依赖数据库脚本文件配置Hasor配置 运行测试小结 工程师工具箱系列(2)hasor 简介 Hasor有着自己的独立的生命周期与Spring的不同&#xff0c;是一套完整的体系&#xff0c;提供了注入DataQL、Dataway、hasor-web等等&am…

《中阿科技论坛(中英文)》是什么级别的期刊?是正规期刊吗?

问题解答 问&#xff1a;《中阿科技论坛&#xff08;中英文&#xff09;》是核心期刊吗&#xff1f; 答&#xff1a;不是&#xff0c;但是正规期刊 问&#xff1a;《中阿科技论坛&#xff08;中英文&#xff09;》是什么级别期刊&#xff1f; 答&#xff1a;省级 主管单位…

十三、Redis哨兵模式--Sentinel

上一篇介绍了Redis中的主从复制。我们知道Redis主从中一般只有主节点对外提供写操作&#xff0c;如果主节点发生故障&#xff0c;为了保证Redis的可用性&#xff0c;这时就要在可用的slave节点中&#xff0c;挑选一个作为主节点。这种切换操作如果是人为的操作&#xff0c;那么…

i春秋-GetFlag

题目 考点 sql注入&#xff0c;md5加密&#xff0c;代码审计&#xff0c;利用eval函数 解题 参考wp https://www.cnblogs.com/qiaowukong/p/13630130.html找md5值 看见验证码中的提示&#xff0c;就是去找一个md5值前六位是指定值的数&#xff08;严格来说不一定是数&…

基于python的旅游爬虫可视化与实现

摘要 本项目为基于python的旅游爬虫可视化的设计与实现&#xff0c;项目以Web系统形式展示&#xff0c;利用Xpath爬虫爬取去哪儿网针对旅游业的需求&#xff0c;对国内热门旅游景点数据可视化系统&#xff0c;将爬取好的数据保存为CSV文件&#xff0c;再通过ORM框架导入MySQL数…

出现Duplicate key

解决&#xff1a; 第一种情况&#xff1a; 添加一个字段prjId &#xff0c;和数据库表映射时&#xff0c;映射的字段存在映射关系了。 将第二个 TableField中的prj_num改成prj_id 即可。 第二种情况&#xff1a; 转成map的形式时&#xff1a;key重复了&#xff0c;不知道把值赋…

QuickBooks 2024 for Mac 激活版:智慧管理,财务无忧

想要轻松掌控财务&#xff0c;实现高效管理吗&#xff1f;QuickBooks 2024 for Mac&#xff0c;您的智慧财务管理专家&#xff0c;为您带来前所未有的便利和体验。无论是账务、工资还是销售和库存&#xff0c;它都能一手搞定。直观易用的界面&#xff0c;让您轻松上手&#xff…

(二)Jetpack Compose 布局模型

前文回顾 &#xff08;一&#xff09;Jetpack Compose 从入门到会写-CSDN博客 首先让我们回顾一下上一篇文章中里提到过几个问题&#xff1a; ComposeView的层级关系&#xff0c;互相嵌套存在的问题&#xff1f; 为什么Compose可以实现只测量一次&#xff1f; ComposeView和…

加密与CA证书

文章目录 加密与CA证书http协议是不安全的使用对称秘钥进行数据加密非对称秘钥加密CA证书应用补充 加密与CA证书 CA 证书是什么&#xff0c;证书的目的是什么 首先明确一点&#xff0c;CA证书是数字时代中确保身份和数据安全的重要工具&#xff0c;为用户提供了安心、便捷和可…

vlock工具:锁定Linux终端的安全智能方法

虚拟控制台是 Linux 非常重要的功能&#xff0c;它们为系统用户提供 shell 提示&#xff0c;以非图形设置方式使用系统&#xff0c;该设置只能在物理机上使用&#xff0c;而不能远程使用。 用户只需从一个虚拟控制台切换到另一个虚拟控制台即可同时使用多个虚拟控制台会话。 …

[机器学习-05] Scikit-Learn机器学习工具包进阶指南:协方差估计和交叉分解功能实战【2024最新】

&#x1f3a9; 欢迎来到技术探索的奇幻世界&#x1f468;‍&#x1f4bb; &#x1f4dc; 个人主页&#xff1a;一伦明悦-CSDN博客 ✍&#x1f3fb; 作者简介&#xff1a; C软件开发、Python机器学习爱好者 &#x1f5e3;️ 互动与支持&#xff1a;&#x1f4ac;评论 &…

QT自适应界面 处理高DPI 缩放比界面乱问题

1.pro文件添加 必须添加要不找不到 QT版本需要 5。4 以上才支持 QT widgets 2.main界面提前处理 // 1. 全局缩放使能QApplication::setAttribute(Qt::AA_EnableHighDpiScaling, true);// 2. 适配非整数倍缩放QGuiApplication::setHighDpiScaleFactorRoundingPolicy(Qt::High…