深入浅出：ConcurrentLinkedQueue源码分析与实战

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

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

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

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

前言

  在多线程编程中，由于线程之间的竞争，导致多线程访问数据时容易出现数据不一致的问题，为了解决这个问题，Java提供了一些线程安全的数据结构，其中之一就是ConcurrentLinkedQueue，它是一个非阻塞的线程安全队列。

摘要

  本文主要介绍ConcurrentLinkedQueue的源代码解析、应用场景案例、优缺点分析、类代码方法介绍以及测试用例。

ConcurrentLinkedQueue

简介

  ConcurrentLinkedQueue是一个线程安全的队列，它的特点是非阻塞，也就是说当队列为空时，出队操作不会阻塞线程，而是立即返回null。同时，它也不允许插入null元素。

  ConcurrentLinkedQueue是一个基于链接节点的无界线程安全队列。它采用了先进先出的原则，对于并发访问，它采取了一种无锁算法（lock-free），实现了高效率的并发操作。它通过CAS操作实现了“原子操作”，保证了线程安全。

源代码解析

  ConcurrentLinkedQueue的源代码中，最重要的是Node类和head、tail两个节点。每个节点代表队列中的一个元素，节点中除了存储元素外，还包含了指向下一个节点的指针。

private static class Node<E> {volatile E item;volatile Node<E> next;Node(E item) {UNSAFE.putObject(this, itemOffset, item);}boolean casItem(E cmp, E val) {return UNSAFE.compareAndSwapObject(this, itemOffset, cmp, val);}void lazySetNext(Node<E> val) {UNSAFE.putOrderedObject(this, nextOffset, val);}boolean casNext(Node<E> cmp, Node<E> val) {return UNSAFE.compareAndSwapObject(this, nextOffset, cmp, val);}private static final sun.misc.Unsafe UNSAFE;private static final long itemOffset;private static final long nextOffset;static {try {UNSAFE = sun.misc.Unsafe.getUnsafe();Class<?> k = Node.class;itemOffset = UNSAFE.objectFieldOffset(k.getDeclaredField("item"));nextOffset = UNSAFE.objectFieldOffset(k.getDeclaredField("next"));} catch (Exception e) {throw new Error(e);}}
}

  在队列中head和tail是两个Node节点，其中head代表队列中最先入队的元素，tail代表队列中最后入队的元素。head和tail节点中的next指针指向队列中的下一个元素，通过这样的方式将整个队列串起来，实现了队列的操作。

在这里插入图片描述

public class ConcurrentLinkedQueue<E> extends AbstractQueue<E>implements Queue<E>, java.io.Serializable {private transient volatile Node<E> head;private transient volatile Node<E> tail;public ConcurrentLinkedQueue() {head = tail = new Node<E>(null);}private void updateHead(Node<E> h, Node<E> p) {if (h != p && casHead(h, p))h.lazySetNext(h);}private void updateTail(Node<E> t, Node<E> p) {if (t != p && casTail(t, p))t.lazySetNext(p);}boolean casHead(Node<E> cmp, Node<E> val) {return UNSAFE.compareAndSwapObject(this, headOffset, cmp, val);}boolean casTail(Node<E> cmp, Node<E> val) {return UNSAFE.compareAndSwapObject(this, tailOffset, cmp, val);}private static final sun.misc.Unsafe UNSAFE;private static final long headOffset;private static final long tailOffset;static {try {UNSAFE = sun.misc.Unsafe.getUnsafe();Class<?> k = ConcurrentLinkedQueue.class;headOffset = UNSAFE.objectFieldOffset(k.getDeclaredField("head"));tailOffset = UNSAFE.objectFieldOffset(k.getDeclaredField("tail"));} catch (Exception e) {throw new Error(e);}}
}

应用场景案例

  ConcurrentLinkedQueue的应用场景很广泛，它可以作为多线程环境下的任务队列，也可以作为消息队列、日志队列等。下面以一个简单的任务队列为例进行说明。

