死磕 java集合之ConcurrentLinkedQueue源码分析

       ConcurrentLinkedQueue

       （1）不是阻塞队列

       （2）通过CAS+自旋保证并发安全

       （3）可用于多线程环境，但不能用在线程池中

       简介

       主要属性

       两个属性：头节点与尾节点

       主要内部类

       典型单链表结构

       主要构造方法

       构造简单，实现无界单链表队列

       入队

       add(e)与offer(e)方法

       无异常抛出，流程清晰

       出队

       remove()与poll()方法

       逻辑清晰，网页版社交源码不阻塞线程

       总结

       非阻塞队列，不适用于线程池

       彩蛋

       与LinkedBlockingQueue对比

       线程安全与返回null特性相似

       效率与锁机制差异显著

       无法实现等待元素与用在线程池中的限制

ConcurrentHashMap确实很复杂，这样学源码才简单

       ConcurrentHashMap相较于HashMap在实现上更为复杂，主要涉及多线程环境下的并发安全、同步和锁的概念。虽然HashMap的原理主要围绕数组、链表、哈希碰撞和扩容，但在多线程场景下，这些知识还不够，需要对并发和同步有深入理解。

       在实际编程中，HashMap经常被使用，而ConcurrentHashMap的使用频率却相对较低，这使得学习它的门槛变高。学习ConcurrentHashMap之前，关键在于理解HashMap的基本实现，特别是它在非线程安全情况下的操作，如数组初始化和putVal()方法。

       HashMap的线程不安全问题主要表现在数组的懒加载和带if判断的put操作上，这可能导致数据一致性问题。为了解决这些问题，像HashTable和Collections.synchronizedMap()通过synchronized关键字加锁，但会导致性能下降。ConcurrentHashMap引入了CAS（Compare And Swap）技术，比如在initTable()方法中，通过volatile修饰的直播间弹幕源码在哪成员变量保证了数组初始化的线程安全。

       ConcurrentHashMap在数组初始化、下标为空时使用CAS，而在有冲突时切换到synchronized，降低了锁的粒度，以提高效率。扩容是ConcurrentHashMap的难点，需要处理新旧数组的同步迁移问题，通过helpTransfer()方法和transfer()方法来确保线程安全。

       总结来说，学习ConcurrentHashMap不仅是对HashMap知识的扩展，更是进入并发编程世界的重要一步。面试时，如果只问基本数据结构，那可能只需要了解HashMap；但若深入到ConcurrentHashMap，就涉及到了并发编程的核心技术，如CAS、同步和锁的管理。

从HotSpot源码，深度解读 park 和 unpark

       我最近建立了一个在线自习室（App：番茄ToDO）用于相互监督学习，感兴趣的小伙伴可以加入。自习室加入码：D5A7A

       Java并发包下的类大多基于AQS（AbstractQueuedSynchronizer）框架实现，而AQS线程安全的实现依赖于两个关键类：Unsafe和LockSupport。

       其中，Unsafe主要提供CAS操作（关于CAS，在文章《读懂AtomicInteger源码（多线程专题）》中讲解过），LockSupport主要提供park/unpark操作。实际上，park/unpark操作的最终调用还是基于Unsafe类，因此Unsafe类才是核心。

       Unsafe类的实现是由native关键字说明的，这意味着这个方法是原生函数，是客服系统网页源码编写用C/C++语言实现的，并被编译成了DLL，由Java去调用。

       park函数的作用是将当前调用线程阻塞，而unpark函数则是唤醒指定线程。

       park是等待一个许可，unpark是为某线程提供一个许可。如果线程A调用park，除非另一个线程调用unpark(A)给A一个许可，否则线程A将阻塞在park操作上。每次调用一次park，需要有一个unpark来解锁。

       并且，unpark可以先于park调用，但不管unpark先调用多少次，都只提供一个许可，不可叠加。只需要一次park来消费掉unpark带来的许可，再次调用会阻塞。

       在Linux系统下，park和unpark是通过Posix线程库pthread中的mutex（互斥量）和condition（条件变量）来实现的。

       简单来说，mutex和condition保护了一个叫_counter的信号量。当park时，这个变量被设置为0，当unpark时，这个变量被设置为1。当_counter=0时线程阻塞，当_counter>0时直接设为0并返回。

       每个Java线程都有一个Parker实例，Parker类的部分源码如下：

       由源码可知，Parker类继承于PlatformParker，实际上是andlua悬浮球源码下载用Posix的mutex和condition来实现的。Parker类里的_counter字段，就是用来记录park和unpark是否需要阻塞的标识。

       具体的执行逻辑已经用注释标记在代码中，简要来说，就是检查_counter是不是大于0，如果是，则把_counter设置为0，返回。如果等于零，继续执行，阻塞等待。

       unpark直接设置_counter为1，再unlock mutex返回。如果_counter之前的值是0，则还要调用pthread_cond_signal唤醒在park中等待的线程。源码如下：

       （如果不会下载JVM源码可以后台回复“jdk”，获得下载压缩包）

