java并发编程-AQS
1.什么是AQS
AQSjava.util.concurrent.locks.AbstractQueuedSynchronizer
抽象队列同步器 ,是用来构建锁或者其他同步组件的基础框架。它使用了一个 int 成员变量表示同步状态,通过内置的 FIFO(先进先出) 队列来完成资源获取线程的排队工作。
使用AQS能简单且高效地构造出应用广泛的大量的同步器,比如我们经常用到的ReentrantLock,Semaphore,其他的诸如ReentrantReadWriteLock,SynchronousQueue,FutureTask等等皆是基于AQS的。
AQS 自身没有实现任何同步接口,它仅仅是定义了若干同步状态获取和释放的方法来自定义同步组件使用,同步器既可以支持独占式地获取同步状态,也可以支持共享式地获取同步状态,这样就可以方便实现不同类型的同步组件。
AQS的设计基于模板方法模式。模板方法模式的意图是,定义一个操作中的算法的骨架,而将一些步骤的实现延迟到子类中。模板方法使得子类可以不改变一个算法的结构即可重定义该算法的某些特定步骤。
2.修改同步状态的方法
AQS 的主要使用方式是继承,子类通过继承 AQS 并实现它的抽象方法来管理同步状态,在 AQS 里由一个 int 型的 state 来代表这个状态,在抽象方法的实现过程中免不了要对同步状态进行更改,重写同步器指定的方法时,需要使用同步器提供的如下 3 个方法来访问或修改同步状态:
getState()
获取当前同步状态
setState(intnewState)
设置当前同步状态。
compareAndSetState(int expect,int update)
使用 CAS 设置当前状态,该方法能够保证状态设置的原子性。
3.模板方法
void acquire(int arg)
独占锁获取同步状态,如果当前线程获取同步状态成功,则由该方法返回。否则,将会进入同步队列等待,该方法会调用重写的 tryAcquire(int arg)
。
void acquireInterruptibly(int arg)
与acquire(int arg)
相同,但是该方法响应中断,当前线程为获取到同步状态而进入同步队列中,如果当前线程被中断,则该方法会抛出InterruptedException并返回。
boolean tryAcquireNanos(int arg, long nanosTimeout)
在acquireInterruptibly(int arg)
基础上增加了超时限制,如果当前线程在超时时间内没有获取到同步状态,那么将返回false,如果获取到了返回true。
void acquireShared(int arg)
共享式的获取同步状态,如果当前线程未获取到同步状态,将会进入同步队里等待,与独占式获取的主要区别是在同一时刻可以有多个线程获取到同步状态。
void acquireSharedInterruptibly(int arg)
与acquireShared(int arg)
相同,该方法响应中断。
boolean tryAcquireSharedNanos(int arg, long nanosTimeout)
在acquireSharedInterruptibly(int arg)
基础上增加了超时限制。
boolean release(int arg)
独占式的释放同步状态,该方法会在释放同步状态之后,将同步队列中第一个节点包含的线程唤醒。
boolean releaseShared(int arg)
共享式的释放同步状态。
Collection<Thread> getQueuedThreads()
获取等待在同步队列上的线程集合。
这些模板方法同步器提供的模板方法基本上分为 3 类:独占式获取与释放同步状态、共享式获取与释放、同步状态和查询同步队列中的等待线程情况。
4.可重写的方法
protected boolean tryAcquire(int arg)
独占式获取同步状态,实现该方法需要查询当前状态并判断同步状态是否符合预期,然后再进行CAS设置同步状态。
protected boolean tryRelease(int arg)
独占式的同步状态,等待获取同步状态得线程将有机会获取同步状态。
protected int tryAcquireShared(int arg)
共享式获取同步状态,返回大于等于0的值,表示获取成功,反之,获取失败。
protected boolean tryReleaseShared(int arg)
共享式释放同步状态
protected boolean isHeldExclusively()
当前同步状态是否在独占模式下被占用,一般方法表示是否被当前所线程独占。
5.AQS 的基础原理-CLH 队列锁
CLH 队列锁即 Craig, Landin, and Hagersten (CLH) locks。(这是三个人的名字)
CLH 队列锁也是一种基于链表的可扩展、高性能、公平的自旋锁,申请线程仅仅在本地变量上自旋,它不断轮询前驱的状态,假设发现前驱释放了锁就结束自旋。
当一个线程需要获取锁时:
- 创建一个的QNode,将其中的locked设置为true表示需要获取锁,myPred表示对其前驱结点的引用。
- 线程 A 对 tail 域调用 getAndSet 方法,使自己成为队列的尾部,同时获取
一个指向其前驱结点的引用 myPred
线程 B 需要获得锁,同样的流程再来一遍
- 线程就在前驱结点的 locked 字段上旋转,直到前驱结点释放锁(前驱节点 的锁值 locked == false)
- 当一个线程需要释放锁时,将当前结点的 locked 域设置为 false,同时回收 前驱结点
如上图所示,前驱结点释放锁,线程 A 的 myPred 所指向的前驱结点的 locked
字段变为 false,线程 A 就可以获取到锁。CLH 队列锁的优点是空间复杂度低(如果有 n 个线程,L 个锁,每个线程每次只获取一个锁,那么需要的存储空间是 O(L+n),n 个线程有 n 个 myNode,L个锁有 L 个 tail)。CLH 队列锁常用在 SMP 体系结构下。
Java 中的 AQS 是 CLH 队列锁的一种变体实现。
6.实现一个自己的独占锁
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.AbstractQueuedSynchronizer;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;/***类说明:实现一个自己的独占锁*/
public class SelfLock implements Lock {/*静态内部类,自定义同步器*/private static class Sync extends AbstractQueuedSynchronizer{/*是否处于占用状态*/@Overrideprotected boolean isHeldExclusively() {return getState()==1;}/*获取锁*/@Overrideprotected boolean tryAcquire(int arg) {if(compareAndSetState(0,1)){setExclusiveOwnerThread(Thread.currentThread());return true;}return false;}/*释放*/@Overrideprotected boolean tryRelease(int arg) {if(getState()==0){throw new IllegalMonitorStateException();}setExclusiveOwnerThread(null);setState(0);return true;}Condition newCondition(){return new ConditionObject();}}private final Sync sync = new Sync();@Overridepublic void lock() {System.out.println(Thread.currentThread().getName()+" 准备获取锁!");sync.acquire(1);System.out.println(Thread.currentThread().getName()+" 已经获取到锁!");}@Overridepublic void lockInterruptibly() throws InterruptedException {sync.acquireInterruptibly(1);}@Overridepublic boolean tryLock() {return sync.tryAcquire(1);}@Overridepublic boolean tryLock(long time, TimeUnit unit){return false;}@Overridepublic void unlock() {System.out.println(Thread.currentThread().getName()+" 准备释放锁!");sync.release(1);System.out.println(Thread.currentThread().getName()+" 已经释放了锁!");}@Overridepublic Condition newCondition() {return sync.newCondition();}}
java并发编程-AQS相关推荐
- Java并发编程—AQS原理分析
目录 一.AQS原理简述 二.自定义独占锁及共享锁 三.锁的可重入性 四.锁的公平性 五.惊群效应 AQS全称AbstractQueuedSynchronizer,它是实现 JCU包中几乎所有的锁.多 ...
- Java并发编程AQS详解
本文内容及图片代码参考视频:https://www.bilibili.com/video/BV12K411G7Fg/?spm_id_from=333.788.recommend_more_video. ...
- Java 并发编程AQS基本介绍
what-什么是AQS? AQS是AbstractQueuedSynchronizer的简称.直译就是"抽象队列同步器". 它定义了一套多线程访问共享资源的同步框架,需要同步类实现 ...
- Java并发编程-AQS源码之条件队列
System.out.println(name + "==>成功获取到锁" + lock); try { condition.await(); } catch (Interr ...
- Java 并发编程—有锁互斥机制及AQS理论
原文作者:Java并发编程 原文地址:AQS这样学就很简单了 目录 一.有锁互斥机制 二.AQS如何实现互斥 三.结语 如果你是道格李,你要实现一套机制来保证线程互斥,你会如何实现呢?你肯定不会一上来 ...
- Java并发编程—常见面试题
建议: 学习java并发前需要先掌握JVM知识 关于下面问题档案的详细解析都在后面推荐的相关系列文章中 一.线程安全相关 1.什么叫线程安全? 线程安全就是说多线程访问同一代码,不会产生不确定的结果. ...
- JUC里面的相关分类|| java并发编程中,关于锁的实现方式有两种synchronized ,Lock || Lock——ReentrantLock||AQS(抽象队列同步器)
JUC分类 java并发编程中,关于锁的实现方式有两种synchronized ,Lock AQS--AbstractQueuedSynchronizer
- aqs clh java_【Java并发编程实战】—– AQS(四):CLH同步队列
在[Java并发编程实战]-–"J.U.C":CLH队列锁提过,AQS里面的CLH队列是CLH同步锁的一种变形. 其主要从双方面进行了改造:节点的结构与节点等待机制.在结构上引入了 ...
- JAVA并发编程: CAS和AQS
说起JAVA并发编程,就不得不聊聊CAS(Compare And Swap)和AQS了(AbstractQueuedSynchronizer). CAS(Compare And Swap) 什么是CA ...
最新文章
- docker下的mysql my.ini_Docker + MySQL 主从环境搭建
- oracle触发器修改同一张表,oracle触发器中对同一张表进行更新再查询时,需加自制事务...
- 有了这些经典书籍+配套实验环境上线,还有什么借口说学不好编程?
- lduan SCCM 2012 介绍及SQL部署(一)
- 华为京东联手,火拼小米生态链!
- HDU2013 蟠桃记【递推】
- 第十章 动态选录协议
- MarkDown 行首缩进
- 计算机对log取反函数,ln计算(log计算器在线)
- Base64编码原理分析
- POJ 【1088】 滑雪
- 这20种PS技术让你的照片美不胜收
- 算符优先算法java实现,算符优先算法
- 计算机磁盘网络怎么共享,手机怎么访问电脑共享磁盘
- time秒和年月日时分秒的转化
- java编写四则运算代码_java编写四则运算
- 3D动画概述暨骨骼动画实现
- 非洲瓜哇JAVA布的特点_非洲人的服装及其着装特点
- Centos6.8安装Nginx
- IDL对HDF5图像做GLT校正