1.casԴ?码部벿??
2.Linux基础组件之无锁消息队列ypipe/yqueue详解
3.ConcurrentHashMap确实很复杂,这样学源码才简单
4.ReentrantLock 源码解析 | 京东云技术团队
5.jdk源码剖析手册?
casԴ?码部벿??
我最近建立了一个在线自习室(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时线程阻塞,bd系统源码当_counter>0时直接设为0并返回。
每个Java线程都有一个Parker实例,Parker类的部分源码如下:
由源码可知,Parker类继承于PlatformParker,实际上是用Posix的mutex和condition来实现的。Parker类里的_counter字段,就是用来记录park和unpark是否需要阻塞的标识。
具体的执行逻辑已经用注释标记在代码中,简要来说,就是检查_counter是不是大于0,如果是,则把_counter设置为0,返回。如果等于零,继续执行,阻塞等待。
unpark直接设置_counter为1,再unlock mutex返回。如果_counter之前的值是0,则还要调用pthread_cond_signal唤醒在park中等待的线程。源码如下:
(如果不会下载JVM源码可以后台回复“jdk”,获得下载压缩包)
Linux基础组件之无锁消息队列ypipe/yqueue详解
CAS定义
比较并交换(compare and swap, CAS),在多线程编程中用于实现不被打断的数据交换,避免数据不一致问题。该操作通过比较内存值与指定数据,当数值相同则替换内存数据。
为什么需要无锁队列
锁引起的问题:cache损坏/失效、同步机制上的争抢、动态内存分配。
有锁导致线程切换引发cache损坏
大量线程切换导致cache数据失效,处理器与主存之间数据传输效率下降,影响性能。
在同步机制上的争抢队列
阻塞队列导致任务暂停或睡眠,大量时间浪费在获取互斥锁,而非处理数据,引发严重争用。
动态内存分配
多线程中动态分配内存导致互斥,线程频繁分配内存影响应用性能。
无锁队列的实现
无锁队列由ypipe_t和yqueue_t类构成,适用于一读一写场景。通过chunk模式批量分配结点,伍德 源码减少动态内存分配的互斥问题。批量分配大小根据业务场景调整,通常设置较大较为安全。利用spare_chunk存储未释放的chunk,降低频繁分配释放。预写机制减少CAS调用。巧妙的唤醒机制,读端等待无数据时进入等待状态,写端根据返回值判断队列是否为空以唤醒读端。
无锁队列使用
yqueue.write(count,false)用于写入元素并标记完成状态,yqueue.flush()使读端可见更新后数据。yqueue.read(&value)读取元素,返回true表示读到元素,返回false表示队列为空。
ypipe_t使用
write(val, false)更新写入位置,flush()刷新数据到管道,read()读取数据并更新可读位置。
yqueue_t构造函数
初始化队列,end_chunk总是指向最后分配的chunk,back_chunk仅在有元素插入时指向对应的chunk。
front()和back()函数
返回队列头和尾的可读写元素位置。
push()和pop()函数
push()更新写入位置,pop()更新读取位置并检测释放chunk,保持数据流。
源码分析
yqueue_t内部使用chunk批量分配,减少内存操作,spare_chunk存储释放的chunk以供再次使用。ypipe_t构建单写单读无锁队列,通过CAS操作控制读写位置,实现高效数据交换。
ypipe_t / yqueue_t无锁队列利用chunk机制避免频繁内存动态分配,提升性能。通过局部性原理复用回收的chunk,减少资源消耗。flush()检测队列状态通知唤醒,优化数据交换过程。
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、同步和锁的管理。
ReentrantLock 源码解析 | 京东云技术团队
并发指同一时间内进行了多个线程。并发问题是多个线程对同一资源进行操作时产生的问题。通过加锁可以解决并发问题,Yp街机源码ReentrantLock 是锁的一种。
1 ReentrantLock
1.1 定义
ReentrantLock 是 Lock 接口的实现类,可以手动的对某一段进行加锁。ReentrantLock 可重入锁,具有可重入性,并且支持可中断锁。其内部对锁的控制有两种实现,一种为公平锁,另一种为非公平锁.
1.2 实现原理
ReentrantLock 的实现原理为 volatile+CAS。想要说明 volatile 和 CAS 首先要说明 JMM。
1.2.1 JMM
JMM (java 内存模型 Java Memory Model 简称 JMM) 本身是一个抽象的概念,并不在内存中真实存在的,它描述的是一组规范或者规则,通过这组规范定义了程序中各个变量的访问方式.
由于 JMM 运行的程序的实体是线程。而每个线程创建时 JMM 都会为其创建一个自己的工作内存 (栈空间), 工作内存是每个线程的私有数据区域。而 java 内存模型中规定所有的变量都存储在主内存中,主内存是共享内存区域,所有线程都可以访问,但线程的变量的操作 (读取赋值等) 必须在自己的工作内存中去进行,首先要将变量从主存拷贝到自己的工作内存中,然后对变量进行操作,操作完成后再将变量操作完后的新值写回主内存,不能直接操作主内存的变量,各个线程的工作内存中存储着主内存的变量拷贝的副本,因不同的线程间无法访问对方的工作内存,线程间的通信必须在主内存来完成。
如图所示:线程 A 对变量 A 的操作,只能是从主内存中拷贝到线程中,再写回到主内存中。
1.2.2 volatile
volatile 是 JAVA 的关键字用于修饰变量,是 java 虚拟机的轻量同步机制,volatile 不能保证原子性。 作用:
作用:CAS 会使用现代处理器上提供的高效机器级别原子指令,这些原子指令以原子方式对内存执行读 - 改 - 写操作。
1.2.4 AQSAQS 的全称是 AbstractQueuedSynchronizer(抽象的队列式的同步器),AQS 定义了一套多线程访问共享资源的同步器框架。
AQS 主要包含两部分内容:共享资源和等待队列。AQS 底层已经对这两部分内容提供了很多方法。
2 源码解析
ReentrantLock 在包 java.util.concurrent.locks 下,实现 Lock 接口。
2.1 lock 方法
lock 分为公平锁和非公平锁。
公平锁:
非公平锁:上来先尝试将 state 从 0 修改为 1,如果成功,代表获取锁资源。如果没有成功,调用 acquire。state 是 AQS 中的一个由 volatile 修饰的 int 类型变量,多个线程会通过 CAS 的方式修改 state,在并发情况下,只会有一个线程成功的修改 state。
2.2 acquire 方法
acquire 是一个业务方法,里面并没有实际的业务处理,都是在调用其他方法。
2.3 tryAcquire 方法
tryAcquire 分为公平和非公平两种。
公平:
非公平:
2.4 addWaiter 方法
在获取锁资源失败后,需要将当前线程封装为 Node 对象,并且插入到 AQS 队列的末尾。
2.5 acquireQueued 方法
2.6 unlock 方法
释放锁资源,将 state 减 1, 如果 state 减为 0 了,唤醒在队列中排队的 Node。
3 使用实例
3.1 公平锁
1. 代码:
2. 执行结果:
3. 小结:
公平锁可以保证每个线程获取锁的机会是相等的。
3.2 非公平锁
1. 代码:
2. 执行结果:
3. 小结:
非公平锁每个线程获取锁的机会是随机的。
3.3 忽略重复操作
1. 代码:
2. 执行结果:
3. 小结:
当线程持有锁时,不会重复执行,可以用来防止定时任务重复执行或者页面事件多次触发时不会重复触发。
3.4 超时不执行
1. 代码:
2. 执行结果:
3. 小结:
超时不执行可以防止由于资源处理不当长时间占用资源产生的死锁问题。
4 总结
并发是现在软件系统不可避免的问题,ReentrantLock 是可重入的独占锁,比起 synchronized 功能更加丰富,支持公平锁实现,支持中断响应以及限时等待等,是处理并发问题很好的解决方案。
jdk源码剖析手册?
源码解析-偏向锁撤销流程解读
实现上面atomic-free(表示尽可能减少CAS这样的原子操作)偏向锁的难点就在于如何协调获取偏向锁和撤销偏向锁的过程。
偏向锁的撤销,需要等待全局安全点(在这个时间点上没有字节码正在执行),它会首先暂停拥有偏向锁的线程,判断锁对象是否处于被锁定状态,撤销偏向锁后恢复到未锁定(标志位为“”)或轻量级锁(标志位为“”)的状态。
分析-XX:+PrintSafepointStatistics–XX:PrintSafepointStatisticsCount=1产生的日志信息基本上STW的原因都是RevokeBias或者BulkRevokeBias。这个是撤销偏向锁操作,虽然每次暂停的时间很短,但是特别频繁出现也会很耗时。
学习JAVA的同学都是怎么读源码的?1、面对未知的、茫茫多的源码,我们往往没有足够的时间、经历和耐心去通读所有源码,我们只需要去读我们关注的部分即可(有人可能会说我都不关心,这?)。
2、首先要理清楚代码结构和业务结构(应该有些文档或者大的流程图),这是阅读具体代码的前提。阅读Javaweb项目的代码:你需要找到View层的代码:前端页面、、资源文件都在其中。
3、了解和使用工具很多工具都可以有助于源代码阅读,并且对可视化代码有很大的帮助。在使用过程中,成都IT培训认为IntelliJIdea工具能够导航源代码,允许使用单词的一部分,甚至单词的缩写进行搜索。您还应该学习键盘的快捷键。
4、阅读分析源代码,一些有效的方法是:阅读源代码的说明文档和API文档。如果源代码有用法示例或向导,先阅读这个。了解整个项目的模块结构,可以按模块进行阅读。
如何在Eclipse中查看JDK类库的源代码在Eclipse中查看Java类库的源代码,可以通过Ctrl+鼠标左键的方式来完成;在下载JDK并安装的时候,会有一个src.zip文件,此文件就是Java类库的源码。但是有时候,会出现源码未找到的问题,此时可以通过对其设置来解决。
第一次使用eclipse查看jar包里的源代码时,没有导入jdk的项目源码,所以无法查看源码。查看源代码的方法:打开eclipse,点击window,之后选择Preferences选项。
首先打开eclipse,建立项目:Test,将struts2相关jar包导入到其中。在PackageExplorer标签栏下操作。这里查阅struts2中,struts2-core-1jar下的源代码。
java在eclipse中有两种被运行的方式(jre的方式和jdk的方式)。你看不到源码就是因为你是通过jre的方式运行的。通过eclipse进入菜单Window-Preferences-Java-InstalledJREs。
JDK查看源码可首先从ArrayList、Vector、LinkedList源码比较开始看起。
如何高效阅读源代码?
1、首先要理清楚代码结构和业务结构(应该有些文档或者大的流程图),这是阅读具体代码的前提。阅读Javaweb项目的代码:你需要找到View层的代码:前端页面、、资源文件都在其中。
2、当然有。终于到重点了,隆重推出由官方支持的方式:只需要在代码仓库页面按一下.就可以直接使用VSCode打开,而且支持编辑。也可以通过地址访问,把.com改成.dev,比如:太方便了,太优雅了。
3、查看拦截器,监听器代码,知道拦截了什么请求,这个类完成了怎样的工作。
4、用命令(apktooldxxx.apkxxx_xml)反编译xxx.apk包从xxx_xml文件夹得到xml文件第二步得到的程序源代码和第三步得到的xml文件组合下,即可得到完整的apk源码。
5、先找出功能体系,再分离出功能模块。知道能干什么,再知道怎么干。
6、面对未知的、茫茫多的源码,我们往往没有足够的时间、经历和耐心去通读所有源码,我们只需要去读我们关注的部分即可(有人可能会说我都不关心,这?)。
如何在Eclipse中查看JDK类库的源代码?在Eclipse中查看Java类库的源代码,可以通过Ctrl+鼠标左键的方式来完成;在下载JDK并安装的时候,会有一个src.zip文件,此文件就是Java类库的源码。但是有时候,会出现源码未找到的问题,此时可以通过对其设置来解决。
首先打开eclipse,建立项目:Test,将struts2相关jar包导入到其中。在PackageExplorer标签栏下操作。这里查阅struts2中,struts2-core-1jar下的源代码。
第一次使用eclipse查看jar包里的源代码时,没有导入jdk的项目源码,所以无法查看源码。查看源代码的方法:打开eclipse,点击window,之后选择Preferences选项。
如何查看javaJDK中底层源码1、查看源代码的方法:打开eclipse,点击window,之后选择Preferences选项。找到Java选项,点开,选择InstalledJRES,此时右边是列表窗格,列出了系统中的JRE环境,选择你的JRE,然后点边上的Edit。
2、在你的JDK文件夹下不是有个src.rar包吗?解压出来,把你想看的某个类的源码拖到eclipse中就可以查看了。
3、你安装JDK的目录下,有个src.zip文件,这个就是JDK源代码的java文件。你可以解压来查看,但,最好是关联到IDE如eclipse中(不需解压),然后CTRL+点击就可以查看到源代码了。
4、在安装jdk文件路径下的src.zip可以查看。。在eclipse里面也可以,只要按着ctrl键将鼠标放到想看的类上在点击左键就能进入到定义那个类的里面去了。。
5、在Eclipse中查看Java类库的源代码,可以通过Ctrl+鼠标左键的方式来完成;在下载JDK并安装的时候,会有一个src.zip文件,此文件就是Java类库的源码。但是有时候,会出现源码未找到的问题,此时可以通过对其设置来解决。
6、其实最好的方式是你通过对某一块代码的阅读,进行绘制流程图,VISIO画起流程图来很方便,找出数据流,再加上自己的阅读的注释。在你阅读学习的过程中,会发现其他coder的非常巧妙的做法,这是你应该庆幸,因为你在进步。