登录免费注册

首页  流程图  详情



 



AQS同步器源码分析

AQS同步器源码分析

2018-07-24 17:08:33   0  举报





仅支持查看

AQS同步器源码分析

AQS

同步器

phimine

AbstractQueuedSynchronizer

模板推荐

作者其他创作

大纲/内容

Y

设置当前结点为head

s != null?

*共享模式下，自己拿到资源后如果尚有剩余资源，还会去唤醒后继线程(较独占模式的不同)

*安全结点：找到在当前结点前面的最近一个正常等待状态的结点并排在其后面，忽略掉中间的放弃状态(state0)的结点们

*有效结点：state=0

找到队列中最前面的有效结点s

设置前驱结点状态为SIGNAL

*等待被唤醒：unpark()或interrupt()

false

成功(r=0)

true，CAS成功

返回true结束

false，置零失败，自旋循环

N

acquire()开始

true

唤醒方式是否通过interrupt()？

unparkSuccessor()唤醒后继

tryAcquireShared(arg)

shouldParkAfterFailedAcquire()找安全结点

r=tryAcquireShared(arg)

*PROPAGATE传播失败

=

release()开始

addWaiter(Node.SHARED)加入等待队列尾部

判断h的状态waitStauts

首先尝试快速方式CAS直接入队，如果失败了再调用enq()通过CAS自旋的方式入队

失败，自旋

独占模式获取和释放资源

成功

tryAcquire()

唤醒结点线程LockSupport.unpark(s.thread)

h!=null && h!=tail?

被唤醒之后

false，CAS失败，自旋

SIGNAL(-1)

成功(=0)

前驱结点为head并且tryAcquire()成功？

r0？资源还有剩余?

线程获取资源成功

*arg: 资源数量

判断前驱结点为head？

doAcquireShared(arg)

CAS状态置零compareAndSetWaitStatus

结点状态置0compareAndSetWaitStatus

selfInterrupt()中断当前线程

失败(0)

addWaiter()加入等待队列尾部

doReleaseShared()唤醒后继线程

获取资源成功

selfInterrupt()中断当前线程，结束

0(执行过唤醒后继)

N，自旋

挂起线程LockSupport.park(this)

找到head结点(一般为当前结点)

N(自旋)

CAS状态设为PROPAGATE(-3)

tryRelease()

acquireShared(arg)开始

判断当前线程的唤醒方式是否是通过interrupt()？

返回false结束

releaseShared(arg)开始

当前结点设为head

h=head找到head结点(一般为当前结点)

设置前驱结点为SIGNAL

tryReleaseShared(arg)

共享模式获取和释放资源

 Collect

Get Started

Nacos 源码分析

 Collect

Get Started

Spring 源码分析

AbstractQueuedSynchronizer（AQS）同步器

 Collect

Get Started

AbstractQueuedSynchronizer（AQS）同步器

Spring 整合 Mybatis 源码分析

 Collect

Get Started

Spring 整合 Mybatis 源码分析













评论

0 条评论

下一页

Document