首页 > 其他分享 >简单说说 ReentrantLock

简单说说 ReentrantLock

时间:2024-10-08 15:52:53浏览次数:8  
标签:return ReentrantLock 获取 线程 公平 简单 final acquires

        ReentrantLock底层依赖AQS进行实现,是一种可重入的锁。

        在ReentrantLock中实现公平锁和非公平锁。

        在公平锁中,当调用lock方法,会先判断队列是否存在等待中的节点,如果队列无节点,会尝试去获取锁,如果获取到了锁,则执行业务代码,如果获取不到锁,一般是因为存在锁竞争,则会将当前线程Node加入到AQS中队列的尾部,同时,当前线程会被中断(调用线程interrupt方法)。

        在非公平锁中,当调用了lock方法,会先尝试去获取锁,如果可以获取锁,则直接执行业务代码,如果获取不到锁,则和公平锁一样,将node节点加入到线程尾部,同时,中断当前线程。

        公平锁和非公平锁【不同点】就是:非公平锁会在lock发生的时候尝试获取锁,而公平锁会直接加入队列尾部。

        当调用了unLock方法的时候,内部会调用release方法,该方法会将当前node的下一个node节点唤醒。


以下是对ReentrantLock源码的解析

公平锁

FairSync部分源码解析,FairSync是ReentrantLock的内部类,是对公平锁的实现

static final class FairSync extends Sync {
    private static final long serialVersionUID = -3000897897090466540L;

    final void lock() {
        //调用父类的方法,最终会调用到tryAcquire方法,父类方法中还会有获取锁失败后,加队列节点的操作
        acquire(1);
    }

    /**
     * 尝试去获取锁
     */
    protected final boolean tryAcquire(int acquires) {
        final Thread current = Thread.currentThread();
        int c = getState();
        //如果state = 0,说明当前没有线程占用锁
        if (c == 0) {
            //当队列中不存在任何node,然后去尝试设置state的值
            //就是说,在公平锁中,必须要队列中没有node,才会在一开始就获取锁,否则,不会去获取锁
            if (!hasQueuedPredecessors() &&
                    compareAndSetState(0, acquires)) {
                setExclusiveOwnerThread(current);
                return true;
            }
        }
        //这里是可重入的操作
        else if (current == getExclusiveOwnerThread()) {
            int nextc = c + acquires;
            if (nextc < 0)
                throw new Error("Maximum lock count exceeded");
            setState(nextc);
            return true;
        }
        return false;
    }
}

NofairSync部分源码解析,NofairSync是ReentrantLock的内部类,是对非公平锁的实现,NofairSync继承自Sync,Sync继承自AQS

static final class NonfairSync extends Sync {
        private static final long serialVersionUID = 7316153563782823691L;

        /**
         * 尝试获取锁
         */
        final void lock() {
            //在非公平锁中,会先通过cas尝试获取锁
            if (compareAndSetState(0, 1))
                setExclusiveOwnerThread(Thread.currentThread());
            else
                acquire(1);
        }

        protected final boolean tryAcquire(int acquires) {
            //该方法是父类的方法
            return nonfairTryAcquire(acquires);
        }
}

Sync部分源码解析,对nonfairTryAcquire方法的描述

 /**
 * 非公平锁尝试获取锁
 * @param acquires 操作数,在ReentrantLock中为1
 * @return
 */
final boolean nonfairTryAcquire(int acquires) {
    //当前线程
    final Thread current = Thread.currentThread();
    //获取AQS的state状态
    int c = getState();
    //当state为0,说明可以通过cas尝试获取锁
    if (c == 0) {
        //通过cas尝试获取锁
        if (compareAndSetState(0, acquires)) {
            //当cas成功,则将线当前线程设置为独占线程
            setExclusiveOwnerThread(current);
            return true;
        }
    }
    //如果当前线程是独占线程,说明这里需要操作可重入
    else if (current == getExclusiveOwnerThread()) {
        int nextc = c + acquires;
        if (nextc < 0) // overflow
            throw new Error("Maximum lock count exceeded");
        setState(nextc);
        return true;
    }
    return false;
}

