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

2024-05-13 22:52

本文主要是介绍深入浅出: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 !!!


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

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

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

这篇关于深入浅出:ConcurrentLinkedQueue源码分析与实战的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/987046

相关文章

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库,完全使用 Python 语言编写,它对 XPath表达式提供了良好的支 持,因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块,该模块专门用来解析 HTML/XML 文档,下面来介绍一下 lxml 库

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题,本文将一起从代码层去分析为什么没有建立索引? 开源ERP项目地址:https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

Java ArrayList扩容机制 (源码解读)

结论:初始长度为10,若所需长度小于1.5倍原长度,则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1:数组默认长度         2:这是一个共享的空数组实例,用于明确创建长度为0时的ArrayList ,比如通过 new ArrayList<>(0),ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL

如何在Visual Studio中调试.NET源码

今天偶然在看别人代码时,发现在他的代码里使用了Any判断List<T>是否为空。 我一般的做法是先判断是否为null,再判断Count。 看了一下Count的源码如下: 1 [__DynamicallyInvokable]2 public int Count3 {4 [__DynamicallyInvokable]5 get

滚雪球学Java(87):Java事务处理:JDBC的ACID属性与实战技巧!真有两下子!

咦咦咦,各位小可爱,我是你们的好伙伴——bug菌,今天又来给大家普及Java SE啦,别躲起来啊,听我讲干货还不快点赞,赞多了我就有动力讲得更嗨啦!所以呀,养成先点赞后阅读的好习惯,别被干货淹没了哦~ 🏆本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,助你一臂之力,带你早日登顶🚀,欢迎大家关注&&收藏!持续更新中,up!up!up!! 环境说明:Windows 10

SWAP作物生长模型安装教程、数据制备、敏感性分析、气候变化影响、R模型敏感性分析与贝叶斯优化、Fortran源代码分析、气候数据降尺度与变化影响分析

查看原文>>>全流程SWAP农业模型数据制备、敏感性分析及气候变化影响实践技术应用 SWAP模型是由荷兰瓦赫宁根大学开发的先进农作物模型,它综合考虑了土壤-水分-大气以及植被间的相互作用;是一种描述作物生长过程的一种机理性作物生长模型。它不但运用Richard方程,使其能够精确的模拟土壤中水分的运动,而且耦合了WOFOST作物模型使作物的生长描述更为科学。 本文让更多的科研人员和农业工作者

MOLE 2.5 分析分子通道和孔隙

软件介绍 生物大分子通道和孔隙在生物学中发挥着重要作用,例如在分子识别和酶底物特异性方面。 我们介绍了一种名为 MOLE 2.5 的高级软件工具,该工具旨在分析分子通道和孔隙。 与其他可用软件工具的基准测试表明,MOLE 2.5 相比更快、更强大、功能更丰富。作为一项新功能,MOLE 2.5 可以估算已识别通道的物理化学性质。 软件下载 https://pan.quark.cn/s/57

工厂ERP管理系统实现源码(JAVA)

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本,并实时掌握各环节的运营状况。 在采购管理方面,系统能够处理采购订单、供应商管理和采购入库等流程,确保采购过程的透明和高效。仓库管理方面,实现库存的精准管理,包括入库、出库、盘点等操作,确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、