位置: IT常识 - 正文

Java多线程(6):锁与AQS(中)

编辑:rootadmin
您好,我是湘王,这是我的博客园,欢迎您来,欢迎您再来~ Java中的AQS(AbstractQueuedSynchronizer,抽象队列同步器)是用来实现锁及其他同步功能组件的Java底层技术基础,java.util.concurrent包下大部分类的实现都离不开它。 通过继承AQS: 1、Ree ...

推荐整理分享Java多线程(6):锁与AQS(中),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:,内容如对您有帮助,希望把文章链接给更多的朋友!

您好,我是湘王,这是我的博客园,欢迎您来,欢迎您再来~

Java中的AQS(AbstractQueuedSynchronizer,抽象队列同步器)是用来实现锁及其他同步功能组件的Java底层技术基础,java.util.concurrent包下大部分类的实现都离不开它。

通过继承AQS:

1、ReentrantLock的内部类实现了公平锁和非公平锁;

2、CountDownLatch的内部类实现了发令枪;

3、ReentrantReadWriteLock的内部类实现了独享锁和共享锁;

4、Semaphore的内部类实现了公平锁和非公平锁。

AQS主要实现两大功能:独占(Exclusive,有时也叫排他)和共享(Share)。

AQS在内部维护一个FIFO(First In First Out,先进先出)的CLH(Craig,Landin,and Hagersten)线程阻塞队列和一个资源同步状态的变量volatile int state。

CLH是一个虚拟的双向队列,也就是不存在队列实例,仅存在节点之间的关联关系的队列。AQS是将每一条请求共享资源的线程,封装成一个CLH线程队列节点(Node),从而实现锁的分配。因此,说了一大堆,用一句简单的话来形容AQS就是:基于CLH线程阻塞队列,通过volatile变量 + CAS + 自旋方式来改变线程状态,成功则获取锁,失败则进入CLH队列。

Java多线程(6):锁与AQS(中)

AQS已经实现了CLH线程阻塞队列的维护,所以一般子类自定义实现AQS,要么是独占,要么是共享,也就是要么实现tryAcquire()和tryRelease()等系列方法,要么实现tryAcquireShared()和tryReleaseShared()等系列方法。

CLH队列由多个node节点组成,而且大量使用“CAS自旋volatile变量”这种经典代码:

CLH队列的结构为:

给CLH设置首节点:

给CLH设置尾节点:

整个AQS的流程如图:

AQS特别复杂,如果想把多线程搞透的,就需要深入研究每个方法的流程,拿acquire(int)方法的执行流程为例:

我把AQS的源码做了较为详细的注释,可以结合注释看看。例如:

