死磕 java同步系列之AQS起篇
问题
(1)AQS是什么?
(2)AQS的定位?
(3)AQS的实现原理?
(4)基于AQS实现自己的锁?
简介
AQS的全称是AbstractQueuedSynchronizer,它的定位是为Java中几乎所有的锁和同步器提供一个基础框架。
AQS是基于FIFO的队列实现的,并且内部维护了一个状态变量state,通过原子更新这个状态变量state即可以实现加锁解锁操作。
本章及后续章节的内容理解起来可能会比较晦涩,建议先阅读彤哥上一章的内容【死磕 java同步系列之自己动手写一个锁Lock】。
核心源码
主要内部类
static final class Node {// 标识一个节点是共享模式static final Node SHARED = new Node();// 标识一个节点是互斥模式static final Node EXCLUSIVE = null;// 标识线程已取消static final int CANCELLED = 1;// 标识后继节点需要唤醒static final int SIGNAL = -1;// 标识线程等待在一个条件上static final int CONDITION = -2;// 标识后面的共享锁需要无条件的传播(共享锁需要连续唤醒读的线程)static final int PROPAGATE = -3;// 当前节点保存的线程对应的等待状态volatile int waitStatus;// 前一个节点volatile Node prev;// 后一个节点volatile Node next;// 当前节点保存的线程volatile Thread thread;// 下一个等待在条件上的节点(Condition锁时使用)Node nextWaiter;// 是否是共享模式final boolean isShared() {return nextWaiter == SHARED;}// 获取前一个节点final Node predecessor() throws NullPointerException {Node p = prev;if (p == null)throw new NullPointerException();elsereturn p;}// 节点的构造方法Node() { // Used to establish initial head or SHARED marker}// 节点的构造方法Node(Thread thread, Node mode) { // Used by addWaiter// 把共享模式还是互斥模式存储到nextWaiter这个字段里面了this.nextWaiter = mode;this.thread = thread;}// 节点的构造方法Node(Thread thread, int waitStatus) { // Used by Condition// 等待的状态,在Condition中使用this.waitStatus = waitStatus;this.thread = thread;}
}
典型的双链表结构,节点中保存着当前线程、前一个节点、后一个节点以及线程的状态等信息。
主要属性
// 队列的头节点
private transient volatile Node head;
// 队列的尾节点
private transient volatile Node tail;
// 控制加锁解锁的状态变量
private volatile int state;
定义了一个状态变量和一个队列,状态变量用来控制加锁解锁,队列用来放置等待的线程。
注意,这几个变量都要使用volatile关键字来修饰,因为是在多线程环境下操作,要保证它们的值修改之后对其它线程立即可见。
这几个变量的修改是直接使用的Unsafe这个类来操作的:
// 获取Unsafe类的实例,注意这种方式仅限于jdk自己使用,普通用户是无法这样调用的
private static final Unsafe unsafe = Unsafe.getUnsafe();
// 状态变量state的偏移量
private static final long stateOffset;
// 头节点的偏移量
private static final long headOffset;
// 尾节点的偏移量
private static final long tailOffset;
// 等待状态的偏移量(Node的属性)
private static final long waitStatusOffset;
// 下一个节点的偏移量(Node的属性)
private static final long nextOffset;static {try {// 获取state的偏移量stateOffset = unsafe.objectFieldOffset(AbstractQueuedSynchronizer.class.getDeclaredField("state"));// 获取head的偏移量headOffset = unsafe.objectFieldOffset(AbstractQueuedSynchronizer.class.getDeclaredField("head"));// 获取tail的偏移量tailOffset = unsafe.objectFieldOffset(AbstractQueuedSynchronizer.class.getDeclaredField("tail"));// 获取waitStatus的偏移量waitStatusOffset = unsafe.objectFieldOffset(Node.class.getDeclaredField("waitStatus"));// 获取next的偏移量nextOffset = unsafe.objectFieldOffset(Node.class.getDeclaredField("next"));} catch (Exception ex) { throw new Error(ex); }
}// 调用Unsafe的方法原子更新state
protected final boolean compareAndSetState(int expect, int update) {return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
}
关于Unsafe类的讲解请参考彤哥之前写的【死磕 java魔法类之Unsafe解析】。
子类需要实现的主要方法
我们可以看到AQS的全称是AbstractQueuedSynchronizer,它本质上是一个抽象类,说明它本质上应该是需要子类来实现的,那么子类实现一个同步器需要实现哪些方法呢?
// 互斥模式下使用:尝试获取锁
protected boolean tryAcquire(int arg) {throw new UnsupportedOperationException();
}
// 互斥模式下使用:尝试释放锁
protected boolean tryRelease(int arg) {throw new UnsupportedOperationException();
}
// 共享模式下使用:尝试获取锁
protected int tryAcquireShared(int arg) {throw new UnsupportedOperationException();
}
// 共享模式下使用:尝试释放锁
protected boolean tryReleaseShared(int arg) {throw new UnsupportedOperationException();
}
// 如果当前线程独占着锁,返回true
protected boolean isHeldExclusively() {throw new UnsupportedOperationException();
}
问题:这几个方法为什么不直接定义成抽象方法呢?
因为子类只要实现这几个方法中的一部分就可以实现一个同步器了,所以不需要定义成抽象方法。
下面我们通过一个案例来介绍AQS中的部分方法。
基于AQS自己动手写一个锁
直接上代码:
public class MyLockBaseOnAqs {// 定义一个同步器,实现AQS类private static class Sync extends AbstractQueuedSynchronizer {// 实现tryAcquire(acquires)方法@Overridepublic boolean tryAcquire(int acquires) {if (compareAndSetState(0, 1)) {setExclusiveOwnerThread(Thread.currentThread());return true;}return false;}// 实现tryRelease(releases)方法@Overrideprotected boolean tryRelease(int releases) {setExclusiveOwnerThread(null);setState(0);return true;}}// 声明同步器private final Sync sync = new Sync();// 加锁public void lock() {sync.acquire(1);}// 解锁public void unlock() {sync.release(1);}private static int count = 0;public static void main(String[] args) throws InterruptedException {MyLockBaseOnAqs lock = new MyLockBaseOnAqs();CountDownLatch countDownLatch = new CountDownLatch(1000);IntStream.range(0, 1000).forEach(i -> new Thread(() -> {lock.lock();try {IntStream.range(0, 10000).forEach(j -> {count++;});} finally {lock.unlock();}
// System.out.println(Thread.currentThread().getName());countDownLatch.countDown();}, "tt-" + i).start());countDownLatch.await();System.out.println(count);}
}
运行main()方法总是打印出10000000(一千万),说明这个锁也是可以直接使用的,当然这也是一个不可重入的锁。
是不是很简单,只需要简单地实现AQS的两个方法就完成了上一章彤哥自己动手实现的锁的功能。
它是怎么实现的呢?
我们这一章先不讲源码,后面学习了ReentrantLock自然就明白了。
总结
这一章就到此结束了,本篇没有去深入的解析AQS的源码,笔者认为这没有必要,因为对于从来都没有看过锁相关的源码的同学来说,一上来就讲AQS的源码肯定会一脸懵逼的,具体的源码我们穿插在后面的锁和同步器的部分来学习,等所有跟AQS相关的源码学习完毕了,再来一篇总结。
下面总结一下这一章的主要内容:
(1)AQS是Java中几乎所有锁和同步器的一个基础框架,这里说的是“几乎”,因为有极个别确实没有通过AQS来实现;
(2)AQS中维护了一个队列,这个队列使用双链表实现,用于保存等待锁排队的线程;
(3)AQS中维护了一个状态变量,控制这个状态变量就可以实现加锁解锁操作了;
(4)基于AQS自己动手写一个锁非常简单,只需要实现AQS的几个方法即可。
彩蛋
上一章彤哥自己动手写的锁,其实可以看成是AQS的一个缩影,看懂了那个基本上AQS可以看懂一半了,因为彤哥那个里面没有写Condition相关的内容,下一章ReentrantLock重入锁中我们将一起学习Condition相关的内容。
所以呢,还是建议大家去看看这篇文章,点击下面的推荐阅读可以直达。
推荐阅读
死磕 java同步系列之自己动手写一个锁Lock
死磕 java魔法类之Unsafe解析
死磕 java同步系列之JMM(Java Memory Model)
死磕 java同步系列之volatile解析
- 死磕 java同步系列之synchronized解析
欢迎关注我的公众号“彤哥读源码”,查看更多源码系列文章, 与彤哥一起畅游源码的海洋。
转载于:https://blog.51cto.com/14267003/2400411
死磕 java同步系列之AQS起篇相关推荐
- 死磕java_死磕 java同步系列之AQS终篇(面试)
问题 (1)AQS的定位? (2)AQS的重要组成部分? (3)AQS运用的设计模式? (4)AQS的总体流程? 简介 AQS的全称是AbstractQueuedSynchronizer,它的定位是为 ...
- 死磕java_死磕 java同步系列之AQS起篇
问题 (1)AQS是什么? (2)AQS的定位? (3)AQS的实现原理? (4)基于AQS实现自己的锁? 简介 AQS的全称是AbstractQueuedSynchronizer,它的定位是为Jav ...
- 死磕 java同步系列之ReentrantReadWriteLock源码解析
问题 (1)读写锁是什么? (2)读写锁具有哪些特性? (3)ReentrantReadWriteLock是怎么实现读写锁的? (4)如何使用ReentrantReadWriteLock实现高效安全的 ...
- 死磕 java同步系列之redis分布式锁进化史
问题 (1)redis如何实现分布式锁? (2)redis分布式锁有哪些优点? (3)redis分布式锁有哪些缺点? (4)redis实现分布式锁有没有现成的轮子可以使用? 简介 Redis(全称:R ...
- 死磕 java同步系列之终结篇
简介 同步系列到此就结束了,本篇文章对同步系列做一个总结. 脑图 下面是关于同步系列的一份脑图,列举了主要的知识点和问题点,看过本系列文章的同学可以根据脑图自行回顾所学的内容,也可以作为面试前的准备. ...
- java 同步锁_死磕 java同步系列之自己动手写一个锁Lock
问题 (1)自己动手写一个锁需要哪些知识? (2)自己动手写一个锁到底有多简单? (3)自己能不能写出来一个完美的锁? 简介 本篇文章的目标一是自己动手写一个锁,这个锁的功能很简单,能进行正常的加锁. ...
- 死磕 java同步系列之开篇
简介 同步系列,这是彤哥想了好久的名字,本来是准备写锁相关的内容,但是java中的CountDownLatch.Semaphore.CyclicBarrier这些类又不属于锁,它们和锁又有很多共同点, ...
- 2019死磕java面试题_死磕 java同步系列之开篇
简介 同步系列,这是彤哥想了好久的名字,本来是准备写锁相关的内容,但是java中的CountDownLatch.Semaphore.CyclicBarrier这些类又不属于锁,它们和锁又有很多共同点, ...
- java condition_死磕 java同步系列之ReentrantLock源码解析(二)
(手机横屏看源码更方便) 问题 (1)条件锁是什么? (2)条件锁适用于什么场景? (3)条件锁的await()是在其它线程signal()的时候唤醒的吗? 简介 条件锁,是指在获取锁之后发现当前业务 ...
最新文章
- python培训班有用吗-比起自学Python,参加Python培训班有什么优势?
- PyTorch 实现 VAE 变分自编码器 含代码
- DirectX 3D相关资源参考
- 2016年第七届蓝桥杯 - 省赛 - C/C++大学A组 - I. 密码脱落
- php-fpm进程利用CPU不均问题的优化过程
- oracle 行数大于一时,oracle – PL / SQL ORA-01422:精确的提取返回超过请求的行数
- [读书笔记]读《Effective Objective-C 2.0编写高质量iOS与OS X代码的52个有效方法》(一)...
- LDA模型,主题聚类模型
- lane是什么意思_Lane_英文名Lane是什么意思
- 也谈阻塞、非阻塞、同步、异步
- 当程序员这么多年,我学到了25条人生经验
- java中feli删除操作_Feli的生日礼物
- 万字长文,详述TRIDENT: Poseidon 哈希算法的硬件加速与实现!
- Python_Day06_1 - 字典
- first-child、last-child、nth-child( )失效问题
- 【实用工具】鼠标连点器
- 诺基亚e72微信怎么一直显示服务器繁忙啊,诺基亚E72微信自动关闭的解决办法
- 路由器停产,360的其他硬件产品是否安好?
- 怎样恢复u盘里删除的文件
- 系统分析与设计HW1
热门文章
- L3-016 二叉搜索树的结构 (30 分)-PAT 团体程序设计天梯赛 GPLT
- L1-062 幸运彩票 (15 分)-PAT 团体程序设计天梯赛 GPLT
- LaTeX公式打出U上面一个小圈表示去心领域的符号:\mathring{U}
- 第七届 蓝桥杯 省赛 第七题 剪邮票
- Oracle数据库间的数据复制 - SQLPlus中的COPY命令
- 使用Eclipse将项目上传至远程GitLab
- “价值互联网”时代,带你读懂区块链
- Android--Activity的跳转及Activity之间的数据传递
- hdu 5443 The Water Problem 线段树
- 适用于 Windows PowerShell 的 SMS Cmdlet