标签:return,ReentrantLock,获取,线程,公平,简单,final,acquires
From: https://blog.csdn.net/sjdxx/article/details/142755322

相关文章

  • 【学习记录丨UVM】1.2驱动器driver(1)——最简单的driver及其实例化
    《UVM白皮书》关于driver的介绍一、只有driver——最简单的验证平台UVM是一个库,其中的driver等组件都是派生(extends)自UVM库中的类(class)。类中通过function和task实现组件功能。UVM常用类及树形结构_uvm树-CSDN博客 下边这张图展示了UVM常用的类之间的派生关系。可......
  • 01-flask简单介绍
    Flask是一个使用Python编写的轻量级Web应用框架,对比与Django框架呢,他的灵活度就很高了,可以自己一些设计代码框架。比较适合一些,分层比较少,逻辑不怎么复杂的web项目 pip安装pipinstallflask-ihttps://pypi.tuna.tsinghua.edu.cn/simple 简单实例fromflaskim......
  • 最简单的示例:通过JDBC查询数据
    引言在现代企业级应用开发中,持久层框架(如MyBatis、Hibernate等)极大地简化了数据库操作,提高了开发效率和代码的可维护性。本文将通过一个最简单的示例,演示如何使用JDBC连接数据库、执行SQL语句以及处理结果,并与Mybatis源码做对比,为后续深入研究MyBatis源码打下基础......
  • EGOI2024 简单题解
    Day1T1InfiniteRace由于只有重复超过一个人才肯定是跑过一圈的,所以只用用一个数组做标记就可以了,每超过一次就打上标记,否则去掉标记。T2Bouquet定义\(dp[i]\)为,以第\(i\)种郁金香结尾的选法中最大可选的郁金香数量,易得状态转移方程为:\(dp[i]=max{dep[j]}+1(j<l_i\le......
  • 关于结合faststream + python rq callback 进行job 状态标记的简单说明
    以前简单介绍过基于faststream+pythonrqcallback进行job状态标记,以下是结合源码说明下处理参考玩法代码实现faststream参考代码fromfaststream.redisimportRedisBroker fromfaststream.asgiimportAsgiFastStream,get,AsgiResponse fromty......
  • ReentrantLock 实现原理
    文章目录ReentrantLock基本使用可重入锁等待可中断设置超时时间公平锁条件变量ReentrantLock原理加锁流程解锁流程可重入锁原理可打断原理公平锁原理条件变量原理ReentrantLock基本使用在Java中,synchronized和ReentrantLock都是用于确保线程同步的锁,都属于......
  • 订单交易平台三(登录界面整个实现过程)阶段一(只实现简单的登录功能)
    1.在视图函数account进行写代码逻辑(需要了解django中form组件的知识、md5码加密、脚本的编写)1.1登录界面后端的编写"""在account.py文件"""fromdjango.shortcutsimportrender,redirectfromwebimportmodelsfromutils.encryptimportmd5#1.定义类fromd......
  • 基于json数据格式实现的简单数据库——jsonDB
    //基于json数据格式实现的简单数据库——jsonDB//https://www.cnblogs.com/cynchanpin/p/7068151.html//已在github上建立项目:https://github.com/ThinkerCodeChina/jsonDB/**+-----------------------------------------*jsonDB基于json数据格式构建的数据模型+--......
  • 《博德之门3》ac1st16.dll怎么安装,ac1st16dll简单解决方法
    针对《博德之门3》中遇到的ac1st16.dll文件问题,以下是详细的安装和简单解决方法:安装方法手动下载并安装:访问可靠的DLL文件下载网站(如DLL-files.com),在搜索框中输入“ac1st16.dll”并搜索。下载与您的Windows版本(32位或64位)相匹配的ac1st16.dll文件。将下载的文件复制到游......
  • 如何通过几个简单步骤创建博客
    搭建博客不仅可以表达自我和分享知识,还可以成为一种潜在的收入来源。如果你也对搭建博客感兴趣,下面的几个步骤将帮助你轻松入门。一、选择一个主题确定你的兴趣点:首先,你需要选择一个你感兴趣且擅长的领域。你悉的领域既能激发你的写作热情,还能吸引读者的注意。例如,旅游、美食、科技......