文章目录
- AQS概述
- AQS的本质:为啥叫做异步队列同步器
- AQS的核心机制
- “异步队列”的含义
- “同步器”的含义
- 总结
- 加锁失败的时候如何借助AQS异步入队阻塞等待
- AQS的锁队列
- 加锁失败时的处理流程
- 异步入队的机制
- 总结
- ReentractLock如何设置公平锁策略以及原理
- 设置公平锁策略
- 公平锁的运作原理
- 尝试获取锁
- 释放锁
- 性能与公平性的权衡
- tryLock如何实现加锁等待一段时间过后放弃
- tryLock的基本用法
- tryLock的实现原理
- 实现示例
- 总结
- ReentractLock底层如何实现
- 用第三个线程尝试加锁失败彻底图解AQS队列等待机制
- 场景设定
- Thread C尝试获取锁
- Thread C加入等待队列
- Thread C被阻塞
- 图解
- 总结
- AQS默认的非公平加锁策略的运作原理
- 非公平锁的运作原理
- 尝试获取锁
- 重新获取锁
- 等待队列中的线程
- 总结
- 服务注册中心的最近更新服务实例队列实现
- 设计思路
- 实现示例
- 注意事项
- 服务注册中心提供全量和增量拉取注册表的接口
- 全量拉取
- 实现思路：
- 示例代码（使用Spring Boot）：
- 增量拉取
- 实现思路：
- 示例代码（使用Spring Boot）：
- 注意事项
- 客户端实现启动时拉取全量注册表
- 步骤 1: 添加依赖
- 步骤 2: 创建配置类
- 步骤 3: 实现全量拉取逻辑
- 步骤 4: 在启动时执行全量拉取
- 注意事项
- 案例实战:客户端实现定时拉取增量注册表到本地合并
- 业务需求
- 使用AQS设计定时任务
- 实现步骤
- 代码示例
- 注意事项
- 案例实战:增量合并注册表后进行校验与全量纠正
- 业务需求
- AQS辅助设计
- 实现步骤
- 代码示例
- 注意事项
- AQS如何基于无锁化的CAS机制实现高性能的加锁
- CAS机制
- AQS中的CAS应用
- 获取锁
- 释放锁
- 无锁化的优势
- 如何巧妙的借助AQS中的state变量实现可重入式加锁
- 基于AQS实现的可重入锁释放过程的源码剖析
- 锁释放过后如何对AQS队列中唤醒阻塞线程尝试抢占锁
- AQS的唤醒机制
- 唤醒等待线程
- `unparkSuccessor`方法详解
- 尝试抢占锁
- 总结
- 一种新奇的加锁玩法:读锁和写锁分开是怎么玩的
- 读写锁的原理
- 使用场景
- Java中的读写锁实现
- 总结
- 读写锁中的写锁是如何基于AQS的state变量完成加锁的
- AQS的`state`变量
- 写锁加锁过程
- 代码示例
- 总结
- 基于AQS的state二进制高低16位判断实现写锁的可重入加锁
- `state`变量的位分配
- 写锁的可重入加锁
- 代码实现
- 总结
- 写锁加锁失败时如何基于AQS队列完成入队阻塞等待?
- 尝试获取写锁
- 加锁失败后的处理
- 加入AQS队列
- 阻塞线程
- 监听锁状态变化
- 队列中的线程唤醒
- 总结
- 读写锁互斥:基于AQS的state二进制高低16位完成互斥判断
- `state`变量的位分配
- 互斥判断
- 代码示例
- 互斥性的保证
- 总结
AQS_1">AQS概述
AQS，全称 AbstractQueuedSynchronizer，是 Java 并发包 java.util.concurrent.locks 中的一个抽象类，它为实现依赖于先进先出（FIFO）等待队列的阻塞锁和其他同步器提供了基础框架。AQS 是 Java 内置锁和大部分并发工具类（如 ReentrantLock, Semaphore, CountDownLatch 等）的基础，通过它我们可以理解 Java 高级并发工具的内部工作原理。
AQS__4">AQS 的核心概念
-
独占式与共享式同步：
- 独占式：一次只有一个线程可以获取同步状态，如 ReentrantLock。
- 共享式：多个线程可以同时获取同步状态，如 Semaphore。
-
状态管理：
- AQS 使用一个 int 成员变量来表示同步状态，通过内置的
Unsafe类的原子操作方法来修改这个状态，保证线程安全。
- AQS 使用一个 int 成员变量来表示同步状态，通过内置的
-
CLH 锁队列：
- CLH（Craig-Landin-Hagersten）队列是一种高性能的非阻塞队列，AQS 使用 CLH 锁队列来管理等待线程，当线程尝试获取锁而未能成功时，会被加入到队列中。
