ReentrantLock中的Condition实现原理 C/C++

信息发布员 5月前 100

导读

这篇文章我们来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把自己包装成节点,waitStatus设为CONDITION(-2),追加到ConditionObject中的条件队列(每个ConditionObject有一个自己的条件队列);

线程1释放锁,把state设置为0;

然后唤醒等待队列中head节点的下一个节点;

如下:

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

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

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

2、signal唤醒

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

把条件队列中的第一个节点追加到等待队列中;

把等待队列原来尾节点的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);

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

第一节我们知道只有线程获取到ReentrantLock的锁之后才可以继续往下执行,中间可能会因为执行await而进入条件队列并释放锁,最后又会被唤醒重新获取锁,继续往下执行。最后按照书写规范,我们一定会在代码中执行ReentrantLock.unlock()释放锁,然后继续唤醒等待队列后续线程继续执行。


少客联盟- 版权声明 1、本主题所有言论和图片纯属会员个人意见,与少客联盟立场无关。
2、本站所有主题由该帖子作者发表,该帖子作者信息发布员少客联盟享有帖子相关版权。
3、少客联盟管理员和版主有权不事先通知发贴者而删除本文。
4、其他单位或个人使用、转载或引用本文时必须同时征得该帖子作者信息发布员少客联盟的同意。
5、帖子作者须承担一切因本文发表而直接或间接导致的民事或刑事法律责任。
6、本帖部分内容转载自其它媒体,但并不代表本站赞同其观点和对其真实性负责。
7、如本帖侵犯到任何版权问题,请立即告知本站,本站将及时予与删除并致以最深的歉意。
8、官方反馈邮箱:chinasuc@chinasuc.cn


上一篇:Java中的读写锁ReentrantReadWriteLock介绍与使用
下一篇:HTML特殊转义字符对照表
人生的价值,并不是用时间,而是用深度去衡量的。
最新回复 (0)
    • 少客联盟
      2
        登录 注册 QQ登录(停用)
返回