qidao123.com技术社区-IT企服评测·应用市场

标题: Java 并发编程 - 并发控制的哲学思想 [打印本页]
作者: 愛在花開的季節    时间: 2025-5-2 12:40
标题: Java 并发编程 - 并发控制的哲学思想
Java 并发编程 - 并发难点及解决方法

并发难点

顺序性

由于多个CPU执行多个线程,以是谁先谁后就很重要,比如CPU1否则读取,CPUB负责计算,那么计算要保证在读取之后.
就好像你买菜,你媳妇做饭,那么做饭这件事要等待买菜完成,但是两件事是不同的两个人用不同的环境实现的.
现实世界的解决方案就是:你媳妇等你买菜,你买完菜了通知你媳妇可以开始做饭了.这就必要你媳妇等待做饭,你通知她做饭.此为等待通知机制
可见性

由于CPU读取数据的时候有缓存,写出数据的时候有缓冲区,以是CPU1读写完的数据并不一定能被CPU2看到结果.
就好像你媳妇给你和你老弟发短信去买白菜,假如你们俩不带电话,记在脑子里(缓存数据),那么你媳妇此时改变主意了,要买黄瓜了(其他线程修改数据),你就不知道.以是必要带上电话,你媳妇改变注意的时候,你俩就不知道,就会买错菜.
现实世界的解决方案就是,你们带上电话,你媳妇改变主意了给你们再发信息,此为广播通知,你们收到消息,知道改变主意了,在采购的时候重新查看一下短信,获取最新的购买需求,此为缓存同等.
原子性

由于多个CPU执行多个线程,以是无法保证一个数据的读写只能被一个CPU的一个线程执行,中间大概有其他CPU的其他线程干预.
就好像你媳妇做好的菜饭,必要放到橱柜,此时菜能吃,但是要防止你谁人淘气的儿子来吐口水,假如吐了口水,则不能吃了.
现实世界的解决方案就是,给你儿子锁屋子里,但是锁太大了(总线锁),妨碍了你儿子玩你,以是锁了橱柜(缓存锁),你儿子仅仅不能碰那些大米饭.
解决方法

对某个资源加锁来保证原子性

多个操作者操作一个资源,必要对资源上锁,处理完再解锁.这样可以保证数据原子操作,就好像互联网常用的分布式锁,CPU也会有总线锁/缓存锁.
锁定的是公共资源

从现实世界来说,我们在使用公共资源的时候,通常都会独占某公共资源;但是你使用你的胳膊,嗓子,眼睛的时候,这是你的私有资源,不会影响别人,除非别人想摘掉你的胳膊,否则你的私有资源使用与别人无关.
注意锁的粒度

就好像你把你儿子关起来,还是把饭菜锁起来一样,锁必要有一个粒度,很明显的是,在入库的时候我们不会让整个体系其他所有入库操作都禁止,而是当前操作的谁人仓库被锁住,想想商城里的公共卫生间不会由于有人进入卫生间,而锁住整个阛阓不让其他人进出.
同样,CPU在上锁的时候有两个选择①将整个CPU操作的总线锁定,②将会涉及到的缓存锁定.很明显锁定缓存让锁的粒度更小,其他CPU受到的影响也小.
因此我们要知道,锁的粒度会对体系性能有很大影响.
用比力和替换(CAS)来保证原子性

其实计算机中的数据只有读写两种操作,原子性操作就是保证你读取和写入之间没有别人写入.我们可以在写入的时候比力一下,假如是从当初你读取的值写入到当前值,则是中间没有操作入过,否则就是有操作写入过.这就是cas操作,比力后替换.
就好像你听见儿子说他饿了(读取儿子的状态),你去拿来奶喂它(写入充饥的数据),假如你去拿奶的时候你小舅子来照顾过你的儿子给他奶了,你再喂他,他大概就吃多了撑得慌,为了克制这种情况,你必要喂他之前再问问你儿子"小家伙,你还饿么?" 假如跟之前的信息(饿)不同等,则放弃喂奶.
用排队等待解决顺序性

多个操作的顺序乱序,可以让他们排队操作,此时必要等待通知来实现.起首要锁定这个资源,然后争抢使用这个资源的操作必要排队.
等待的一定是个公共资源