java并发原子类AtomicBoolean解析

       本文针对Java并发包下的原子类AtomicBoolean进行深入解析。在多线程环境中，传统的布尔变量`boolean`并非线程安全，容易导致数据竞争问题。为解决这一问题，引入了AtomicBoolean类，该类提供了一种线程安全的布尔值封装。

       使用`AtomicBoolean`的主要原因在于其提供的原子操作保证了多线程环境下的线程安全。在`AtomicBoolean`内部实现中，主要依赖于`compareAndSet`方法和CAS（Compare and Swap）机制。通过CAS操作，`AtomicBoolean`能够在多线程环境下实现原子的更新操作，有效避免了数据竞争和并发问题。

       在`AtomicBoolean`的源码中，`compareAndSet`方法使用了`Unsafe`类的`compareAndSwapInt`方法进行底层操作。CAS机制的渲染平台源码怎么找到核心思想是：在不进行锁操作的情况下，检查指定内存位置的预期值是否与当前值相等，若相等，则更新该位置的值为预期值；若不相等，则操作失败，返回原值。

       为了理解这一机制，我们可以通过一个简单例子进行说明。假设我们希望在多线程环境下实现一个“先来后到”的规则，例如：一个人完成起床、上班和下班三件事后，另一个人才能开始。在单线程下，这一逻辑自然无问题，但在多线程环境下，`AtomicBoolean`可以确保这一顺序得到实现。

       在实际应用中，`AtomicBoolean`类提供了丰富的原子操作方法，包括但不限于`compareAndSet`、`getAndSet`、`compareAndExchange`等。这些方法允许开发人员在多线程环境下安全地执行原子操作，简化了多线程编程的复杂性。

       总结而言，`AtomicBoolean`是一个在Java并发编程中非常实用的工具类，它通过原子操作保证了多线程环境下的线程安全。对于开发者而言，掌握`AtomicBoolean`的使用方法和原理，可以有效避免数据竞争问题，提升程序的并发性能和稳定性。

