前面分析了AbstractQueuedSynchronizer实现的其他两部分:
Condition源码解析
独占模式解析
本文继续介绍AbstractQueuedSynchronizer最后一部分功能--共享模式
共享模式资源获取
共享模式获取资源的入口如下
// 忽略中断异常
public final void acquireShared(int arg) {
if (tryAcquireShared(arg) < 0)
doAcquireShared(arg);
}
// 抛出中断异常
public final void acquireSharedInterruptibly(int arg)
throws InterruptedException {
if (Thread.interrupted())
throw new InterruptedException();
if (tryAcquireShared(arg) < 0)
doAcquireSharedInterruptibly(arg);
}
// 超时获取,并抛出中断异常
public final boolean tryAcquireSharedNanos(int arg, long nanosTimeout)
throws InterruptedException {
if (Thread.interrupted())
throw new InterruptedException();
return tryAcquireShared(arg) >= 0 ||
doAcquireSharedNanos(arg, nanosTimeout);
}
tryAcquireShared留给工具自己去实现,用于判断是否满足获取资源要求,与独占模式判断函数不一样,tryAcquire返回的是boolean,因为是独占模式,每次只能一个线程获取资源,所以直接返回boolean,共享模式下资源可以被多个线程通知占用,tryAcquireShared返回int类型,表示还有多少个资源可以同时被占用,用于共享模式下传播唤醒。
doAcquireShared
重点分析下doAcquireShared方法,doAcquireSharedInterruptibly和doAcquireSharedNanos区别不是很大,不做分析
private void doAcquireShared(int arg) {
//添加共享模式节点,主要区分独占模式
final Node node = addWaiter(Node.SHARED);
boolean failed = true;
try {
boolean interrupted = false;
for (;;) {
//拿到当前节点的前驱节点,如果前驱节点是head节点,说明没有等待节点
final Node p = node.predecessor();
if (p == head) {
// 尝试获取资源,大于等于0,说明有资源获取。
int r = tryAcquireShared(arg);
if (r >= 0) {
//把当前节点设置成head节点,并传播唤醒后面的节点。
setHeadAndPropagate(node, r);
p.next = null; // help GC
if (interrupted)
selfInterrupt();
failed = false;
return;
}
}
// 这里和独占模式一样,如果没资源申请,封装节点,并park等待
if (shouldParkAfterFailedAcquire(p, node) &&
parkAndCheckInterrupt())
interrupted = true;
}
} finally {
if (failed)
cancelAcquire(node);
}
}
setHeadAndPropagate
private void setHeadAndPropagate(Node node, int propagate) {
// 设置head节点,保留之前的head的节点,用于是否传播唤醒之后节点判断
Node h = head; // Record old head for check below
setHead(node);
/**
* 需要传播唤醒的几个条件
* 1,propagate>0,当大于0的时候,说明还有其他资源空余,需要传播唤醒之后的节点
* 2,head == null || head.waitStatus < 0,头结点为空,head.waitStatus < 0即需要唤醒状态或者是传播状态,也无条件尝试唤醒之后的节点
* 唤醒之后的节点,会去重新尝试获取资源。
* 这里存在误唤醒,不过没关系,唤醒之后的节点,会继续回到doAcquireShared for循环中,尝试获取资源。
*/
if (propagate > 0 || h == null || h.waitStatus < 0 ||
(h = head) == null || h.waitStatus < 0) {
Node s = node.next;
// 判断是否是共享节点
if (s == null || s.isShared())
doReleaseShared();
}
}
以上是共享模式获取资源流程,释放资源函数如下:
doReleaseShared
private void doReleaseShared() {
for (;;) {
Node h = head;
if (h != null && h != tail) {
int ws = h.waitStatus;
// 如果head节点的后继节点需要被唤醒,然后唤醒
if (ws == Node.SIGNAL) {
if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0))
continue; // loop to recheck cases
unparkSuccessor(h);
}
// 如果head节点后没有需要被唤醒的节点,设置成PROPAGATE状态,然后传播唤醒
else if (ws == 0 &&
!compareAndSetWaitStatus(h, 0, Node.PROPAGATE))
continue; // loop on failed CAS
}
if (h == head) // loop if head changed
break;
}
}
网友评论