而且你只会在你所等待的公共资源的队列上排队;就好像你在烧烤店门口排队,那么你等待的资源就是烧烤店,而等待卫生间的人不会到烧烤店门口排队,以是你们俩之前不竞争,而是排队等待卫生间的那些人存在竞同一资源.换言之:这个世界上肯定是你占用了某资源才造成排队,比如公共电话亭,比如公共卫生间.
被动等待

就好像许多人去银行排队取钱,银行会给你一个号(排队),到你了用喇叭喊你(广播通知),你听见广播了(叫醒)就去柜台,在你拿到排队号的时候,你没得选,保安要求你必须排队等待.这是被动的等待,由Jvm给我们提供的shynchronized关键字.
自动等待

但是你在取钱的时候发现银行现在没钱了,那么你有两个选择,①放弃取钱,②等待总行来送钱.此时你会重新排队,但是队列不一样,是一个等待拿钱就走的队列,那么此时进入等待是你自动的,在运钞车来的时候,会通知等着钱的这个队列的人,给他们现金然后让他们走人.由jdk为我们提供的 Object.wait 和Object.notify 方法.
一定要获取锁才能自动等待

由于你一定要独占了这个资源,才有本事分辨出这个资源是否符合你操作的必要,否则别人也操作这个资源,你的判断大概就不准确.
就好像在卫生间门口排队,自然就是等待,而你进入卫生间才会发现里面没有纸,此时你已经获取了卫生间的使用权(关门,上锁)才能发现,那么你很大概让那些不必要纸就能上茅厕的人先用,以是你出来了并重新排队(wait).以是你看,自动等待的时候会释放锁.
由此可见排队等待必须在某个资源上排队,也是叫醒排队某个资源的等待队列,以是synchronized关键字要对某个对象加锁,Object.wait和Object.notify也是针对某个对象上的队列.
让缓存失效保证可见性

每个操作之间有缓存,必要通过广播让缓存失效,失效之后要重新获取下最新数据.比如通过MQ发布一个主题消息,通知其他机器某个缓存失效了,订阅主题的机器收到消息之后将本地的缓存标记失效,这是分布式体系上的,从CPU微观来说,连接MQ的网线是CPU的总线,类似的机制实现就是CPU缓存同等性.
我们最好不用(也最好不要)每次失效都重新读取数据,由于假如在时间点1->2之间失效100次,那么则将重新获取100次数据,而这100次获取数据都不一定会被读取一次.就好像你10台机器上都有用户信息,但是不一定每台的用户信息都会被读取.(此为惰性缓存)
宏观来看

假如你不了解什么是微服务,不知道zookeeper,不知道分布式锁,不知道消息队列服务器,可以不看这些.
你完全可以将上面这些过程想象成许多个微服务实例下,拥有自己的本地缓存,在操作某个缓存数据的时候,会在zookeeper上加一个分布式锁,处理完成的时候会在mq上某个主题发布消息,通知缓存被修改,其他实例收到消息后,将本地缓存标记失效,在下次读取数据操作的时候,重新加载缓存.
这个时候你就发现,原本的CPU总线换成了网线传输数据,原本CPU的1,2,3级缓存变成了微服务的本地缓存,原本的缓存锁变成了分布式锁.
但是这还不够,有的时候用户拿到数据等了很久才提交,以是我们的数据上会有一个版本号,每次提交增长版本号,每次写回数据库的时候比力当前数据库版本和用户提交的版本,这就是cpu上的cas操作.
如何实现

比力替换的实现

在CPU层面为我们提供了 cmpxchg 指令来实现,  这是个IA-32的汇编指令.
缓存加锁的实现

在CPU层面为我们提供了 lock 指令前缀来实现, 这个指令会锁定总线/缓存,然后独享数据的去修改,而且修改完之后会将当前CPU缓冲区写会主存.这是个IA-32的汇编指令.
缓存失效的实现

在CPU层面为我们提供了总线广播监听机制,这个机制可以监听缓存的失效,并将其标记失效,下次看到失效的缓存则从主存读取,这个机制的学名为 MESI(缓存同等性协议).
线程等待的实现