/** * Provides a framework for implementing blocking locks and related * synchronizers (semaphores, events, etc) that rely on first-in-first-out * (FIFO) wait queues. 提供了一个实现阻塞锁和依赖FIFO的等待队列的相关的同步器(信号灯、事件等)框架 * * This class is designed to be a useful basis for most kinds of synchronizers * that rely on a single atomic {@code int} value to represent state. * 这个类对于大多数使用一个单独原子类的int值来表示状态的同步器很有用 * * Subclasses must define the protected methods that change this state, and * which define what that state means in terms of this object being acquired or * released. 子类必须定义protected方法来改变这个状态值,并且定义状态值是获取还是释放对象 * * Given these, the other methods in this class carry out all queuing and * blocking mechanics. 鉴于此,这个类中的其他方法实现了所有排队和阻塞的机制 * * Subclasses can maintain other state fields, but only the atomically updated * {@code int} value manipulated using methods {@link #getState}, * {@link #setState} and {@link #compareAndSetState} is tracked with respect to * synchronization. 子类可以维护其他的状态值字段,但只有getState、setState和compareAndSetState * 方法是通过原子更新来实现同步的 * * <p> * Subclasses should be defined as non-public internal helper classes that are * used to implement the synchronization properties of their enclosing class. * 子类应该定义成非public的内部helper工具类,用于实现其封闭类的同步属性 * * Class {@code AbstractQueuedSynchronizer} does not implement any * synchronization interface. AbstractQueuedSynchronizer类没有实现任何同步接口 * * Instead it defines methods such as {@link #acquireInterruptibly} that can be * invoked as appropriate by concrete locks and related synchronizers to * implement their public methods. * 取而代之的是,它定义了像acquireInterruptibly这样的方法,通过调用恰当的具体 锁和相关同步器方法,以便实现他们自己的公共方法 * * <p> * This class supports either or both a default <em>exclusive</em> mode and a * <em>shared</em> mode. 这个类既支持默认的独占模式,也支持共享模式,也支持两种模式一起实现 * * When acquired in exclusive mode, attempted acquires by other threads cannot * succeed. 当在独占模式获取到锁时,其他线程再尝试获取锁会失败 * * Shared mode acquires by multiple threads may (but need not) succeed. * 共享模式,多个线程都能成功获取到锁 * * This class does not understand these differences except in the mechanical * sense that when a shared mode acquire succeeds, the next waiting thread (if * one exists) must also determine whether it can acquire as well. * 这个类不会理解机制的不同,共享模式中的一个线程获取锁成功了,下一个线程 (如果存在)仍然会去确定它自己是否也可以获取 * * Threads waiting in the different modes share the same FIFO queue. * 线程虽在不同的模式中,却都在等待共享相同的FIFO队列 * * Usually, implementation subclasses support only one of these modes, but both * can come into play for example in a {@link ReadWriteLock}. * 通常,子类只需要实现这两种模式中的一种,但也能两种都实现,例如ReadWriteLock * * Subclasses that support only exclusive or only shared modes need not define * the methods supporting the unused mode. 仅支持一种模式的子类,不必定义另一种模式下的方法 * * <p> * This class defines a nested {@link ConditionObject} class that can be used as * a {@link Condition} implementation by subclasses supporting exclusive mode * for which method {@link#isHeldExclusively} reports whether synchronization is * exclusively held with respect to the current thread, method {@link #release} * invoked with the current {@link #getState} value fully releases this object, * and {@link #acquire}, given this saved state value, eventually restores this * object to its previous acquired state. * 这个类定义了一个嵌套的ConditionObject类,该类可以被支持独占模式的子类用作 * Condition实现,为此,isHeldExclusively()报告当前线程是否持续保持同步, * release方法通过调用getState来完全释放当前对象,并且将当前的资源状态 再保存到state中,最后会将此对象恢复为先前的获取状态 * * No {@code AbstractQueuedSynchronizer} method otherwise creates such a * condition, so if this constraint cannot be met, do not use it. * 没有AbstractQueuedSynchronizer方法去创建condition,因此如果不能满足 这个约束,就不要使用它 * * The behavior of {@link ConditionObject} depends of course on the semantics of * its synchronizer implementation. ConditionObject的行为依赖于其同步器实现的语义 * * <p> * This class provides inspection, instrumentation, and monitoring methods for * the internal queue, as well as similar methods for condition objects. * 这个类提供检查、追踪和监控内部队列的方法,类似于condition对象的方法 * * These can be exported as desired into classes using an * {@code AbstractQueuedSynchronizer} for their synchronization mechanics. * 可以根据需要使用AbstractQueuedSynchronizer,将它们导入到类中以实现其同步机制 * * <p> * Serialization of this class stores only the underlying atomic integer * maintaining state, so deserialized objects have empty thread queues. * 这个类仅序列化state的原子值,因此反序列化出来的对象中的线程队列是空的 * * Typical subclasses requiring serializability will define a {@code readObject} * method that restores this to a known initial state upon deserialization. * 需要序列化的子类可以在反序列化的时候定义一个readObject方法来恢复已知的初始状态 * * * <h3>Usage</h3> 使用 * * <p> * To use this class as the basis of a synchronizer, redefine the following * methods, as applicable, by inspecting and/or modifying the synchronization * state using {@link #getState}, {@link #setState} and/or * {@link #compareAndSetState}: 使用这个类作为同步器锁,需要重新定义以下方法: * * <ul> * <li>{@link #tryAcquire} * <li>{@link #tryRelease} * <li>{@link #tryAcquireShared} * <li>{@link #tryReleaseShared} * <li>{@link #isHeldExclusively} * </ul> * * Each of these methods by default throws * {@link UnsupportedOperationException}. * 这些方法默认抛出UnsupportedOperationException异常 * * Implementations of these methods must be internally thread-safe, and should * in general be short and not block. 这些方法的实现必须在内部是线程安全的,而且通常都很简短,没有阻塞 * * Defining these methods is the <em>only</em> supported means of using this * class. 定义这些方法是使用这个类唯一可行的方式 * * All other methods are declared {@code final} because they cannot be * independently varied. 所有其他的方法都被
本文链接地址:https://www.jiuchutong.com/zhishi/304134.html 转载请保留说明!

上一篇:phpcms如何更换模板(phpcms怎么用)

下一篇:帝国cms怎么替换网址域名(帝国cms怎么用)

  • 中国城市人口密度榜出炉,根据统计显示,人口密度高的城市主要集中在长三角、珠三角

    中国城市人口密度榜出炉,根据统计显示,人口密度高的城市主要集中在长三角、珠三角

  • 拒收后怎么让卖家退款(拒收要卖家同意吗)

    拒收后怎么让卖家退款(拒收要卖家同意吗)

  • 怎么打开cmd命令窗口(怎么打开cmd命令窗口快捷键)

    怎么打开cmd命令窗口(怎么打开cmd命令窗口快捷键)

  • 华为手机自检功能在哪(华为手机自检功能代码)

    华为手机自检功能在哪(华为手机自检功能代码)

  • airpods滴滴响(airpods滴滴响怎么关)

    airpods滴滴响(airpods滴滴响怎么关)

  • 苹果手机信号显示operator(苹果手机信号显示透明)

    苹果手机信号显示operator(苹果手机信号显示透明)

  • 爱奇艺绑定手机被占用(爱奇艺绑定手机号显示该手机号已被绑定)

    爱奇艺绑定手机被占用(爱奇艺绑定手机号显示该手机号已被绑定)

  • 开视频对方忙线中是什么意思(开视频对方忙线中对方会有提示吗?)

    开视频对方忙线中是什么意思(开视频对方忙线中对方会有提示吗?)

  • win7摄像头怎么调出来(win7摄像头怎么关闭)

    win7摄像头怎么调出来(win7摄像头怎么关闭)

  • 微信群二维码被盗原因(微信群二维码被屏蔽)

    微信群二维码被盗原因(微信群二维码被屏蔽)

  • 互联网和因特网的区别与联系(互联网和因特网的关系)

    互联网和因特网的区别与联系(互联网和因特网的关系)

  • 多媒体数据压缩类型(多媒体数据压缩采用的基本技术是)

    多媒体数据压缩类型(多媒体数据压缩采用的基本技术是)

  • 苹果乱扣费怎么办退款(iphone乱扣费怎么追回)

    苹果乱扣费怎么办退款(iphone乱扣费怎么追回)

  • xr怎么设置来电铃声(xr怎么设置来电不断网)

    xr怎么设置来电铃声(xr怎么设置来电不断网)

  • 苹果xsmax怎么设置指纹(苹果xsmax怎么设置悬浮球)

    苹果xsmax怎么设置指纹(苹果xsmax怎么设置悬浮球)

  • 蓝牙耳机共享联系人有啥用(蓝牙耳机共享联系人能关吗)

    蓝牙耳机共享联系人有啥用(蓝牙耳机共享联系人能关吗)

  • 苹果11打不出去电话(苹果11打不出去电话怎么回事)

    苹果11打不出去电话(苹果11打不出去电话怎么回事)

  • 拼多多销量怎么统计的(拼多多销量怎么计算)

    拼多多销量怎么统计的(拼多多销量怎么计算)

  • rename文件怎么安装(rename文件怎么安装苹果11)

    rename文件怎么安装(rename文件怎么安装苹果11)

  • 转转如何收款(转转的收款方式在哪里)

    转转如何收款(转转的收款方式在哪里)

  • 同一个苹果id怎么不共享通话记录(同一个苹果id怎么改锁屏密码)

    同一个苹果id怎么不共享通话记录(同一个苹果id怎么改锁屏密码)

  • 详解Linux系统中crontab命令处理定时任务的用法(linux c gui)

    详解Linux系统中crontab命令处理定时任务的用法(linux c gui)

  • Vue获取DOM元素并修改属性的方法(vue获取dom元素的方法)

    Vue获取DOM元素并修改属性的方法(vue获取dom元素的方法)

  • 即征即退需要缴纳税款吗
  • 企业如何代扣代缴个人所得税20%
  • 包装物押金计入成本吗
  • 没有收入也可以信用贷
  • 销售商品,提供服务以及从事其他经营活动
  • 政府补助具有无偿性的特征
  • 长期股权投资收益会计处理
  • 支付稿费演出费用怎么算
  • 其他货币资金存出投资款什么时候用
  • 未分配利润转增股本需要缴纳企业所得税吗
  • 净利润为负数还要交所得税吗
  • 实收资本未实缴到位,是否缴纳印花税
  • 道路施工企业的财务核算包括
  • 退税后钱到哪里
  • 拿票报销的交通费要交个人所得税吗
  • 苗木增值税发票税率
  • 商铺租金收入税是多少税率
  • 自然人办税服务平台怎么登录和注册
  • 结转成本计算方法
  • 分期付款融资账务处理
  • 投资款缴纳印花税税目是什么
  • 营业外支出怎么冲减
  • 延期申报出口退税流程
  • 雇主责任保险
  • 个人所得税应纳税额计算表图片
  • 工信部推出一键解绑怎么用
  • 开机进入睡眠模式按哪个键解除
  • 分期服务费是啥
  • 明股实债和明债实股
  • 怎么获取win10密钥
  • 招商银行直播在哪个平台
  • ServiceLayer.exe - ServiceLayer是什么进程 有什么用
  • 施工机械保险费属于什么费用
  • 买支票需要带什么章
  • 企业所得税如何更正申报
  • 浅谈php技术
  • 中秋快乐图片大全
  • thinkphp5框架介绍
  • 增值税专用发票有几联?
  • 委托开发和购买开发
  • ICLR2023《Crossformer: Transformer Utilizing Cross-Dimension Dependency for Multivariate Time Series》
  • 《设计模式》
  • 2021年车辆检测
  • 美国人用什么英语词典
  • mongodb4.4.2安装教程
  • 公司车辆固定资产管理办法
  • mysql 表不存在报错信息
  • 营改增有关事项的规定
  • 本月冲红上月发票后的税款能抵减吗
  • 税后利润分配还要交税
  • 收取物业费不开发票
  • 科技专项资金的考核指标确需调整
  • 资本性支出是什么活动
  • 预付卡发票如何做分录
  • 小规模纳税人购进税控收款机
  • 没有发票的费用支出怎么入账
  • 本票丢了别人可以取钱吗
  • 个体工商户是否要交税
  • mysql数据库性能监控
  • window8开机
  • 在基于Xen的CentOS系统VPS上配置PPTP VPN的教程
  • solaris 11.4
  • win10edge浏览器如何切换到ie
  • xp系统怎么删除应用程序
  • linux命令nano
  • centos8 php7.4
  • xp系统停止服务了还能用吗
  • 为什么没有win8系统
  • Unity符国新:3D技术将渗透到生活的各个方面
  • linux修改目录路径
  • angularjs1.5
  • JavaScript中的数据类型分哪为两大类?
  • 客户端脚本错误怎么解决
  • javascript面向对象编程指南第三版
  • 税务经侦科立案标准
  • 123600是税务电话吗
  • 国家税务总局监控的重点税源纳税人的标准是
  • 手撕发票查询真伪平台
  • 回迁房需要交契税吗
  • 信用体系建设
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设