public class TaskQueue {private ConcurrentLinkedQueue<Task> queue;public TaskQueue() {queue = new ConcurrentLinkedQueue<>();}public void addTask(Task task) {queue.offer(task);}public void executeTasks() {if (queue.isEmpty()) {return;}Task task = null;while ((task = queue.poll()) != null) {task.execute();}}
}

  在上述代码中，我们定义了一个TaskQueue类，它包含了一个ConcurrentLinkedQueue对象，用于存储任务。addTask()方法用于向队列中添加任务，executeTasks()方法用于执行队列中的任务。当队列为空时，直接返回。否则，使用poll()方法从队列中取出一个任务执行，直到队列中的任务全部被执行完成。

优缺点分析

优点

  • 高并发性：ConcurrentLinkedQueue的实现采用了无锁算法，相比于同步队列的加锁操作，它在高并发场景下的性能更优；
  • 无阻塞：当队列为空时，出队操作不会阻塞线程，而是立即返回null；
  • 线程安全：ConcurrentLinkedQueue是线程安全的，不需要我们手动进行同步。

缺点

  • 不支持随机访问：由于ConcurrentLinkedQueue是基于链表实现的，所以它不支持随机访问操作，只能从队头或队尾进行插入、删除和访问操作。如果应用场景中需要随机访问，建议使用其他数据结构；
  • 不支持元素排序：ConcurrentLinkedQueue是一个队列，它不支持对元素进行排序。如果应用场景中需要对元素排序，建议使用其他数据结构。

类代码方法介绍

offer(E e)

  插入指定元素作为此队列的末尾（最后一个元素）。如果队列为空，则插入位于队头（第一个元素）。

