Java源码阅读之ReentrantLock - lockInterruptibly和tryLock方法

简介: 阅读优秀的源码是提升编程技巧的重要手段之一。如有不对的地方,欢迎指正转载请注明出处https://blog.lzoro.com。碎碎念上一篇博客阅读了Java的ReentrantLock的lock和unlock,这篇分析另外三个方法lockInterruptibly、tryLock()和tryLock(long time, TimeUnit unit) throws InterruptedException;嗯,闲话少说,开工。

阅读优秀的源码是提升编程技巧的重要手段之一。
如有不对的地方,欢迎指正
转载请注明出处https://blog.lzoro.com

碎碎念

上一篇博客阅读了Java的ReentrantLocklockunlock,这篇分析另外三个方法lockInterruptiblytryLock()tryLock(long time, TimeUnit unit) throws InterruptedException;

嗯,闲话少说,开工。

lockInterruptibly

顾名思义,这是一个可中断的获取锁方法。

方法的描述如下:
请求锁,除非当前线程被中断。

如果没有其他线程持有锁,则当前线程获取到锁,并为锁计数加1,并且立即返回。
如果当前线程已经持有锁,则为锁计数加1,并立即返回。
如果其他线程持有锁,则当前线程将处于不可用状态以达到于线程调度目的,并且休眠直到下面两个事件中的一个发生:
①、当前线程获取到锁
②、其他线程中断当前线程

如果当前线程获取到锁,则将锁计数设置为1。
如果当前线程在方法条目上设置了中断状态或者在请求锁的时候被中断,将抛出中断异常。

阅读 Continue

public void lockInterruptibly() throws InterruptedException {
    sync.acquireInterruptibly(1);
}

从源码可以看出,实现还是依赖于内部类SyncacquireInterruptibly方法是Sync的父类AbstractQueuedSynchronizer-AQS提供的,我们主要还是以NonFairSync实现为主进行阅读。

继续,可以看到方法内部有两个if判断,第一个是判断线程的中断标识,如果为true,则抛出中断异常。

另外一个if,则是去尝试获取锁,并判断获取结果,如果获取失败,则执行doAcquireInterruptibly

①
public final void acquireInterruptibly(int arg)
        throws InterruptedException {
    if (Thread.interrupted())
        throw new InterruptedException();
    if (!tryAcquire(arg))
        doAcquireInterruptibly(arg);
}

②
protected final boolean tryAcquire(int acquires) {
    return nonfairTryAcquire(acquires);
}

这里的tryAcquire方法目的是尝试获取锁,与上一篇博客里提到的是一致的,这里不再赘述,直接看tryAcquire失败后执行的doAcquireInterruptibly

private void doAcquireInterruptibly(int arg)
        throws InterruptedException {
    //将当前线程添加等CLH等待队列
    final Node node = addWaiter(Node.EXCLUSIVE);
    //初始化失败标志
    boolean failed = true;
    try {
        //利用循环/自旋来请求锁
        for (;;) {
            //获取前置节点
            final Node p = node.predecessor();
            //如果前置节点为首节点,并且当前线程能够成功获取锁
            if (p == head && tryAcquire(arg)) {
                //将当前节点设置为首节点
                setHead(node);
                p.next = null; // help GC 前首节点出队,帮助GC 
                failed = false;
                return;
            }
            //判断是否可以阻塞线程并做相应操作
            if (shouldParkAfterFailedAcquire(p, node) &&
                parkAndCheckInterrupt())
                //抛出中断异常
                throw new InterruptedException();
        }
    } finally {
        if (failed)
            cancelAcquire(node);
    }
}

基本上可以看出,跟之前分析的acquireQueued方法是相似的。将当前线程加入CLH的等待队列后,进行循环/自旋获取锁,未获取成功则判断是否可以阻塞并做相关操作。

具体的shouldParkAfterFailedAcquireparkAndCheckInterrupt请参照上一篇,此处不再赘述。

到这里lockInterruptibly告一段落。

tryLock()

该方法也是获取锁的一种,与locklockInterruptible不同的是,tryLock()方法会立即返回结果,如果锁可用并且当前线程能够成功获取的话,直接返回true,否则返回false。

下面具体看下ReentrantLock是怎么实现的

public boolean tryLock() {
    return sync.nonfairTryAcquire(1);
}

