AQS原理

这个问题该怎么回答呢?
全部评论
公平锁,每次判断state为0时不能立即抢占,而是判断是否还有前置结点,也就是判断首节点后面是否还有结点排队等候,如果有通过cas入队。 非公平锁,新线程来了,不管有没有其他结点在排队先cas抢占,如果两次强锁失败,那么就进入到队列中,其实这和公平锁一样啦,需要排队。当没有新的线程抢占时,强锁也是按照队列先后顺序来抢的,类似公平锁。 非公平锁和公平锁 最大的区别就是新来的线程是不是插队抢占,如果它没抢到那后面就是老老实实排队,后面唤醒也要等前面的结点出队了才能唤醒,而且入队的结点可能存在饥饿。
47 回复 分享
发布于 2023-07-23 11:13 浙江
从clh开始讲,aqs是它的升级版避免cas空旋,其实就是clh fifo队列的升级版,首节点独占锁,后面的结点排序等候,状态state为0表示初始状态可以占有锁,state=1表示已有线程占有,大于1是重入锁,设置的state和入队都是通过cas保证原子操作。首节点结点状态为signal时释放锁将state置为0且唤醒后续结点,后续结点开始自旋判断state获取锁。大概讲这些就好了
18 回复 分享
发布于 2023-07-23 11:06 浙江
看一遍源码就知道了,有些工具确实该看一下
4 回复 分享
发布于 2023-07-22 17:03 广东
这个我会,源码我一行一行搞懂的
3 回复 分享
发布于 2023-08-04 11:16 广东
抽象队列同步器,见名知义。 维护一个state互斥变量来实现一个锁机制,然后并发线程cas去修改这个state,成功则上位成为当前持锁线程,失败则在双向链表里排队等待。队列同步由此而来。 然后了解一下锁重入,和线程唤醒即可。
2 回复 分享
发布于 2023-09-17 12:56 上海
是只要描述一下框架的思想,还是要深入到源码层面
2 回复 分享
发布于 2023-07-22 15:12 江西
这篇文章对AQS的理解提出了自己的看法: https://blog.csdn.net/m0_53157173/article/details/132325973?spm=1001.2014.3001.5501
1 回复 分享
发布于 2023-09-10 23:12 湖北
m
1 回复 分享
发布于 2023-08-19 23:44 陕西
https://www.zhihu.com/answer/3151995460😋哥们写的文章,没有写condition的队列,那个你得自己看一下
1 回复 分享
发布于 2023-08-17 15:29 陕西
state表示锁状态,通过cas实现状态更新,clh队列实现加锁失败后的阻塞唤醒机制
1 回复 分享
发布于 2023-08-13 16:36 安徽
m
1 回复 分享
发布于 2023-07-24 09:01 陕西
m
点赞 回复 分享
发布于 2023-09-14 23:46 江苏
我觉得就是从两个方面去讲 1.就是它的共享变量state(volatile修饰的)用于cas判断是否状态满足 2.就是从同步队列来进行讲 这个时候就要分为独占锁和共享锁来进行解释 独占锁是要判断是否前一个节点是否为头结点 如果是 则会尝试获取锁 否则 则进入自旋判断 如果是共享锁 则只需要判断state是否大于0即可 详情可以看看蓝色那本并发的书
点赞 回复 分享
发布于 2023-09-11 11:11 广东
m
点赞 回复 分享
发布于 2023-09-05 21:55 四川
mm
点赞 回复 分享
发布于 2023-07-24 09:04 陕西

相关推荐