等待有两种方式,一个是一直等待,一个是超时等待,一直等待直接将线程保存起来,比及有叫醒的时候再调度执行就行.超时等待则必要一个定时器.
定时器的具体实现是OS层面的东西,比力复杂,但是现在很成熟,同时有硬件层面的支持.硬件层面有一个固定时钟和计数器,每一个时钟周期将计数器递减,计数器为0的时候触发CPU中断,这看上去很斲丧CPU,由于每次CPU的周期都必要检查.也就是说操作体系级别的等待是硬件级别的操作,以是斲丧是很小很小的.
其实无论如何都离不开不断检查,从现实世界来说,假如我们想等待到某时间点,唯一的办法(不考虑闹钟等)就是不断的检查当前时间和任务列表.不大概有其他办法.考虑其实等待到某时间点和等待一段时间其实都是一样的,以是只必要一个定时检查的计时器就可以了.这就是为什么一个线程能等待一段时间.
排队的实现思路

有了计时器,我们在加上排队,就可以实现排队-等待-通知,排队的实现必要一个队列,不管你是基于链表,还是数组,总之必要一个排队的地方,现实世界中有排队的地方,就有插队的人,不同的是看守理队列的人允不允许插队而已.
此时有两种实现思路,公平排队和非公平排队.
Java 层面的实现

Jvm级别

起首Java的线程跟OS线程是1:1映射关系,以是底层会有OS的体系调用库来实现线程创建,销毁,启动,等待操作,然后封装成 Thread 类操作. 提供synchronized实现对一个对象资源的锁定操作,提供volatile实现对CPU缓存的锁定和缓冲区flush的操作.
Jdk级别

然后在JDK层面,为我们提供了Object.wait 和Object.notify方法与synchronized配合,来实现排队-等待-通知机制.
CPU级别的CAS操作,jdk提供了UNSAFE类来操作,这个类里面有许多CAS操作的方法.
JUC级别

最后在JUC包内,为我们提供了LockSupport类,让我们可以直接操作一个线程进入等待,和叫醒线程;有了LockSupport类,便可以向OS操作线程一样去实现高级的排队-等待-通知-叫醒等操作,于是提供了AQS线程同步框架.
有了AQS线程同步框架,便可以利用将线程排队-等待这些操作,实现非常灵活的Lock类.
编程实现范式

普通等待通知
  1. // 获得锁，判断条件是否满足,不满足,则等待
  2. // 一个线程也能在没有被通知、中断或超时的情况下唤醒，也即所谓的“虚假唤醒”，虽然这点在实践中很少发生，应用应该检测导致线程唤醒的条件，并在条件不满足的情况下继续等待，以此来防止这一点。
  3.            synchronized (obj) {
  4.                while (<condition does not hold>)
  5.                    obj.wait(timeout);
  6.            }
  7. // 摘录来自: jdk 源代码 wait方法注释
复制代码
普通等待通知且支持超时
  1. // 获得锁，计算结束时间，循环判断条件是否满足，等待剩余时间时间，被唤醒之后检查条件，并且重新计算等待时间
  2. public synchronized Object get(long mills) throws InterruptedException {
  3.        long future = System.currentTimeMillis() + mills;
  4.        long remaining = mills;
  5.        // 当超时大于0并且result返回值不满足要求
  6.        while ((result == null) && remaining > 0) {
  7.               wait(remaining);
  8.               remaining = future - System.currentTimeMillis();
  9.        }
  10.    return result;
  11. }
  12. // 摘录来自: 方腾飞,魏鹏,程晓明 著. “Java并发编程的艺术 (Java核心技术系列)。” Apple Books.
复制代码
具体的实现类

Object 类

Object 类提供了线程的基础等待通知实现方法,这些方法要求在synchronized关键字范围内的代码段执行,即:获取了jvm提供的锁.
之以是定义在Object方法中,一部分原因由于synchronized锁是在某个对象头加锁,换言之就是锁定某个对象资源.然后进行排队等待等调度,之以是这样计划,是由于必须要有一个资源上加锁之后才能进入等待队列,以是你必要锁定这个对象,然后调用这个对象上的wait-notify,来实现某个资源的锁定和等待通知机制.
Thread 类

Thread.join 实现原理

