从ReentrantLock到AQS：深入解析Java并发锁的实现哲学

引言：为什么我们需要深入理解锁机制？

在Java并发编程的世界中，锁是协调多线程访问共享资源的核心机制。从早期的synchronized关键字到java.util.concurrent包中的各种高级锁，Java的并发工具一直在演进。本文将选择ReentrantLock作为切入点，深入分析其底层依赖的抽象队列同步器（AQS），揭示现代Java并发锁的设计哲学与实现原理。

第一部分：ReentrantLock的使用与特性

1.1 基础使用示例

publicclassReentrantLockDemo{privatefinalReentrantLocklock=newReentrantLock();privateintcounter=0;publicvoidincrement(){lock.lock();// 获取锁try{counter++;System.out.println("Counter: "+counter+" Thread: "+Thread.currentThread().getName());}finally{lock.unlock();// 释放锁}}// 尝试获取锁，带有超时机制publicbooleantryIncrement(longtimeout,TimeUnitunit){try{if(lock.tryLock(timeout,unit)){try{counter++;returntrue;}finally{lock.unlock();}}returnfalse;}catch(InterruptedExceptione){Thread.currentThread().interrupt();returnfalse;}}}

1.2 ReentrantLock的核心特性

  1. 可重入性：同一个线程可以多次获得同一把锁
  2. 公平性选择：支持公平锁和非公平锁两种模式
  3. 可中断的锁获取：支持在等待锁的过程中响应中断
  4. 超时机制：可以尝试在指定时间内获取锁
  5. 条件变量支持：可以创建多个Condition对象

第二部分：揭开AQS的神秘面纱

2.1 AQS的设计思想

AQS采用模板方法模式，将同步器的核心算法框架固定，而将一些具体操作留给子类实现。其核心是一个FIFO双向队列（CLH队列的变体）和一个表示同步状态的volatile变量。

// AQS简化版核心结构publicabstractclassAbstractQueuedSynchronizer{// 同步状态，子类通过CAS操作修改privatevolatileintstate;// 等待队列的头节点和尾节点privatetransientvolatileNodehead;privatetransientvolatileNodetail;// 内部Node类定义staticfinalclassNode{volatileintwaitStatus;// 等待状态volatileNodeprev;// 前驱节点volatileNodenext;// 后继节点volatileThreadthread;// 等待线程NodenextWaiter;// 条件队列的后继节点}}

2.2 同步状态（State）的妙用

AQS中的state字段是一个int类型的volatile变量，不同的同步器以不同的方式解释这个状态：

  • ReentrantLock：state表示持有锁的线程的重入次数
  • Semaphore：state表示当前可用的许可证数量
  • CountDownLatch：state表示还需要等待的事件数量
  • ReentrantReadWriteLock：高16位表示读锁数量，低16位表示写锁重入次数

第三部分：ReentrantLock如何基于AQS实现

3.1 公平锁与非公平锁的实现差异

// 非公平锁的实现staticfinalclassNonfairSyncextendsSync{finalvoidlock(){// 直接尝试获取锁，不检查队列if(compareAndSetState(0,1))setExclusiveOwnerThread(Thread.currentThread());elseacquire(1);// 调用AQS的acquire方法}protectedfinalbooleantryAcquire(intacquires){returnnonfairTryAcquire(acquires);}}// 公平锁的实现staticfinalclassFairSyncextendsSync{finalvoidlock(){acquire(1);// 直接进入队列排队}protectedfinalbooleantryAcquire(intacquires){finalThreadcurrent=Thread.currentThread();intc=getState();if(c==0){// 关键区别：先检查队列中是否有等待的线程if(!hasQueuedPredecessors()&&compareAndSetState(0,acquires)){setExclusiveOwnerThread(current);returntrue;}}// 重入逻辑...returnfalse;}}

3.2 锁获取的完整流程

// AQS中的acquire方法publicfinalvoidacquire(intarg){if(!tryAcquire(arg)&&// 步骤1：尝试获取锁acquireQueued(addWaiter(Node.EXCLUSIVE),arg))// 步骤2&3：入队并等待selfInterrupt();// 步骤4：恢复中断状态}// 节点入队privateNodeaddWaiter(Nodemode){Nodenode=newNode(Thread.currentThread(),mode);// 快速入队：尝试直接添加到队尾Nodepred=tail;if(pred!=null){node.prev=pred;if(compareAndSetTail(pred,node)){pred.next=node;returnnode;}}enq(node);// 完整入队流程returnnode;}// 在队列中等待获取锁finalbooleanacquireQueued(finalNodenode,intarg){booleanfailed=true;try{booleaninterrupted=false;for(;;){finalNodep=node.predecessor();// 只有前驱节点是头节点时，才尝试获取锁if(p==head&&tryAcquire(arg)){setHead(node);p.next=null;// help GCfailed=false;returninterrupted;}// 检查并更新等待状态，可能需要阻塞if(shouldParkAfterFailedAcquire(p,node)&&parkAndCheckInterrupt())interrupted=true;}}finally{if(failed)cancelAcquire(node);}}

第四部分：条件变量（Condition）的实现原理

4.1 ConditionObject的内部结构

publicclassConditionObjectimplementsCondition{privatetransientNodefirstWaiter;// 条件队列头节点privatetransientNodelastWaiter;// 条件队列尾节点// 等待条件publicfinalvoidawait()throwsInterruptedException{if(Thread.interrupted())thrownewInterruptedException();Nodenode=addConditionWaiter();// 添加到条件队列intsavedState=fullyRelease(node);// 完全释放锁intinterruptMode=0;while(!isOnSyncQueue(node)){LockSupport.park(this);// 阻塞当前线程if((interruptMode=checkInterruptWhileWaiting(node))!=0)break;}// 被唤醒后重新获取锁if(acquireQueued(node,savedState)&&interruptMode!=THROW_IE)interruptMode=REINTERRUPT;if(node.nextWaiter!=null)unlinkCancelledWaiters();if(interruptMode!=0)reportInterruptAfterWait(interruptMode);}// 发出信号publicfinalvoidsignal(){if(!isHeldExclusively())thrownewIllegalMonitorStateException();Nodefirst=firstWaiter;if(first!=null)doSignal(first);// 将节点从条件队列转移到同步队列}}

4.2 条件队列与同步队列的交互

同步队列（获取锁的等待队列） 条件队列（等待条件的队列） head firstWaiter | | Node1 <-> Node2 <-> Node3 CNode1 -> CNode2 -> CNode3 | | tail lastWaiter signal()操作： 1. 将CNode1从条件队列移除 2. 将CNode1转移到同步队列尾部 3. 唤醒CNode1中的线程

第五部分：性能优化与最佳实践

5.1 锁优化策略

  1. 减少锁的持有时间：只在必要的时候持有锁
  2. 减小锁的粒度：使用更细粒度的锁
  3. 锁分离技术：如ReadWriteLock分离读锁和写锁
  4. 无锁编程：考虑使用CAS操作或并发容器

5.2 选择合适的锁策略

publicclassLockStrategyExample{// 场景1：高竞争环境下的公平性选择// 公平锁：保证顺序性，但吞吐量较低privatefinalReentrantLockfairLock=newReentrantLock(true);// 场景2：低竞争或追求最大吞吐量// 非公平锁：可能产生饥饿，但吞吐量高privatefinalReentrantLockunfairLock=newReentrantLock(false);// 场景3：读多写少的场景privatefinalReentrantReadWriteLockrwLock=newReentrantReadWriteLock();publicvoidreadOperation(){rwLock.readLock().lock();try{// 读操作，可以并发执行}finally{rwLock.readLock().unlock();}}publicvoidwriteOperation(){rwLock.writeLock().lock();try{// 写操作，独占执行}finally{rwLock.writeLock().unlock();}}}

5.3 诊断锁问题

// 使用ThreadMXBean诊断死锁publicclassDeadlockDetector{publicstaticvoiddetectDeadlock(){ThreadMXBeanthreadMXBean=ManagementFactory.getThreadMXBean();long[]threadIds=threadMXBean.findDeadlockedThreads();if(threadIds!=null){ThreadInfo[]threadInfos=threadMXBean.getThreadInfo(threadIds);for(ThreadInfothreadInfo:threadInfos){System.out.println("Deadlocked thread: "+threadInfo.getThreadName());System.out.println("Lock held: "+threadInfo.getLockName());System.out.println("Lock owner: "+threadInfo.getLockOwnerName());}}}}

第六部分：AQS在Java并发框架中的应用

6.1 基于AQS的同步器家族

同步器类状态state的含义使用场景
ReentrantLock重入次数互斥访问
Semaphore可用许可数资源池限制
CountDownLatch剩余计数多任务等待
CyclicBarrier等待线程数线程屏障
ReentrantReadWriteLock读写状态读写分离

6.2 自定义同步器示例

// 基于AQS实现一个简单的二元闭锁publicclassBinaryLatch{privatestaticclassSyncextendsAbstractQueuedSynchronizer{protectedinttryAcquireShared(intacquires){// 闭锁打开时返回1，否则返回-1returngetState()==1?1:-1;}protectedbooleantryReleaseShared(intreleases){// 打开闭锁setState(1);returntrue;}}privatefinalSyncsync=newSync();publicvoidawait()throwsInterruptedException{sync.acquireSharedInterruptibly(1);}publicvoidopen(){sync.releaseShared(1);}}

结论：AQS的设计哲学与启示

通过深入分析ReentrantLock和AQS，我们可以得出以下结论：

  1. 模板方法模式的威力：AQS通过模板方法提供了同步器的框架，子类只需要实现少数几个关键方法。

  2. 队列管理的艺术：CLH队列变体的设计既保证了公平性，又通过前驱节点的状态传递减少了不必要的线程唤醒。

  3. 状态机的思维：AQS将线程的等待状态建模为节点的状态变迁，这是解决复杂同步问题的有效方法。

  4. 性能与公平的权衡：非公平锁通过"插队"机制提高吞吐量，公平锁通过严格排队保证顺序性。

  5. 可重入性的重要性：可重入锁避免了自死锁，简化了嵌套锁的使用。

理解AQS不仅有助于我们更好地使用Java并发工具，更重要的是，它提供了一种设计同步原语的通用范式。这种范式强调状态管理、队列操作和线程调度的分离，是现代并发编程的重要思想源泉。

扩展阅读

  1. Java Memory Model (JMM)：理解happens-before关系
  2. Lock-Free算法：比较锁与无锁编程的优劣
  3. Synchronized的优化：偏向锁、轻量级锁、重量级锁的升级过程
  4. StampedLock：Java 8引入的乐观读锁机制

通过从ReentrantLock到AQS的深入探索，我们不仅掌握了一个具体技术的实现细节，更重要的是理解了Java并发框架的设计哲学。这种从具体到抽象，再从抽象到具体的思考过程，是每一位Java开发者都应该掌握的工程思维方法。

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

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

相关文章

AHN技术：3B小模型高效处理超长文本新突破

AHN技术：3B小模型高效处理超长文本新突破

AHN技术&#xff1a;3B小模型高效处理超长文本新突破 【免费下载链接】AHN-GDN-for-Qwen-2.5-Instruct-3B 项目地址: https://ai.gitcode.com/hf_mirrors/ByteDance-Seed/AHN-GDN-for-Qwen-2.5-Instruct-3B 导语&#xff1a;字节跳动最新发布的AHN&#xff08;Artifici…
阅读更多...
如何在Arch Linux上完成Packet Tracer下载安装

如何在Arch Linux上完成Packet Tracer下载安装

如何在 Arch Linux 上丝滑安装 Cisco Packet Tracer&#xff08;告别依赖地狱&#xff09; 你是不是也遇到过这种情况&#xff1a;想用 Cisco Packet Tracer 做个网络拓扑实验&#xff0c;结果发现官方只提供 .deb 包——而你是坚定的 Arch Linux 用户&#xff1f;别急&am…
阅读更多...
SongPrep-7B：70亿参数歌曲解析转录新工具

SongPrep-7B：70亿参数歌曲解析转录新工具

SongPrep-7B&#xff1a;70亿参数歌曲解析转录新工具 【免费下载链接】SongPrep-7B SongPrep-7B是腾讯混元推出的开源70亿参数模型&#xff0c;基于百万歌曲数据集训练&#xff0c;支持全歌曲结构解析与歌词转录&#xff0c;提供端到端音频处理能力&#xff0c;适用于音乐分析、…
阅读更多...
ERNIE 4.5思维升级：21B轻量模型推理再突破

ERNIE 4.5思维升级：21B轻量模型推理再突破

ERNIE 4.5思维升级&#xff1a;21B轻量模型推理再突破 【免费下载链接】ERNIE-4.5-21B-A3B-Thinking 项目地址: https://ai.gitcode.com/hf_mirrors/baidu/ERNIE-4.5-21B-A3B-Thinking 百度ERNIE系列大模型迎来重要更新&#xff0c;推出专注提升复杂推理能力的ERNIE-4.…
阅读更多...
Tar-7B：文本对齐视觉AI的全能新方案

Tar-7B：文本对齐视觉AI的全能新方案

Tar-7B&#xff1a;文本对齐视觉AI的全能新方案 【免费下载链接】Tar-7B 项目地址: https://ai.gitcode.com/hf_mirrors/ByteDance-Seed/Tar-7B 导语&#xff1a;字节跳动种子团队&#xff08;ByteDance-Seed&#xff09;推出的Tar-7B模型&#xff0c;通过文本对齐表示…
阅读更多...
VLAC：机器人学的终极多模态AI评论家

VLAC：机器人学的终极多模态AI评论家

VLAC&#xff1a;机器人学的终极多模态AI评论家 【免费下载链接】VLAC 项目地址: https://ai.gitcode.com/hf_mirrors/InternRobotics/VLAC 导语&#xff1a;上海AI实验室最新发布的VLAC&#xff08;Vision-Language-Action-Critic&#xff09;模型&#xff0c;通过融合…
阅读更多...
Qwen2.5-7B模型蒸馏：轻量化部署方案

Qwen2.5-7B模型蒸馏：轻量化部署方案

Qwen2.5-7B模型蒸馏&#xff1a;轻量化部署方案 1. 引言&#xff1a;为何需要对Qwen2.5-7B进行模型蒸馏&#xff1f; 随着大语言模型&#xff08;LLM&#xff09;在自然语言处理任务中的广泛应用&#xff0c;性能与效率的平衡成为工程落地的核心挑战。阿里云发布的 Qwen2.5-7B…
阅读更多...
Wan2.2视频大模型：电影级AI视频创作新突破

Wan2.2视频大模型：电影级AI视频创作新突破

Wan2.2视频大模型&#xff1a;电影级AI视频创作新突破 【免费下载链接】Wan2.2-T2V-A14B 项目地址: https://ai.gitcode.com/hf_mirrors/Wan-AI/Wan2.2-T2V-A14B 导语&#xff1a;Wan2.2视频大模型正式发布&#xff0c;凭借创新的混合专家&#xff08;MoE&#xff09;架…
阅读更多...
KaniTTS：450M参数实现8语言实时语音合成

KaniTTS：450M参数实现8语言实时语音合成

KaniTTS&#xff1a;450M参数实现8语言实时语音合成 【免费下载链接】kani-tts-450m-0.1-pt 项目地址: https://ai.gitcode.com/hf_mirrors/nineninesix/kani-tts-450m-0.1-pt 导语&#xff1a;近日&#xff0c;一款名为KaniTTS的新型文本转语音&#xff08;TTS&#x…
阅读更多...
17亿参数Palmyra-mini：数学解题AI新体验

17亿参数Palmyra-mini：数学解题AI新体验

17亿参数Palmyra-mini&#xff1a;数学解题AI新体验 【免费下载链接】palmyra-mini 项目地址: https://ai.gitcode.com/hf_mirrors/Writer/palmyra-mini 导语&#xff1a;Writer公司推出的17亿参数模型Palmyra-mini&#xff0c;凭借在数学推理任务上的出色表现&#xf…
阅读更多...
ModbusPoll下载结合逻辑分析仪提升RTU调试效率

ModbusPoll下载结合逻辑分析仪提升RTU调试效率

用ModbusPoll和逻辑分析仪打通RTU调试的“任督二脉”在工业现场&#xff0c;你是否也遇到过这样的场景&#xff1f;一台PLC通过RS-485总线连接多个传感器&#xff0c;Modbus Poll轮询时数据时好时坏——有时超时&#xff0c;有时CRC错误&#xff0c;重试几次又能通。你反复检查…
阅读更多...
工业现场USB通信异常：快速理解核心要点

工业现场USB通信异常：快速理解核心要点

工业现场USB通信异常&#xff1a;从“拔插重试”到系统化根治 你有没有遇到过这样的场景&#xff1f; 在车间调试一台新上的数据采集模块&#xff0c;工控机反复提示“ 未知USB设备 ”&#xff0c;换了几根线、重启了三次电脑&#xff0c;终于识别了——可刚采集十分钟&…
阅读更多...
字节跳动开源Seed-OSS-36B：512K上下文智能推理大模型

字节跳动开源Seed-OSS-36B：512K上下文智能推理大模型

字节跳动开源Seed-OSS-36B&#xff1a;512K上下文智能推理大模型 【免费下载链接】Seed-OSS-36B-Base 项目地址: https://ai.gitcode.com/hf_mirrors/ByteDance-Seed/Seed-OSS-36B-Base 导语&#xff1a;字节跳动Seed团队正式开源360亿参数大语言模型Seed-OSS-36B系列&…
阅读更多...
Qwen2.5-VL-AWQ：让AI成为你的视觉全能助手

Qwen2.5-VL-AWQ：让AI成为你的视觉全能助手

Qwen2.5-VL-AWQ&#xff1a;让AI成为你的视觉全能助手 【免费下载链接】Qwen2.5-VL-7B-Instruct-AWQ 项目地址: https://ai.gitcode.com/hf_mirrors/Qwen/Qwen2.5-VL-7B-Instruct-AWQ 导语&#xff1a;阿里达摩院最新发布的Qwen2.5-VL-AWQ多模态大模型&#xff0c;凭借…
阅读更多...
Qwen2.5-7B部署教程：RMSNorm与RoPE配置要点详解

Qwen2.5-7B部署教程：RMSNorm与RoPE配置要点详解

Qwen2.5-7B部署教程&#xff1a;RMSNorm与RoPE配置要点详解 1. 引言&#xff1a;为何选择Qwen2.5-7B进行本地部署&#xff1f; 随着大模型在实际业务中的广泛应用&#xff0c;高效、稳定且可定制的本地化部署成为开发者和企业的核心需求。阿里云最新发布的 Qwen2.5-7B 模型&am…
阅读更多...
官方yoloV5开源代码注释，基本每个文件夹和模块都有注释，非常详细。 自己写的注释，供学习参考使用

官方yoloV5开源代码注释，基本每个文件夹和模块都有注释，非常详细。 自己写的注释，供学习参考使用

官方yoloV5开源代码注释&#xff0c;基本每个文件夹和模块都有注释&#xff0c;非常详细。 自己写的注释&#xff0c;供学习参考使用。 深度学习入门代码解读注释。直接扒开YOLOv5的代码仓库&#xff0c;迎面而来的utils文件夹里藏着不少好玩的工具。比如这个datasets.py里的Lo…
阅读更多...
零基础学习DRC：如何配置并运行第一次检查任务

零基础学习DRC：如何配置并运行第一次检查任务

零基础跑通第一次 DRC 检查&#xff1a;从环境搭建到结果解读的完整实战指南你刚画完人生第一个版图&#xff0c;心里美滋滋地准备流片——慢着&#xff01;DRC 过了吗&#xff1f;在IC设计的世界里&#xff0c;这句话就像“代码编译通过了吗&#xff1f;”一样基础&#xff0c…
阅读更多...
GLM-4.5-FP8震撼发布：355B参数MoE模型推理效率飞跃

GLM-4.5-FP8震撼发布：355B参数MoE模型推理效率飞跃

GLM-4.5-FP8震撼发布&#xff1a;355B参数MoE模型推理效率飞跃 【免费下载链接】GLM-4.5-FP8 项目地址: https://ai.gitcode.com/zai-org/GLM-4.5-FP8 导语&#xff1a;智谱AI正式推出GLM-4.5-FP8大语言模型&#xff0c;以3550亿总参数的混合专家&#xff08;MoE&#…
阅读更多...
qthread信号发射与槽函数响应时序分析

qthread信号发射与槽函数响应时序分析

QThread信号与槽的时序之谜&#xff1a;为什么你的槽函数“延迟”了&#xff1f;你有没有遇到过这样的情况&#xff1f;点击一个按钮&#xff0c;触发了一个信号&#xff0c;连接的槽函数却没有立刻执行——UI似乎卡了一下&#xff0c;或者日志显示它在几毫秒后才被调用。更奇怪…
阅读更多...
Emu3.5：10万亿token！原生多模态AI创作新体验

Emu3.5：10万亿token！原生多模态AI创作新体验

Emu3.5&#xff1a;10万亿token&#xff01;原生多模态AI创作新体验 【免费下载链接】Emu3.5 项目地址: https://ai.gitcode.com/BAAI/Emu3.5 导语&#xff1a;BAAI团队推出的Emu3.5模型凭借10万亿多模态token训练量和原生多模态架构&#xff0c;重新定义AI内容创作体验…
阅读更多...
最新文章

Copyright @ 2022~2023