01-09 00:38
门头沟学院 Java
一面: 1. RabbitMQ怎么保证消息的可靠性? 生产者这方面的这个回调是指什么回调?2. synchronized 的这个锁的加锁的方式?  锁住的范围有什么不同3. synchornized加锁的过程?4. 锁升级流程?5. synchronize 是一个公平锁吗?6. CAS会存在什么问题?怎么解决7. 介绍JVM常见的垃圾回收算法8. CMS 和 G1 回收器的区别是啥9. CMS 浮动垃圾问题?10. G1 是怎么做STW 时间预测的?11. MVCC 是怎么实现可重复读的?12. 介绍MySQL 里的 binlog, redolog, undolog13. 这个 redo log 和 redo log 在这个发生这个 crash 的时候,他们俩是怎么配合去恢复保证这个数据的一致性的?14. 平常用 Redis 的话主要是用在什么场景?用了缓存的话也没有遇到一些什么问题。15. 如何解决缓存DB一致性问题? 缓存删除失败了怎么办?16. 分布式事务常用的有哪些方法?手撕:二叉树的最小深度二面:1. 异步或者并发编程里面通常会出现这种可见性问题是什么原因导致的? 应该怎么解决?  除了volatile,还有什么其他方法解决可见性?(从Java内存模型角度回答   解决方法:volatile, 锁,原子类)2. 线程池它底层是如何去运行的?3. 线程池里的线程它把任务执行完之后,它接着干嘛?4. 场景题1:有一个银行转账,比方说a、b、 c 三个账户,每个账户都有 200 块钱,我 a 账户去给 b 账户转 100 块钱, b 账户给 c 账户转 100 块钱,然后他们同时去转账,我如何去保证他的账户数据安全或者正确?(事务 + 行锁写锁(select * from xx for update)  )5. mysql什么样的数据结构能够作为索引的存储结构?6. 什么场景我应该用 b+树?什么场景我应该 b 树?什么场景我应该用哈希。7. Mysql 的索引,它在什么场景下它会失效?8. 假如说我要把一个树状结构存储到 Mysql 数据库中,怎么去存呢?9. 假如说我有 1, 000 万个学生,对吧?嗯,学生有学号、姓名、年龄,我按年龄上加了一个二级索引,我再按年龄从小到大去排序,我要查询到第 900 万个学生怎么去查?10. HTTP状态码代表的含义11. Redis 的话怎么是去保证数据的可靠性的?RDB 的过程中它会阻塞主线程吗?12. Redis 持久化中,异步过程如果有新的数据写入,它是怎么处理的?13. 了解哪些限流算法吗?14. 实现一个限流工具要怎么去做?手撕: 三数之和
发面经攒人品
点赞 评论 收藏
分享
2025-12-21 13:10
门头沟学院 Java
1、Java面向对象具有封装、继承、多态三大核心特性。封装通过访问修饰符隐藏对象内部细节,仅暴露必要接口;继承允许子类复用父类属性和方法,实现代码复用和层次化扩展;多态分为编译时重载和运行时重写,使程序能够通过统一接口处理不同对象,提升灵活性和可扩展性。2、重载发生在同一类中,方法名相同但参数列表不同,与返回值和访问修饰符无关,编译时绑定;重写是子类覆盖父类方法,方法名、参数列表和返回类型必须相同,访问权限不能更严格,不能抛出新的检查异常,运行时动态绑定。3、线程池核心参数包括:核心线程数、最大线程数、空闲存活时间、时间单位、阻塞队列、线程工厂、拒绝策略。ThreadLocal底层使用ThreadLocalMap存储数据,其Key是弱引用的ThreadLocal对象,Value是强引用的实际存储值,每个线程独立拥有此Map实现数据隔离,需注意内存泄漏问题。4、使用线程池实现1~100累加时,首先创建固定大小的线程池,然后将累加任务拆分为多个子任务,通过线程池提交实现了Callable接口的每个子任务,收集返回的Future对象后,遍历这些Future并累加其阻塞获取的中间结果,最终关闭线程池并输出总和。整个过程利用线程池并行处理子任务,通过分治策略提升计算效率,同时确保资源合理回收。5、B+树非叶子节点仅存储键,叶子节点包含全部数据且形成有序链表。相比B树:1. 查询更稳定:所有数据都在叶子节点,查询路径长度一致;2. 范围查询高效:叶子节点链表直接遍历,无需回溯;3. 磁盘I/O更低:节点存储更多键,树更矮胖;4. 全表扫描更快:叶子节点链表顺序遍历即可。6、失效场景:1. 违反最左前缀原则;2. 对索引列使用函数或表达式;3. 类型隐式转换;4. 模糊查询以通配符开头;5. OR条件包含非索引列。优化方法:1. 按高频查询顺序建联合索引;2. 避免索引列运算;3. 用覆盖索引减少回表;4. 数据量大时用分区表;5. 定期分析索引使用率并删除冗余索引。7、通过EXPLAIN命令查看SQL执行计划,关注key字段显示使用的索引名,type字段为ref/range表示有效索引扫描;若为ALL则是全表扫描。额外检查Extra字段:Using index、Using filesort
点赞 评论 收藏
分享
2025-12-21 14:25
门头沟学院 Java
1. 布隆过滤器;缓存空结果;参数校验。2. 延迟双删;基于binlog监听;设置合理缓存过期时间兜底。3. RDB。AOF4. RDB更快。5. 单线程处理命令 + I/O多路复用。单线程避免锁竞争;I/O多路复用使单线程高效管理大量连接,仅当socket就绪时处理IO。6. 读未提交、读已提交、可重复读、串行化7. 可重复读。解决脏读、不可重复读;通过MVCC和间隙锁减少幻读发生。8. 默认 B+树。9. 红黑树的二叉搜索树,树高较高;范围查询需中序遍历效率低;节点存储利用率较低。 B+树的更矮胖;叶节点链表结构使范围查询/全表扫描极高效;节点存储更多键。10.使用二级索引查询时,若所需列不在该索引中,需根据索引中存储的主键值,回到聚集索引 树中查找完整行数据。额外磁盘IO是主要性能损耗。11.查询:连接器、查询缓存、分析器、优化器、执行器、返回结果。更新:额外涉及事务开启、写undo log、执行器调引擎修改内存数据、写redo log、写binlog、提交事务。12.更新:写undo/redo,改内存,写binlog,提交redo;两阶段提交。13.继承Thread类,实现Runnable接口,实现Callable接口,使用线程池提交任务。14.核心线程数、最大线程数、存活时间、时间单位、工作队列、线程工厂、拒绝策略。15.CountDownLatch要求子线程主动存结果到共享集合后countDown(),主线程await()阻塞等待;CyclicBarrier由线程在await()前存结果,最后到达的线程触发汇总;而线程池通过主线程收集Future并调用get()阻塞获取结果。16.start() 启动新线程,run()普通方法调用。17.数组+ 链表/红黑树。18.非线程安全。19.JDK8 ConcurrentHashMap:改用 synchronized 锁单个桶 + CAS + volatile,替代 JDK7 分段锁,并发度更高。20.MQ 消息可靠:依赖生产者可靠投递(含重试)、Broker 持久化与高可用、消费者手动 ACK 与幂等处理三方协同保障。21.消费者幂等性:通过唯一约束(如 DB/REDIS 记录消息 ID)防止重复处理,确保多次消费结果一致
点赞 评论 收藏
分享
评论
28
181
分享

创作者周榜

更多
牛客网
牛客网在线编程
牛客网题解
牛客企业服务