这属于什么类型的文件？

       -- 常用文件扩展名解释

       A 对象代码库文件

       AAM Authorware shocked文件

       AAS Authorware shocked包

       ABF Adobe二进制屏幕字体

       ABK CorelDRAW自动备份文件

       ABS 该类文件有时用于指示一个摘要（就像在一篇有关科学方面的文章的一个摘要或概要，取自abstract）

       ACE Ace压缩档案格式

       ACL CorelDRAW 6键盘快捷键文件

       ACM Windows系统目录文件

       ACP Microsoft office助手预览文件

       ACR 美国放射医学大学文件格式

       ACT Microsoft office助手文件

       ACV OS/2的驱动程序，用于压缩或解压缩音频数据

       AD After Dark屏幕保护程序

       ADA Ada源文件（非-GNAT）

       ADB Ada源文件主体（GNAT）；HPLX组织者的约定数据库

       ADD OS/2用于引导过程的适配器驱动程序

       ADF Amiga磁盘文件

       ADI AutoCAD设备无关二进制绘图仪格式

       ADM After Dark多模块屏幕保护；Windows NT策略模板

       ADP FaxWork用于传真调制解调器的交互安装文件；Astound Dynamite文件

       ADR After Dark随机屏幕保护；Smart Address的地址簿

       ADS Ada源文件说明书（GNAT）

       AFM Adobe的字体尺度

       AF2，AF3 ABC的FlowChat文件

       AI Adobe Illustrator格式图形

       AIF，AIFF 音频互交换文件，Silicon Graphic and Macintosh应用程序的声音格式

       AIFC 压缩AIF

       AIM AOL即时信息传送

       AIS ACDSee图形序列文件；Velvet Studio设备文件

       AKW RoboHELP的帮助工程中所有A-关键词

       ALAW 欧洲电话音频格式

       ALB JASC Image Commander相册

       ALL 艺术与书信库

       AMS Velvet Studio音乐模块（MOD）文件；Extreme的Tracker模块文件

       ANC Canon Computer的调色板文件，包含一系列可选的颜色板

       ANI Windows系统中的动画光标

       ANS ANSI文本文件

       ANT SimAnt For Windows中保存的游戏文件

       API Adobe Acrobat使用的应用程序设计接口文件

       APR Lotus Approach 文件

       APS Microsoft Visual C++文件

       ARC LH ARC的压缩档案文件

       ARI Aristotle声音文件

       ARJ Robert Jung ARJ压缩包文件

       ART Xara Studio绘画文件；Canon Crayola美术文件；Clip Art文件格式；另一种光线跟踪格式；AOL使用的用Johnson―Grace压缩算法压缩的标记文件

       ASA Microsoft Visual InterDev文件

       ASC ASCⅡ文本文件；PGP算法加密文件

       ASD Microsoft Word的自动保存文件；Microsoft高级流媒体格式（microsoft advanced streaming FORMat，ASF）的描述文件；可用NSREX打开 Velvet Studio例子文件

       ASE Velvet Studio采样文件

       ASF Microsoft高级流媒体格式文件

       ASM 汇编语言源文件，Pro/E装配文件

       ASO Astound Dynamite对象文件

       ASP 动态网页文件；ProComm Plus安装与连接脚本文件；Astound介绍文件

       AST Astound多媒体文件；ClarisWorks“助手”文件

       ASV DataCAD自动保存文件

       ASX Cheyenne备份脚本文件；Microsoft高级流媒体重定向器文件，视频文件

       ATT AT< Group 4位图文件

       ATW 来自个人软件的Any Time Deluxe For Windows个人信息管理员文件

       AU Sun/NeXT/DEC/UNIX声音文件；音频U-Law（读作“mu-law”）文件格式

       AVB Computer Associates Inoculan反病毒软件的病毒感染后文件

       AVI Microsoft Audio Video Interleave**格式

       AVR Audio Visual Research文件格式

       AVS 应用程序可视化格式

       AWD FaxVien文档

       AWR Telsis数字储存音频文件扩展名格式

       Axx ARJ压缩文件的分包序号文件，用于将一个大文件压至几个小的压缩包中（xx取-的数字）

       A3L Authorware 3.x库文件

       A4L Authorware 4.x库文件

       A5L Authorware 5.x库文件

       A3M，A4M Authorware Macintosh未打包文件

       A4P Authorware无运行时间的打包文件

       A3W，A4W，A5W 未打包的Authorware Windows文件

       BAK 备份文件

       BAS BASIC源文件

       BAT 批处理文件

       BDF West Point Bridger Designer文件

       BFC Windows Briefcase文档

       BG Backgammon For Windows下的游戏文件

       BGL Microsoft Flight Simulator（微软飞行模拟器）的视景文件

       BI 二进制文件

       BIF Group Wise的初始化文件

       BIFF XLIFE 3D格式文件

       BIN 二进制文件

       BK，BK$ 有时用于代表备份版本

       BKS IBM BookManager Read书架文件

       BMK 书签文件

       BMP Windows或OS/2位图文件

       BMI Apogee BioMenace数据文件

       BOOK Adobe FrameMaker Book文件

       BOX Lotus Notes的邮箱文件

       BPL Borlard Delph 4打包库

       BQY BrioQuery文件

       BRX 用于查看多媒体对象目录的文件

       BSC MS Developer Studio浏览器信息文件

       BSP Quake图形文件

       BS1 Apogee Blake Stone数据文件

       BS_ Microsoft Bookshelf Find菜单外壳扩展名

       BTM Norton 应用程序使用的批处理文件

       BUD Quicken的备份磁盘

       BUN CakeWalk 声音捆绑文件(一种MIDI程序)

       BW SGI黑白图像文件

       BWV 商业波形文件

       BYU BYU的**文件格式

       B4 Helix Nuts and Bolts文件

       C C代码文件

       C0l 台风波形文件

       CAB Microsoft压缩档案文件

       CAD Softdek的Drafix CAD文件

       CAL CALS压缩位图；日历计划表数据

       CAM Casio照相机格式

       CAP 压缩音乐文件格式

       CAS 逗号分开的ASCⅡ文件

       CAT Quicken使用 的IntellCharge分类文件

       CB Microsoft干净引导文件

       CBI 二进制卷格式文件(用于IBM大型机系统)

       CC Visual dBASE用户自定义类文件

       CCA cc：邮件文件

       CCB Visual Basic动态按钮配置文件

       CCF 多媒体查看器配置文件，用于OS/2

       CCH Corel图表文件

       CCM Lotus cc：邮箱（例如“INBOX.CCM”）

       CCO CyberChat数据文件

       CCT Macromedia Director Shockwave投影

       CDA CD音频轨道

       CDF Microsoft频道定义格式文件

       CDI Philip的高密盘交互格式

       CDM Visual dBASE自定义数据模块文件

       CDR CorelDRAW绘图文件；原始音频CD数据文件

       CDT CorelDRAW模板

       CDX CorelDRAW压缩绘图文件；Microsoft Visual FoxPro索引文件

       CEL CIMFast事件语言文件

       CER 证书文件（MIME x-x-ca-cert）

       CFB Compton的多媒文件

       CFG 配置文件

       CFM CotdFusion模板文件；Visual dBASE Windows用户定制表单

       CGI 公共网关接口脚本文件

       CGM 计算机图形元文件

       CH OS/2配置文件

       CHK 由Windows磁盘碎片整理器或磁盘扫描保存的文件碎片

       CHM 编译过的HTML文件

       CHR 字符集（字体文件）

       CHP Ventura Publisher章节文件

       CHT ChartViem文件；Harvard Graphics矢量文件

       CIF Adaptec CD 创建器 CD映像文件

       CIL Clip Gallery下载包

       CIM SimCity 文件

       CIN OS/2改变控制文件用于跟踪INI文件中的变化

       CK1 iD/Apogee Commander Keen 1数据文件

       CK2 iD/Apogee Commander Keen 2数据文件

       CK3 iD/Apogee Commander Keen 3数据文件

       CK4 iD /Apogee Commander Keen 4数据文件

       CK5 iD /Apogee Commander Keen 5数据文件

       CK6 iD /Apogee Commander Keen 6数据文件

       CLASS Java类文件

       CLL Crick Software Clicker文件

       CLP Windows 剪贴板文件

       CLS Visual Basic类文件

       CMD Windows NT，OS/2的命令文件；DOS CD/M命令文件；dBASEⅡ程序文件

       CMF Corel元文件

       CMG Chessmaster保存的游戏文件

       CMP JPEG位图文件；地址文档

       CMV Corel Move动画文件

       CMX Corel Presentation Exchange图像

       CNF Telnet，Windows和其他其内格式会发生改变的应用程序使用的配置文件

       CNM Windows应用程序菜单选项和安装文件

       CNQ Compuworks Design Shop文件

       CNT Windows（或其他）系统用于帮助索引或其他目的内容文件

       COB TrueSpace 2对象文件

       COD Microsoft C编译器产生的可显示机器码/汇编代码文件，其中附有源C代码作为注释

       COM 命令文件（程序）

       CPD Corel Print Office文件（图形）

       CPD，CPE 传真覆盖文档

       CPI Microsoft MS-DOS代码页信息文件

       CPL 控制面板扩展名，Corel颜色板

       CPO Corel打印存储文件

       CPP C++代码文件

       CPR Corel提供说明书文件

       CPT Corel 照片-绘画图像

       CPX Corel Presentation Exchange压缩图形文件

       CRD Windows Cardfile文件

       CRP Corel 提供的运行时介绍文件；Visual dBASE自定义报表文件

       CRT 认证文件

       CSC Corel脚本文件

       CSP PC Emcee On_Screen图像

       CSS 瀑布式表格文件

       CST Macromedia Director Cast文件

       CSV 逗号分隔的值文件

       CT Scitex CT位图文件；Paint Shop Pro Grapic编辑器文件

       CTL 通常用于表示一个包含控件信息的文件；FaxWork用它来保持有关每个传真收到或发出的信息

       CUE Microsoft提示牌数据文件

       CUR Windows光标文件

       CUT Dr Halo位图文件

       CV Corel版本的档案文件；Microsoft CodeView信息屏幕文件

       CWK ClarisWorks数据文件.

       CWS ClarisWorks模块

       CXT Macromedia Director受保护的（不可编辑的）投影文件

       CXX C++源代码文件

       --------------------------------------------------------------------------------

       -- 作者：ray

       -- 发布时间：-- ::

       --

       DAT 数据文件；WrodPerfect合并数据文件；用于一些MPEG格式的文件

       DB Borland的Paradox 7表

       DBC Microsoft Visual FoxPro数据库容器文件

       DBF dBASE文件，一种由Ashton-Tate创建的格式，可以被ACT！、Lipper、FoxPro、Arago、Wordtech、Xbase和类似数据库或与数据库有关产品识别；可用数据文件（能被Excel 打开）；Oracle 8.1.x表格空间文件

       DBX DataBearn图像；Microsoft Visual FoxPro表格文件

       DCM DCM模块格式文件

       DCR 冲击波文件

       DCS 桌面颜色分隔文件

       DCT Microsoft Visual FoxPro数据库容器

       DCU Delphi编译单元文件

       DCX Microsoft Visual FoxPro数据库容器；基于PCX的传真图像；宏

       DC5 DataCAD绘图文件

       DDF Btrieve或Xtrieve数据定义文件，它包含用于描述Btrieve或Xtrieve文件的元数据

       DDIF Digital Equipment或 Compaq格式，用于保存他们图像与字处理文档

       DEF SmartWareⅡ数据文件；C++模块定义文件

       DEFI Oracle 7 卸载脚本文件

       DEM 用于表示数字高度模型的USGS基准的文件

       DER 认证文件

       DEWF Macintosh Sound Cap/Sound Edit录音设备格式

       DGN Macintosh CAD绘图文件

       DIB 设备无关位图

       DIC 目录

       DIF 可进行数据互换的电子表格

       DIG DigiLink格式；Sound DesignerⅠ音频文件

       DIR MacromediaDirector文件