还是Sync提供实现

final boolean nonfairTryAcquire(int acquires) {
    //获取当前线程
    final Thread current = Thread.currentThread();
    //获取锁状态
    int c = getState();
    //如果锁未被其他线程持有
    if (c == 0) {
        //CAS操作设置锁状态
        if (compareAndSetState(0, acquires)) {
            //成功后设置当前线程未锁独占线程,并返回true
            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);
        //返回true
        return true;
    }
    //如果锁被其他线程持有,返回false
    return false;
}

tryLcok是立即返回结果的获取锁方式,相比之前提到的几种自旋方式,它只进行一次获取锁的尝试,成功则返回true,失败则返回false,如果场景要求只进行一次尝试,则可以采用此方法。

tryLock(long time, TimeUnit unit)

为了标题简洁,未将异常声明加上,完整的方法定义是boolean tryLock(long time, TimeUnit unit) throws InterruptedException;该方法可能抛出中断异常。

方法描述如下:
在给定的等待时间内并且线程没有被中断以及锁可用的情况下,去获取锁。
如果锁可用,方法会直接返回。
如果锁不可用,则当前线程将会处于不可用状态以达到线程调度目的,并且休眠直到下面三个事件中的一个发生:
①、当前线程获取到锁
②、其他线程中断当前线程
③、指定的等待时间已过
假如当前线程:
在该方法的条目上设置其中断状态或在获取锁时中断,并且支持锁获取中断时,将抛出中断异常,当前线程中断状态会被清除。
假如给定的等待时间已过,将会返回false。

下面具体阅读源码实现,方法的入参指定了等待时间,和时间的单位,有NANOSECONDSMICROSECONDSMILLISECONDSSECONDS...等单位。

public boolean tryLock(long timeout, TimeUnit unit)
        throws InterruptedException {
    return sync.tryAcquireNanos(1, unit.toNanos(timeout));
}

方法的内部调用了SynctryAcquireNanos,继续往下

public final boolean tryAcquireNanos(int arg, long nanosTimeout)
        throws InterruptedException {
    //判断中断状态并决定是否抛出中断异常
    if (Thread.interrupted())
        throw new InterruptedException();
    //尝试获取锁,如果成功则返回true,失败则调用doAcquireNanos进行等待
    return tryAcquire(arg) ||
        doAcquireNanos(arg, nanosTimeout);
}

tryAcqure和之前分析的是同一个方法,不再赘述。
接下来是doAcquireNanos方法

private boolean doAcquireNanos(int arg, long nanosTimeout)
            throws InterruptedException {
    //如果给定的时间值小于等于0,则直接返回false
    if (nanosTimeout <= 0L)
        return false;
    //根据给定参数计算截止时间
    final long deadline = System.nanoTime() + nanosTimeout;
    //将当前线程添加到CLH等待队列
    final Node node = addWaiter(Node.EXCLUSIVE);
    //初始失败标志
    boolean failed = true;
    try {
        //在给定时间内循环/自旋尝试获取锁
        for (;;) {
            //取出前置节点
            final Node p = node.predecessor();
            //如果前置节点为首节点,并且当前线程能够成功获取锁
            if (p == head && tryAcquire(arg)) {
                setHead(node);
                p.next = null; // help GC 前首节点出队,帮助GC
                failed = false;
                return true;
            }
            //判断是否等待超时,如果超时,则返回false
            nanosTimeout = deadline - System.nanoTime();
            if (nanosTimeout <= 0L)
                return false;
            //这里判断是否可以阻塞线程并做相应操作,跟之前分析的几个方法不一样的是,这里的阻塞多了一个判断,并且是在有限时间内阻塞,类似于sleep
            if (shouldParkAfterFailedAcquire(p, node) &&
                nanosTimeout > spinForTimeoutThreshold)
                LockSupport.parkNanos(this, nanosTimeout);
            //判断中断状态,并决定是否抛出异常
            if (Thread.interrupted())
                throw new InterruptedException();
        }
    } finally {
        if (failed)
            cancelAcquire(node);
    }
}

从上面我们可以看出doAcquireNanosdoAcquireInterruptibly以及上一篇博客提到的acquireQueued的都有相似点,都是有自旋等待,以及阻塞判断和阻塞操作,不同的是,doAcquireNanos的阻塞是有时间限制的,所以能在给定的时间内,返回获取锁的操作结果。

