亲宝软件园·资讯

展开

ReentrantLock获取锁释放锁的流程示例分析

Alan_YYL 人气:0

目的

代码

package com.company.aqs;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
 * ReentrantLock使用案例——使用ReentrantLock加锁
 * @Author: Alan
 * @Date: 2022/11/20 01:38
 */
public class ReentrantLockDemo {
    private static int sum=0;
    private static Lock lock=new ReentrantLock();
    public static void main(String[] args) throws InterruptedException {
        for (int i = 0; i < 3; i++) {
            new Thread(()->{
                // 获取锁
                lock.lock();
                try {
                    for (int j = 0; j < 1000; j++) {
                        sum++;
                    }
                }finally {
                    // 在finally代码块中释放锁
                    lock.unlock();
                }
            }).start();
        }
        // 保证所有线程执行完毕
        Thread.sleep(1000);
        System.out.println(sum);
    }
}

这是一个使用ReentrantLock实现多线程求和的案例。代码逻辑比较简单,外层循环开启了3个线程,然后每个线程内多sum累加1000,最后输出结果sum=1000。

获取锁流程

整个过程概括起来就做了两件事儿

当第一个线程(thead0)进来的时候,通过CAS去修改state属性为1,如果成功,通过setExclusiveOwnerThread()方法设置exclusiveOwnerThread为当前线程

此时,第二个线程(thead1)进来,再去通过CAS修改state属性为1时,便会失败,此时进入acquire()方法。最终会走到如下方法,首先通过tryAcquire()方法再次尝试去获取锁。

tryAcquire()方法内部还是会通过CAS去获取锁。此时锁资源还被第二线程持有,因此会返回false。现在接着看acquire()方法中的if判断。

此时,会进行acquireQueued(addWaiter(Node.EXCLUSIVE), arg))判断。这里需要执行两个方法addWaiter()和acquireQueued()。首先看addWaiter()方法。这个方法,我们需要关注以下四点。

如果同步队列为空了,那么执行enq()方法,这个方法为我们做了两件事儿。

通过addWaiter()方法和enq()方法,我们也可以看出来,AQS中的同步队列是通过双向链表来实现的,节点入队和出队,需要修改两个指针才行(prev和next)。

addWaiter()方法执行执行完毕后,我们通过下面这张图大致看下此时同步队列中的节点指向情况。此处,不太理解可以再回头看看enq()方法的执行流程。

addWaiter()方法执行执行完毕后,会返回入队后的新节点。然后开始执行acquireQueued()方法。这个方法做了五件事儿。

4. parkAndCheckInterrupt()方法会阻塞当前线程,同时,能够返回当前线程的中断状态(Thread.interrupted()会清除中断标记位)。

经过上述的一通操作,我们可以知道,线程1没有获取到锁,被加入到了同步队列,并且还对其进行了阻塞。概括下就是四个字“入队”、“阻塞”。此时我们的同步队列也变成如下所示。和上述执行完addWaiter()方法相比,只是线程1节点的前驱节点,waitStaus被设置成了-1。

释放锁流程

整个过程(只考虑释放锁成功)概括起来做了三件事儿

当第一个线程(thread0)执行完自己的业务流程后,就会释放锁。此时,我们来看看释放锁的流程又是什么样子的。调用unlock()方法可以对锁进行释放,需要注意的时,为了避免死锁,需要将该方法的调用放在fiaally代码块中。

当thread0去释放锁时,会调用release()方法,该方法主要做了两件事儿。

其方法内部,会将state设置为0,同时通过setExclusiveOwnerThread()方法设置exclusiveOwnerThread为当null,代表此时锁资源被释放,没有任何线程持有锁资源

如果第一步返回true,即释放锁成功,那么开始第二步。第二步首先获取同步队列的头节点,查看其waitStatus属性。这里我们把刚才获取锁过后,同步队列中的节点情况再放一下。此时,我们的head节点的waitStatus为-1,因此会进入unparkSuccessor()方法

unparkSuccessor()方法,主要做了以下三件事儿。注意第三步,根据我们当前同步队列的情况来看,LockSupport.unpark()方法会唤醒线程1。

当执行完unparkSuccessor()方法中的LockSupport.unpark()方法后,线程1(thread1)就会被唤醒了。线程1被唤醒过后,我们又来看看线程1的执行情况。此时线程1,会继续执行acquireQueued()方法中的for循环(注意:这是一个死循环哦)。执行顺序和获取锁时是一致的,和获取锁有所不同的时,此时执行第2步获取锁是会成功的(因为thread0已经释放锁了)。

获取锁成功后呢,会让当前同步队列中的头节点出队,此时,同步队列中的节点情况如下所示。

此时,释放锁的逻辑就执行完成了。归纳起来其实也很简单,首先释放锁资源,然后再唤醒同步队列中头节点的后一个节点对应的线程,最后,更新同步队列(出队)。

总结

以上便是ReentrantLock获取锁、释放锁的的大致流程。通过这篇文章,读者对ReentrantLock的获取锁、释放锁过程有一个大致的了解了,细心的读者可能会发现,获取锁时acquireQueued()方法中有一个队cancelAcquire()方法的调用逻辑,这里没有详细解释,博主会在后面的文章中详细来解释这个方法的处理逻辑(flag先立下!!!)。

加载全部内容

相关教程
猜你喜欢
用户评论