ZookeeperApach Curator 框架源码分析：初始化过程（一）Ver 4.3.0

       Curator是由Netflix开源的一款用于简化Zookeeper客户端开发的工具，它提供了一套高级别API，使得开发者可以更简单易懂地实现分布式应用程序。Curator构建在Zookeeper原生客户端之上，提供了连接重试、异常处理、节点监听等常见功能，减轻了开发者的工作负担。Curator由多个模块组成，其中curator-framework和curator-recipes是最常用的部分，此外还提供了分布式锁等功能。

       Curator的最新版本为5.X系列，不再支持ZK 3.4.X及之前的版本。主要的改动在5.X系列中，原因包括代码重构、API调整等，导致不兼容之前的版本。

       Curator的下载地址可以通过Maven依赖管理或Apache官方网站获取。要开始使用Curator，需要搭建Zookeeper集群环境，详细部署过程可参考其他文章。

       引入Curator依赖后，开发者可以使用CuratorFrameworkFactory构建实例，通过此实例连接Zookeeper集群并执行分布式操作，如分布式锁等。Curator内部实现了重试策略、连接管理等，使得操作更为便捷且稳定。

       Curator提供了可重入锁（公平锁）的示例，开发者可以通过简单的代码实现分布式锁功能。初始化CuratorFramework实例的过程包括设置连接参数、构建实例、启动连接等步骤，内部会处理网络重连、异常处理等逻辑。

       在Curator的初始化过程中，CuratorFrameworkImpl是核心类，它负责构建与Zookeeper集群的连接，并封装了一系列关键组件，如连接管理、异常检测、负载均衡等。CuratorZookeeperClient类负责Zookeeper客户端的封装和调用。

       CuratorFrameworkImpl的启动过程涉及初始化连接状态管理器、启动客户端连接、执行后台操作等关键步骤。通过CAS操作确保线程安全，并在异常情况下自动重试连接。

       连接状态管理器（ConnectionStateManager）负责维护连接状态并处理状态变更通知，确保在状态改变时能够及时通知到监听器。通知机制包括注册一次性监听器、注册CuratorListener和ConnectionStateListener，以及处理未处理的错误。

       Curator的会话管理机制包括连接状态检查和重连策略，确保在连接断开后能够自动恢复连接。在状态变更时，连接状态管理器会通知所有注册的监听器，执行相应的回调逻辑。

       Curator还提供了缓存机制，用于保存节点数据并在数据发生变化时进行更新。此外，Curator支持多次注册监听器，确保在连接断开后能够重新注册监听器，以避免丢失监听事件。

       通过上述分析，Curator为开发者提供了高效、稳定的Zookeeper客户端实现，简化了分布式应用程序的开发过程。在实际应用中，开发者需要根据项目需求选择合适的版本和功能模块，以充分利用Curator提供的便利性。