总结

lockInterruptibly是可中断的获取锁方式。

tryLock()是立即返回获取结果的获取锁方式。

tryLock(long time, TimeUnit unit)是在给定时间内,尝试获取锁的方式。

好了,告一段落。

源码也看了不少,之前写的解析也都没有整理到博客,现在终于是能抽出点时间动动手了。

如果对你有哪怕一丢丢帮助,不妨给个赞呗,溜了溜了。

我的博客即将搬运同步至腾讯云+社区,邀请大家一同入驻:https://cloud.tencent.com/developer/support-plan?invite_code=24hvoorha868k

目录
相关文章
|
8天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
32 2
|
2天前
|
数据采集 人工智能 Java
Java产科专科电子病历系统源码
产科专科电子病历系统,全结构化设计,实现产科专科电子病历与院内HIS、LIS、PACS信息系统、区域妇幼信息平台的三级互联互通,系统由门诊系统、住院系统、数据统计模块三部分组成,它管理了孕妇从怀孕开始到生产结束42天一系列医院保健服务信息。
13 4
|
13天前
|
人工智能 监控 数据可视化
Java智慧工地信息管理平台源码 智慧工地信息化解决方案SaaS源码 支持二次开发
智慧工地系统是依托物联网、互联网、AI、可视化建立的大数据管理平台,是一种全新的管理模式,能够实现劳务管理、安全施工、绿色施工的智能化和互联网化。围绕施工现场管理的人、机、料、法、环五大维度,以及施工过程管理的进度、质量、安全三大体系为基础应用,实现全面高效的工程管理需求,满足工地多角色、多视角的有效监管,实现工程建设管理的降本增效,为监管平台提供数据支撑。
30 3
|
16天前
|
存储 Java 程序员
Java基础的灵魂——Object类方法详解(社招面试不踩坑)
本文介绍了Java中`Object`类的几个重要方法,包括`toString`、`equals`、`hashCode`、`finalize`、`clone`、`getClass`、`notify`和`wait`。这些方法是面试中的常考点,掌握它们有助于理解Java对象的行为和实现多线程编程。作者通过具体示例和应用场景,详细解析了每个方法的作用和重写技巧,帮助读者更好地应对面试和技术开发。
55 4
|
26天前
|
Java API
Java 对象释放与 finalize 方法
关于 Java 对象释放的疑惑解答,以及 finalize 方法的相关知识。
45 17
|
18天前
|
运维 自然语言处理 供应链
Java云HIS医院管理系统源码 病案管理、医保业务、门诊、住院、电子病历编辑器
通过门诊的申请,或者直接住院登记,通过”护士工作站“分配患者,完成后,进入医生患者列表,医生对应开具”长期医嘱“和”临时医嘱“,并在电子病历中,记录病情。病人出院时,停止长期医嘱,开具出院医嘱。进入出院审核,审核医嘱与住院通过后,病人结清缴费,完成出院。
55 3
|
20天前
|
Java 测试技术 Maven
Java一分钟之-PowerMock:静态方法与私有方法测试
通过本文的详细介绍,您可以使用PowerMock轻松地测试Java代码中的静态方法和私有方法。PowerMock通过扩展Mockito,提供了强大的功能,帮助开发者在复杂的测试场景中保持高效和准确的单元测试。希望本文对您的Java单元测试有所帮助。
49 2
|
23天前
|
JavaScript Java 项目管理
Java毕设学习 基于SpringBoot + Vue 的医院管理系统 持续给大家寻找Java毕设学习项目(附源码)
基于SpringBoot + Vue的医院管理系统,涵盖医院、患者、挂号、药物、检查、病床、排班管理和数据分析等功能。开发工具为IDEA和HBuilder X,环境需配置jdk8、Node.js14、MySQL8。文末提供源码下载链接。
|
28天前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
19 3
|
26天前
|
移动开发 前端开发 JavaScript
java家政系统成品源码的关键特点和技术应用
家政系统成品源码是已开发完成的家政服务管理软件,支持用户注册、登录、管理个人资料,家政人员信息管理,服务项目分类,订单与预约管理,支付集成,评价与反馈,地图定位等功能。适用于各种规模的家政服务公司,采用uniapp、SpringBoot、MySQL等技术栈,确保高效管理和优质用户体验。