该方法是一个同步方法,使用一个this.wait的循环来实现当前线程的等待,while的条件是当前线程还存活,wait导致调用线程的等待,在join的线程结束的时候会调用this.notifyAll来叫醒当前等待的线程,这个方法是jvm负责调用.源代码中有一句话:不发起在步伐中的线程实例中使用wait,notify或者notifyAll.
It is recommended that applications not use wait, notify, or notifyAll on Thread instances.
ThreadLocal  类

作用
ThreadLocal可以在当前线程存储一个变量.焦点原理是在当前线程对象下创建一个map,然后将当前ThreadLocal的实例作为key存储变量.
关键点
安全隐患 假如线程没有被销毁,那么线程内部的threadLocals变量将会一直保持引用,无法回收,假如调用ThreadLocal#set方法设置的变量没有调用remove方法清理,则一直保持在ThreadLocalMap中,此时保持的值处于一个无法被回收的状态.
LockSupport  类

LockSupport类提供了park系列和unpark系列方,内部调用UNSAFE类实现,UNSAFE类由JVM在本地C++中实现,具体实现与平台有关,park方法在Linux下使用的是体系方法pthread_cond_wait实现;unpark方法在Linux下是使用pthread_cond_signal实现的.
在park(Object)的时候,dump线程会发现由wait的对象信息,是存储在Thread.parkBlocker字段上,通过UNSAFE.objectFieldOffset写到线程对象上的.
AQS 线程同步器

线程同步器实现了一个线程排队等待的框架,线程排队等待的实现离不开两点实现:①创建一个排队的线程,由于必要前后节节点的快速获取,此队列通常使用链表实现;②利用线程的等待通知机制将队列中的线程阻塞住.Java中的线程和OS的线程是1:1映射的,线程的等待利用的是OS的体系调用实现,封装成了Jdk中的LockSupport类; 这个机制保证了线程的有序性.
线程同步器还提供了一种原子性争抢资源的本事,他内部存储了一个状态标志,用volatile修饰,是一个数字类型,利用cas操作进行修改操作,假如操作成功,表现这个操作期间没有其他线程竞争,或者其他线程都竞争失败,此时其他线程发现自己竞争失败则进入等待队列,竞争成功的线程得以真正的执行,执行结束的时候再次修改这个状态表现,此时由于volatile的语义特性,最后这个修改操作会保证数据被(所有CPU缓冲区)写回主存,这个操作间接的保证了线程的原子性,可见性.
线程同步器提供了独占和共享的两组获取锁和释放锁的抽象方法
线程等待实现

实现线程等待在一个死循环中无限尝试获取锁,直到成功或者被中断,在执行过程中有大概会被 LockSupport.park 方法暂停掉,在首节点执行完毕的时候会叫醒排在其之后的第一个可运行节点,节点被叫醒之后马上重新在死循环中争抢锁.
总的来说,就是在死循环中处理等待通知机制.
独占锁的处理

共享锁的处理

初始一个令牌桶,桶中包含多个锁,锁的数目影响并发数目,,每次获取锁,则从桶中拿走一个(或者多个)令牌,每次释放,则从桶中放回锁,每次取出和释放的过程使用cas操作,保证原子性,则允许通过的线程是: 桶巨细(锁总数)/桶粒度(每次获取锁数)
Condition 等待条件

Condition在自己内部又做了一个队列,在wait的时候将当前线程放入队列,在notify的时候从队列叫醒,由于condition要求在调用wait-notify的时候必须获取锁,以是内部在wait和notify的时候无需cas操作.
如何保证可见性

unlock操作会cas修改一个volatile变量,而volatile变量的修改会运行一条LOCK指令,该指令会锁缓存(或者总线)保证其他CPU不会并发访问数据,而且写完数据之后会立即将这颗CPU的将缓冲区数据刷入主存,同时
并发工具类

CountDownLatch

利用AQS实现,比如5个线程,初始设置state=5;每次结束一个线程(countDown)做减法: state=state-1;await等待方法则是从申请1个值,但是在tryAcquireShared方法中实现的是假如状态不是0,则不允许,假如是0,则允许.
Semaphore

利用AQS实现,类似CountDownLatch,初始化一个令牌桶,每次申请N个令牌桶,不够申请则等待.区别是Semaphore只要桶内数目足够申请就行,CountDownLatch要求必须只剩下0个.
CyclicBarrier

