目录
java.util.concurrent.ConcurrentLinkedQueue是基于FIFO的单向链表的无界线程安全队列。添加元素到队列尾部;获取返回队列头部的元素。
线程安全一般采用两种方式:阻塞和非阻塞。阻塞算法的队列可以用一个锁(入队和出队用同一把锁)或两个锁(入队和出队用不同的锁)等方式来实现。非阻塞算法的队列可以使用循环CAS的方式。ConcurrentLinkedQueue采用了非阻塞方式实现。
如下图所示。ConcurrentLinkedQueue由首节点Node<E> head、尾节点Node<E> tail组成,都用volatile修饰。而Node则由元素E item、下一节点Node<E> next组成,都用volatile修饰。
ConcurrentLinkedQueue是由Node的next关联起来形成链表结构的队列。默认head节点元素为null,而tail等于head,即:head = tail = new Node<E>(null)。
入队列就是将元素添加到队列的尾部。如上图所示,是元素入队过程:
发现入队主要做两件事情:第一是将入队节点设置成当前队列尾节点的next节点;第二是更新tail节点。当前队列尾节点不一样是tail节点,即:tail节点不总是尾节点,详见下《设置tail节点》。
tail节点不总是队列的尾节点,减少自旋CAS设置尾节点来提高入队效率。
注意:入队永远返回true,原因是通过自旋CAS操作完成,所以不要通过返回值判定入队是否成功。
/**
* 添加元素
*/
public boolean add(E e) {
return offer(e);
}
// 入队到链表尾
public boolean offer(E e) {
// 元素不能为null
checkNotNull(e);
// 元素构建成Node
final Node<E> newNode = new Node<E>(e);
// 自旋方式,添加到队列尾部
for (Node<E> t = tail, p = t;;) {
Node<E> q = p.next;
// tail的next为null,说明到链表尾部了(tail指向最后一个元素),就入队
if (q == null) {
// CAS更新入队节点设置为tail的next,若不成功就自旋
if (p.casNext(null, newNode)) {
// 如果p不等于t,说明其它线程更新tail, 也就不会走到q==null这个分支了,p取到的可能是t后面的值
if (p != t) // hop two nodes at a time
casTail(t, newNode); // Failure is OK.
return true; // 入队成功
}
}
// 如果p的next等于p,说明p已经被删除了(已经出队了),重新设置p的值
else if (p == q)
p = (t != (t = tail)) ? t : head;
// t后面还有值,重新设置p的值
else
p = (p != t && t != (t = tail)) ? t : q;
}
}
出队列就是从队列里返回一个元素。如上图所示,是元素出队过程。主要做两件事情:第一是队列移除出队元素的Node,第二是更新head节点。注意:并不是每次出队都更新head节点,详见下节《更新head节点》
并不是每次出队都更新head节点,原因是减少CAS更新来提高出队效率。
/**
* 弹出元素
*/
public E poll() {
restartFromHead:
for (;;) {
for (Node<E> h = head, p = h, q;;) {
// head的元素
E item = p.item;
// head不为null,直接弹出head
if (item != null && p.casItem(item, null)) {
// 其他线程设置head,导致head变化,则重新更新head
if (p != h) // hop two nodes at a time
updateHead(h, ((q = p.next) != null) ? q : p);
return item;
}
// head为null,弹出head的next节点并更新head
else if ((q = p.next) == null) {
updateHead(h, p);
return null;
}
// 如果p等于p,说明p已经出队了,重试
else if (p == q)
continue restartFromHead;
else
p = q;
}
}
}
// CAS更新head
final void updateHead(Node<E> h, Node<E> p) {
if (h != p && casHead(h, p))
h.lazySetNext(h);
}
@Test
public void concurrentLinkedQueueTest(){
ConcurrentLinkedQueue<Integer> concurrentLinkedQueue = new ConcurrentLinkedQueue<>();
// 添加元素
for (int i = 0; i < 10; i++) {
concurrentLinkedQueue.add(i);
}
Object[] array = concurrentLinkedQueue.toArray();
for (int i = 0; i < array.length; i++) {
// 具有顺序性
System.out.println(array[i]);
}
}
深入ConcurrentLinkedQueue底层原理与源码解析 - 知乎
Java并发编程-并发队列(ConcurrentLinkedQueue)的原理分析_记忆力不好的博客-程序员宅基地_concurrentqueue 原理
文章浏览阅读1w次,点赞12次,收藏95次。我们在实现各种电路中,肯定会使用到开关这种器件。开关可以是按键,可以是矩阵键盘。但是如果我们用的是语音模块作为开关,可以让自己的产品显得更加高逼格。本博客用于记录本人准备省电子设计大赛过程中使用的SU-03T的语音模块,使用智能公元的开发网页,博客持续更新,小白向。用你的搜索引擎搜索智能公元:智能公元/AIOT快速产品化平台 (smartpi.cn)登录注册什么的在此不详细介绍。A.点击创建产品:B.随便选择一个产品比如什么什么灯具:C.选择纯离线方案,以及SU-03T模组:D.完成各种配置,点击确定,并生_su-03t
文章浏览阅读2.8k次,点赞2次,收藏7次。出错后退出在默认情况下,当一个测试用例中的某个关键字返回错误时,这个测试用例就停止执行剩余的关键字。RF会继续执行下一个用例。这么做的好处是节省时间--反正这里出问题要返回来看了,再继续执行剩下的关键字也没有用了。出错后继续执行 但是,有时候,我们却需要执行用例中的所有关键字,例如:要获取更多的出错信息、更改某些全局相关的变量、做teardown或者rollback操作等。这时候,我们...
文章浏览阅读4.7k次,点赞3次,收藏11次。JVM实战学习——排查java程序 磁盘IO占用过高、CPU占用过高、内存占用过高(pidstat)一、排查cpu高占用1.示例代码使用以下代码,启动的服务会产生cpu资源大量占用的情况1)占有大量CPU资源2)启动类2.查询项目进程1)使用 jps 命令查询项目启动的进程[root]# jps15539 jar ## 其中15539就是项目进程1349 -- process information unavailable15673 Jps2)或者使用 ps -ef |_pidstat查看哪个线程io高
文章浏览阅读1.8w次,点赞88次,收藏103次。整理 | 屠敏出品 | CSDN(ID:CSDNnews)在 2020 年初雪来临之际,TIOBE 官方在最新发布的 1 月编程语言榜单中为我们最终揭开了「 2019 年度编程语言」的神秘面纱,然意料之外情理之中,获此殊荣的并非是风风火火吵闹了一年又一年的 Python,而是一位低调的老兵——C 语言。Python 惜败,C成为 2019 年度编程语言曾几何时,凭借着“人生..._编程语言排行榜tiobe
文章浏览阅读1.1w次,点赞11次,收藏59次。Queue是RocketMQ中的另一个重要概念。在对该概念进行分析介绍前,我们先来看一张图:从本质上来说,RocketMQ中的Queue是数据分片的产物。为了更好地理解Queue的定义,我们还需要引入一个新的概念:Topic分片。在分布式数据库和分布式缓存领域,分片概念已经有了清晰的定义。同理,对于RocketMQ,一个Topic可以分布在各个Broker上,我们可以把一个Topic分布在一个Broker上的子集定义为一个Topic分片。对应上图,TopicA有3个Topic分片,分布在Broker
文章浏览阅读1.1w次。target ios版本和第三方库ios版本问题问题描述解决方法查看iphone iPad target的最低ios版本修改pod里第三方库问题描述这几天编辑xcode偶尔会发现这个错误,但是有时候重新编译一下错误就消失了,今天彻底解决一下这个错误错误提示:Compiling for iOS 10.0, but module ‘SwiftyJSON’ has a minimum deployment target of iOS 12.0: /Users/tdw/Library/Developer/Xc_compiling for ios 9.0, but module 'reactiveswift' has a minimum deployment t
文章浏览阅读1.4k次。agent学习的过程中,常常无法及时获得回报。就像家长让小朋友写作业,小朋友可能觉得这个是负面的反馈而不去写作业(做作业让我觉得很痛苦qwq),而没有意识到以后会获得的巨大回报:写完作业后成绩提高,考上好大学,成为高富帅,从此走向巅峰赢取白富美...这个一开始的暂时的小的reward 就叫 Sparse Reward如何让agent在Sparse Reward 中拥有更好的学习表现?..._spare reward
文章浏览阅读9.5k次,点赞6次,收藏29次。Centos7设置分辨率_centos7调整屏幕分辨率
文章浏览阅读2.8k次。地址无关代码,在64位下编译动态库的时候,经常会遇到下面的错误/usr/bin/ld: /tmp/ccQ1dkqh.o: relocation R_X86_64_32 against `a local symbol' can not be used when making a shared object; recompile with -fPIC提示说需要-fPIC编译,然后在链接_symbol `g_hall_mode' can not be used when making a shared object; recompile
文章浏览阅读39次。当服务实例很多时,都从配置中心读取文件,这时可以考虑将配置中心做成一个微服务,将其集群化,从而达到高可用,架构图如下:准备工作继续使用上一篇文章的工程,创建一个eureka-server工程,用作服务注册中心。在其pom.xml文件引入Eureka的起步依赖spring-cloud-starter-netflix- eureka-server,代码如下:<?xml version=...
文章浏览阅读3.5k次,点赞7次,收藏21次。对于c语言中"->"和"."的区别总结如下:1、A.B则A为对象或者结构体;2、A->B则A为指针,->是成员提取,A->B是提取A中的成员B,A只能是指向类、结构、联合的指针;3、(*a).b 等价于 a->b。"."一般情况下读作"的”; “->”一般读作"指向的结构体的"。也就是说在结构中,运算符->是运算符*和运算符.的结合4、“->”是指向..._->和.
文章浏览阅读2.1w次,点赞27次,收藏218次。ubuntu20.04安装ROS2_ubuntu20.04安装ros2