• 欢迎访问 winrains 的个人网站!
  • 本网站主要从互联网整理和收集了与Java、网络安全、Linux等技术相关的文章,供学习和研究使用。如有侵权,请留言告知,谢谢!

ReentrantLock 的 Conditiion 原理解析

Java技术 winrains 来源:arthinking 6个月前 (03-21) 45次浏览

导读

这篇文章我们来ReentrantLock中的Condition实现原理。阅读完本篇文章,你将了解到:

1、Condition底层是如何实现的


有如下的ReentrantLock和Condition:

// 锁和条件变量
private final Lock lock = new ReentrantLock();
// 条件
private final Condition condition1 = lock.newCondition();

下面来看看执行await和signal的流程。

1、await等待

一般地,只有线程获取到lock之后,才可以使用condition的await方法。假设此时线程1获取到了ReentrantLock锁,在执行代码逻辑的时候,发现某些条件不符合,于是调用了以下代码:

while(xxx条件不满足) {
  condition1.await();
}

此时AQS主要执行以下动作:

  1. 线程1把自己包装成节点,waitStatus设为CONDITION(-2),追加到ConditionObject中的条件队列(每个ConditionObject有一个自己的条件队列);
  2. 线程1释放锁,把state设置为0;
  3. 然后唤醒等待队列中head节点的下一个节点;

如下:

接下来进入一个循环,如果判断到当前线程的节点不在等待队列,那么会一直让当前线程阻塞,代码如下:

while (!isOnSyncQueue(node)) {
  LockSupport.park(this);
  if ((interruptMode = checkInterruptWhileWaiting(node)) != 0)
    break;
}

这个时候已经唤醒其他线程继续处理了,只有其他线程执行了condition1.signal或者condition1.signalAll之后,才会唤醒线程1进行处理后续的流程。

2、signal唤醒

当另一个线程执行了 condition1.signal之后,主要是做了以下事情:

  1. 把条件队列中的第一个节点追加到等待队列中;
  2. 把等待队列原来尾节点的waitStatus设置为SIGNAL。

然后继续处理自己的事情,自己的事情处理完成之后,会释放锁,唤醒等待队列中head节点的下一个节点线程进行工作。

3、await恢复后继续执行

被唤醒的如果是之前执行了await方法的线程,那么该线程会接着就像往await方法里面阻塞处的下面继续执行,下面是源码:

// 如果当前节点不在等待队列,会一直进行阻塞
while (!isOnSyncQueue(node)) {
  LockSupport.park(this);
  if ((interruptMode = checkInterruptWhileWaiting(node)) != 0)
    break;
}
// 该方法主要做以下事情:
// 1.尝试获取ReentrantLock锁
// 2.获取成功,把现在线程节点变为新的head节点
// 3. 否则根据继续休眠等待
if (acquireQueued(node, savedState) && interruptMode != THROW_IE)
  interruptMode = REINTERRUPT;
if (node.nextWaiter != null) // 如果等待节点被取消了,那么从条件队列中移除
  unlinkCancelledWaiters();
if (interruptMode != 0)
  reportInterruptAfterWait(interruptMode);

可以发现,这里主要是判断到当前线程节点已经放入等待队列了,那么会尝试获取锁,获取成功则继续往下执行代码。

作者:arthinking

来源:https://www.itzhai.com/cpj/analysis-of-reentrantlocks-condition-principle.html


版权声明:文末如注明作者和来源,则表示本文系转载,版权为原作者所有 | 本文如有侵权,请及时联系,承诺在收到消息后第一时间删除 | 如转载本文,请注明原文链接。
喜欢 (0)