public boolean offer(E e) {checkNotNull(e);final Node<E> newNode = new Node<E>(e);for (Node<E> t = tail, p = t;;) {Node<E> q = p.next;if (q == null) {if (p.casNext(null, newNode)) {if (p != t)casTail(t, newNode);  // Failure is OK.return true;}} else if (p == q)p = (t != (t = tail)) ? t : head;elsep = (p != t && t != (t = tail)) ? t : q;}
}

poll()

获取并移除此队列的头。

public E poll() {restartFromHead:for (;;) {for (Node<E> h = head, p = h, q;;) {E item = p.item;if (item != null && p.casItem(item, null)) {if (p != h) // Hop two nodes at a timeupdateHead(h, ((q = p.next) != null) ? q : p);return item;}else if ((q = p.next) == null) {updateHead(h, p);return null;}else if (p == q)continue restartFromHead;elsep = q;}}
}

size()

返回队列中的元素数量。

public int size() {int count = 0;for (Node<E> p = first(); p != null; p = succ(p))if (p.item != null)++count;return count;
}

isEmpty()

判断队列是否为空。

public boolean isEmpty() {return first() == null;
}

contains(Object o)

判断队列中是否包含指定元素。

public boolean contains(Object o) {if (o == null) return false;for (Node<E> p = first(); p != null; p = succ(p)) {E item = p.item;if (item != null && o.equals(item))return true;}return false;
}

add(E e)

插入指定元素作为此队列的末尾。与offer()方法相同。

public boolean add(E e) {return offer(e);
}

remove()

获取并移除此队列的头。与poll()方法相同。

public E remove() {E x = poll();if (x != null)return x;elsethrow new NoSuchElementException();
}

element()

获取但不移除此队列的头。与peek()方法相同。

public E element() {E x = peek();if (x != null)return x;elsethrow new NoSuchElementException();
}

测试用例

  我们可以编写如下测试用例来验证ConcurrentLinkedQueue的正确性。

测试代码

  下面是一个简单的示例代码，使用了ConcurrentLinkedQueue创建了一个线程安全的队列，并对其进行了读写测试：

package com.example.javase.collection;import java.util.concurrent.ConcurrentLinkedQueue;/*** @Author ms* @Date 2023-10-22 18:57*/
public class ConcurrentLinkedQueueTest {public static void main(String[] args) {ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<>();// 添加元素queue.offer("Java");queue.offer("Python");queue.offer("C++");// 输出队列元素System.out.println("Queue elements: " + queue);// 获取并移除队列头部元素String headElement = queue.poll();System.out.println("Head element: " + headElement);// 输出队列元素System.out.println("Queue elements after polling: " + queue);// 获取队列头部元素String peekElement = queue.peek();System.out.println("Peek element: " + peekElement);// 输出队列元素System.out.println("Queue elements after peeking: " + queue);}
}

期望输出结果如下：

Queue elements: [Java, Python, C++]
Head element: Java
Queue elements after polling: [Python, C++]
Peek element: Python
Queue elements after peeking: [Python, C++]

  接下来我们可以在本地执行一下这个测试用例，以作为检验是否能够将其预期结果正确输出。

测试结果

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

在这里插入图片描述
如上测试用例执行后，经肉眼验证与预期结果是一致！

测试代码分析

  根据如上测试用例，在此我给大家进行深入详细的解读一下测试代码，以便于更多的同学能够理解并加深印象。
  如上代码是一个使用ConcurrentLinkedQueue实现的队列的示例代码。ConcurrentLinkedQueue是一个线程安全的无界队列，它采用了无锁算法来实现高效的并发操作。在该示例中，首先创建了一个ConcurrentLinkedQueue对象，并通过调用offer()方法向队列中添加了3个元素。然后，分别演示了poll()方法和peek()方法的使用，它们分别用于获取并移除队列头部元素和获取队列头部元素，最终输出了操作后的队列元素。

小结

  ConcurrentLinkedQueue是一个线程安全的队列，它采用了先进先出的原则，对于并发访问，它采取了一种无锁算法（lock-free），实现了高效率的并发操作。它通过CAS操作实现了“原子操作”，保证了线程安全。

  ConcurrentLinkedQueue的应用场景很广泛，它可以作为多线程环境下的任务队列，也可以作为消息队列、日志队列等。

总结

  1. ConcurrentLinkedQueue是一个基于链接节点的无界线程安全队列；
  2. 支持先进先出原则，采用无锁算法实现高效的并发操作；
  3. 不支持随机访问和元素排序；
  4. 适用于多线程环境下的任务队列、消息队列等；
  5. 具有高并发性、无阻塞、线程安全等优点。

… …

文末

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

… …

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

wished for you successed ！！！

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

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

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

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

CentOS使用Docker搭建Nacos结合内网穿透实现无公网IP远程登录本地管理平台

CentOS使用Docker搭建Nacos结合内网穿透实现无公网IP远程登录本地管理平台

文章目录 1. Docker 运行Nacos2. 本地访问Nacos3. Linux安装Cpolar4. 配置Nacos UI界面公网地址5. 远程访问 Nacos UI界面6. 固定Nacos UI界面公网地址7. 固定地址访问Nacos Nacos是阿里开放的一款中间件,也是一款服务注册中心&#xff0c;它主要提供三种功能&#xff1a;持久化…
阅读更多...
网站服务器备案及域名购买配置教程

网站服务器备案及域名购买配置教程

一、阿里云服务备案准备工作 1.什么是备案？ 备案是指向相关部门提交网站信息，以便监管和管理互联网信息服务，未经备案的网站可能面临罚款甚至被关闭的风险。备案主要看您的网站或App等互联网信息服务解析到的服务器是否在中国内地（大陆），如果服务器在中国内地（大陆），…
阅读更多...
探索Python中的文件操作：如何列出一个目录下的所有文件？

探索Python中的文件操作：如何列出一个目录下的所有文件？

在Python中&#xff0c;处理文件和目录是一项常见的任务。无论是在数据科学项目中读取数据集&#xff0c;还是在Web开发中管理用户上传的文件&#xff0c;我们都需要知道如何列出一个目录下的所有文件。本文将通过通俗易懂的语言&#xff0c;为初学者详细讲解如何在Python中实现…
阅读更多...
Tkinter组件：Text-显示和处理多行文本

Tkinter组件：Text-显示和处理多行文本

Tkinter组件&#xff1a;Text Text&#xff08;文本&#xff09;组件用于显示和处理多行文本。在 Tkinter 的所有组件中&#xff0c;Text 组件显得异常强大和灵活&#xff0c;适用于多种任务。虽然该组件的主要目的是显示多行文本&#xff0c;但它常常也被用于作为简单的文本编…
阅读更多...
kali更新镜像源

kali更新镜像源

1. 什么是镜像源 镜像源一种数据存储和分发技术&#xff0c;通常指的是一个服务器或网站&#xff0c;它存储了另一个服务器或网站上的某些或全部内容的副本。 2. kali更新镜像源 1. 编辑镜像源文件 vi /etc/apt/sources.list 2. 将原来的镜像源用#号注释掉 3. 选择镜像源地址…
阅读更多...
LLM应用-文档解析 AI大模型总结分析文档

LLM应用-文档解析 AI大模型总结分析文档

1&#xff09;https://notegpt.io/pdf-summary 支持总结&#xff0c;思维导图、对话 2&#xff09;chatdoc https://chatdoc.com/ 3&#xff09;chatpdf https://www.chatpdf.com/ https://www.chatpdfs.cn/ 4&#xff09;kimi https://kimi.moonshot.cn/
阅读更多...
HTML静态网页成品作业(HTML+CSS+JS)——华为商城网页(1个页面)

HTML静态网页成品作业(HTML+CSS+JS)——华为商城网页(1个页面)

&#x1f389;不定期分享源码&#xff0c;关注不丢失哦 文章目录 一、作品介绍二、作品演示三、代码目录四、网站代码HTML部分代码 五、源码获取 一、作品介绍 &#x1f3f7;️本套采用HTMLCSS&#xff0c;使用Javacsript代码实现首页图片切换轮播效果&#xff0c;共有1个页面…
阅读更多...
Cweek1

Cweek1

C语言学习 一.初识C语言 1.如何写C代码 ①创建工程 ②添加源文件&#xff1a;c文件&#xff1a;源文件&#xff0c;h文件&#xff1a;头文件 代码实例&#xff1a; main函数是程序的入口&#xff0c;有且仅有一个 在C语言中&#xff0c;#include <stdio.h> 是一个预…
阅读更多...
嵌入式学习-时钟树

嵌入式学习-时钟树

时钟树 时钟分类 时钟树框图 LSI与LSE HSI、HSE与PLL 系统时钟的产生 AHB、APBx的时钟配置 相关寄存器 寄存器部分的细节内容请参考手册。 相关库函数
阅读更多...
PyQt5中Text Edit的常用方法和常用信号

PyQt5中Text Edit的常用方法和常用信号

文章目录 1. 简介1.1. 常用方法&#xff1a;1.2 常用信号&#xff1a; 2. Text Edit的常用方法使用案例3. Text Edit 的常用信号使用案例 1. 简介 QTextEdit是PyQt中用于显示和编辑文本的强大组件之一。它提供了丰富的功能&#xff0c;可以显示普通文本、富文本和HTML文本&…
阅读更多...
e行64位V11.17.4 安卓全局虚拟定位APP

e行64位V11.17.4 安卓全局虚拟定位APP

e行最新版11.17.4 支持全局虚拟位置 小米手机 百度地图 高德地图 实测成功 其他app自测 不一定支持所有app 下载&#xff1a;https://www.123pan.com/s/HAf9-tsyCh.html
阅读更多...
java多线程 线程交替执行（同步）的各种实现方案

java多线程 线程交替执行（同步）的各种实现方案

目录 java多线程 线程交替执行&#xff08;同步&#xff09;的各种实现方案需求 指定具体执行顺序实现一&#xff1a;wait_notify机制 Thread标志位实现二&#xff1a;lock_condition机制 Thread标志位实现三&#xff1a;semaphore信号量 不指定具体执行顺序&#xff0c;只交…
阅读更多...
Electron + GitHub Actions | 自动化流程详解(下)

Electron + GitHub Actions | 自动化流程详解(下)

自动化部署 上篇介绍了 Electron Forge 打包应用教程。在实际开发中&#xff0c;自动化是提升效率和产出质量的关键。本篇我们将详细介绍如何将构建和发布 Electron 应用的过程自动化。 代码挂在 GitHub 仓库上&#xff0c;如果有帮助&#xff0c;记得给仓库点个赞&#xff1a…
阅读更多...
MQTT学习（一）

MQTT学习（一）

MQTT是一种与HTTP类似的应用层协议。 在某些物联网应用中&#xff0c;MQTT优于HTTP。 首先&#xff0c;HTTP是用于客户端服务器计算的以文档为中心的请求-响应协议。 HTTP是万维网的基础&#xff0c;但它不是专门为机器之间通信而设计的。 MQTT是一种机器对机器、以数据为中…
阅读更多...
Python pyqtgraph库：高效可视化数据的利器

Python pyqtgraph库：高效可视化数据的利器

更多Python学习内容&#xff1a;ipengtao.com 在数据科学和工程领域&#xff0c;数据可视化是一项非常重要的任务。Python pyqtgraph库是一个功能强大的数据可视化工具&#xff0c;可以帮助用户快速、高效地可视化各种类型的数据&#xff0c;包括实时数据、大数据集和3D数据等。…
阅读更多...
英伟达解码性能NVDEC

英伟达解码性能NVDEC

如果你能打开官网&#xff0c;请看这里&#xff1a; NVDEC Application Note 下面是摘录&#xff1a;
阅读更多...
STL---排序模板参数

STL---排序模板参数

map 对map进行排序 首先一定要注意map模板类的第三个模板参数&#xff0c;这个参数决定元素按键值升序或者降序在map中的存储方式&#xff1a; 默认&#xff1a;less<key>升序----- < -----第一个小于取第一个 可设置&#xff1a;greater<key>降序-------…
阅读更多...
VC 编程开发中的 封装类 ：log日志类 和SQL server 操作类 源代码

VC 编程开发中的 封装类 ：log日志类 和SQL server 操作类 源代码

VC 编程开发中的 封装类 &#xff1a;日志类 和SQL server 操作类 源代码 在VC&#xff08;Visual C&#xff09;开发中&#xff0c;日志文件输出是一个至关重要的环节&#xff0c;它对于程序调试、问题排查以及系统监控等方面都具有不可替代的作用。以下是对日志文件输出在VC开…
阅读更多...
ASP.NET仪器设备管理系统设计与实现

ASP.NET仪器设备管理系统设计与实现

摘 要 文中以某中小型企业的设备管理为例&#xff0c;对设备管理系统的设计与应用进行研究&#xff0c;旨在通过设备管理系统提高内部设备的利用率及实现其最大的经济效益。文中首先对设备管理的现状及其重要性进行了分析&#xff0c;分析实现设备管理信息系统的必要性与可行…
阅读更多...
如何在windows server下安装mysql5.7数据库，并使用Navicat Premium 15可视化工具新建数据库并读取数据库信息。

如何在windows server下安装mysql5.7数据库，并使用Navicat Premium 15可视化工具新建数据库并读取数据库信息。

如何在windows server下安装mysql5.7数据库&#xff1f; MySQL :: Download MySQL Community Server (Archived Versions)https://downloads.mysql.com/archives/community/点击↑&#xff0c;然后选择对应版本和平台↓下载 将下载后的安装包放入固定目录&#xff08;这里以D:…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023