利用ReentrantLock  以及 ReentrantLock#newCondition ,内部使用一个int count 做计数,每次await一个线程的时候,加锁,做count--,假如count是0,则重新开始,重新开始的时候condition.notifyall;假如不是0,则condition.await(此时会释放锁);
原子操作类

大多数原子类,都是利用一个 Unsafe 类和一个volatile 变量包装的.执行原子更新的时候适用cas方式来执行更新.
Unsafe 类底层实现依靠于汇编指令 cmpxchg 实现原子性操作.
但是lazySet却是使用UNSAFE.putOrderedInt方法执行的,底层虚拟机调用的是C++方法的SET_FIELD_VOLATILE(obj, offset, jlong, x);仅仅是实现了volatile的语义操作,该操作导致修改后不是立即可见的.
计数器类

焦点实现是创建一个base值,做基础累加,在cas操作base值失败之后,根据CPU数目创建多个Cell,将计算的逻辑分散到各个cell中,此时每个CPU最多操作自身的一个cell,险些是资源独占的模式工作,以是累加效率会大有提高,但是读取值的时候必要将所有cell以及base值,读取速度大概变慢.
就好像是一个分桶排序的算法,由于一个桶放了太多数排序太慢,而分为多个桶来计算;或者说数据库表太大,则分成多个表.
其实我们的步伐大多数都是写多读少的
并发编程锁

Java中锁的实现都是基于AQS实现的,具体一个锁的实现会选择实现AQS的独占锁或者共享锁的一种,在初始化的时候初始化一个state,独占锁通常为1,共享锁大概是大于1,获取锁则acquire(1),释放锁则release(1).
ReentrantLock

ReentrantLock 实现了初始state=0的一个AQS,每次acquire则增长1,release则减少1
重入实现

acquire的时候假如当前线程是获取到锁的线程,则会再次增长1,来实现重入获取,release在发现state=0的时候,则将当前获取锁的线程标记为null,来实现重入释放.state不是0,且当前线程没有持有锁,则不允许获取锁.
公平与非公平实现

公平锁在哀求锁的时候会判断是不是有一个前驱节点在排队,假如有则放弃cas操作(tryAcquire 返回false),非公平锁则不判断直接进行cas操作.
判断前驱节点在排队的方法是查看前首节点(当前执行的节点)的下一节点不是当前线程,换言之:当前线程不是队列中排队第二的待执行线程.
ReentrantReadWriteLock

读写锁实现了AQS的共享锁和独占锁两种模式,原理是将一个int值,按位分割成高16位来标记读,和低16位来标记写.内部有一个 int exclusiveCount(int c) 用来计算独占锁的数目,一个 int sharedCount(int c)   用来计算共享锁的数目,
写锁的获取在有读锁已被获取的情况下进行等待,没有读的时候跟ReentrantLock 类似;读锁在没有写锁的情况下就可以用cas尝试更新state了,失败则放入等待队列,用死循环来等待.
写锁重入的实现跟ReentrantLock类似,只不过只能支持低16位最大数次重入,读锁的重入利用ThreadLocale来存放重入次数.
写锁获取

tryAcquire 方法解释说:
读锁获取

tryAcquireShared 方法解释说:
锁降级

根据读锁的获取流程可以看出,获取读锁的时候,假如当前线程已经获取了独占的写锁,也可以获取读锁,此被称为锁降级.但是写锁获取的时候,假如已经有读锁了,直接放弃,意味着无法锁升级.
锁降级是位了写完数据之后马上可以读取到数据,而且在独占的写锁中获取读锁,然后释放写锁,保证了在获取读锁的过程中不会有其他线程写入数据,保证自己写完之后看到的数据是最新的.
总结

我们讨论了Java并发编程的基础,从其面临的困难,以及如何解决这些困难的方案,到方案的具体实现.本文的基础章节很啰嗦,但是他很重要,那些高级的工具类,以及lock都是如何实现的并发包,但是基础章节却是为何要这么实现,以及如何思考到这些东西的思维演进.有了这些基础,我们可以很轻易的实现线程池,阻塞队列,等高级工具.

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 qidao123.com技术社区-IT企服评测·应用市场 (https://dis.qidao123.com/) Powered by Discuz! X3.4