spinlock（linux kernel 自旋锁）

       在Linux内核的世界里，自旋锁spinlock犹如守护者，守护着数据的临界区，确保并发访问的有序性。它不依赖于睡眠，而是通过连续的CPU循环来尝试获取锁，这在中断处理和进程上下文中表现出了极高的效率，但也可能造成CPU资源的浪费。自旋锁有三种主要实现方式：CAS（Compare and Swap）模式，简单直接但竞争随机；Ticket模式，引入公平性但消耗CPU；而MCS（Multi-CPU Scalable）模式，是对Ticket模式的优化，通过链表通知减少了CPU空转，实现了更高的效率与内存利用。

       在Linux内核的广泛应用中，自旋锁的性能优化尤为重要，尤其是在多线程竞态的极端场景。例如，MCS模式虽然牺牲了一定的内存使用，但其高效性能使之成为首选。特别是针对内存密集型的应用，qspinlock的出现，通过一个位原子变量巧妙地管理locked、pending和tail，实现了内存节省和高效操作。然而，这种复杂性也意味着在编写和维护时需要更加谨慎。

       要使用自旋锁，只需在spinlock.h>中引入相关头文件，定义spinlock并调用spin_lock、spin_unlock进行加锁解锁。举个实例，当处理中断和进程混合的并发任务时，spinlock能够确保数据的一致性。内核提供了多种API，如spin_lock, spin_unlock用于无中断操作，spin_lock_irq, spin_unlock_irq则避免了中断的嵌套，spin_is_locked函数则用于检查锁的状态。

       源代码的精髓隐藏在kernel\locking\spinlock.c和qspinlock.c中，头文件位于include\linux\spinlock.h。最新的Linux kernel 5..5 stable tree中包含了这些实现。深入研究源码，你会发现自旋锁的实现层次结构，从spin_lock到do_raw_spin_trylock，再到arch_spin_trylock，映射着qspinlock等优化方案。

       对于内核开发者来说，自旋锁的优化是一个动态发展的领域，新的解决方案可能会不断涌现。想要深入了解，不妨关注我们的专业专栏RTFSC（Linux kernel源码轻松读），这里有丰富的原创内容，助你探索更深层次的内核世界。