Java并发编程系列之九：AQS

AQS是队列同步器的简称，简单来说这个东西是JUC框架工具包和构建锁的基础，它使用一个int成员变量表示同步状态，通过内置的FIFO队列完成资源获取线程的排队工作。深刻理解AQS对后面常用的并发工具也掌握得更深刻。

首先说说AQS和锁的区别吧：锁的底层是使用AQS实现的。锁是面向使用者的，锁定义了使用者与锁交互的接口，隐藏了具体的实现细节；AQS是面向锁的实现者的，它屏蔽了一些复杂的同步状态的管理，简化了锁的实现方式。总结一下：AQS和锁关注的使用者不同。

AQS的使用方式是继承，子类通过实现AQS的三个抽象方法：getState()、setState(int newState)和compareAndSetState(int expect,int update)。compareAndSetState方法也简称为CAS，如果传入的状态与expect相同，那么就把传入的状态设为update，这个操作的原子的。

下面的代码演示了自定义同步组件，它的功能是在同一个时刻只能允许一个线程占有资源

package com.rhwayfun.concurrency;import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.AbstractQueuedSynchronizer;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;/*** Created by rhwayfun on 16-4-3.*/
public class Mutex implements Lock {/*** 静态内部类，自定义同步器*/private static class Sync extends AbstractQueuedSynchronizer {/*** 是否占用锁* @return*/@Overrideprotected boolean isHeldExclusively() {return getState() == 1;}/*** 当状态为0的时候获取锁* @param arg* @return*/@Overrideprotected boolean tryAcquire(int arg) {if (compareAndSetState(0, 1)) {setExclusiveOwnerThread(Thread.currentThread());return true;}return false;}/*** 释放锁，将状态设为0* @param arg* @return*/@Overrideprotected boolean tryRelease(int arg) {if (getState() == 0) throw new IllegalMonitorStateException();setExclusiveOwnerThread(null);setState(0);return true;}/*** @return Condition，每个Condition都包含了一个Condition队列*/Condition newCondition() {return new ConditionObject();}}/*** 直接代理给Sync对象即可*/private final Sync sync = new Sync();public void lock() {sync.acquire(1);}public void lockInterruptibly() throws InterruptedException {sync.acquireInterruptibly(1);}public boolean tryLock() {return sync.tryAcquire(1);}public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {return sync.tryAcquireSharedNanos(1, unit.toNanos(time));}public void unlock() {sync.release(1);}public Condition newCondition() {return sync.newCondition();}
}

程序中使用了静态内部类，该内部类继承了AQS并实现了独占获取锁和释放锁。用户使用这个自定义同步组件的时候，只会使用提供的公共方法，外界是无法直到内部实现细节的。

那么，在AQS内部是如何实现线程同步的呢？经过阅读源码，总结以下几点：

AQS内部依赖一个同步队列——一个FIFO的双向队列完成同步状态（这里的同步状态可以理解为锁）的管理
如果当前线程获取同步状态失败时，同步队列会将当前线程的信息构造成一个节点并将其加入同步队列的尾部，同时会阻塞当前线程
如果线程成功获取到同步状态，那么会把该线程的信息以及等待状态构造成一个节点，并在队列中设置该节点为头节点
获取同步状态失败的线程在被加入到队列尾节点的时候需要保证原子性，因为可能存在多个线程都获取失败的情况；而设置头节点则不需要保证原子性，因为只会由一个线程能够成功获取到同步状态
头节点的线程在释放同步状态之后，将会唤醒其后继节点，后继节点被唤醒后会检查自己的前驱节点是否是头节点
如果检查到自己的前驱节点是头节点，那么线程会采用自旋的方式获取同步状态

Java并发编程系列之九：AQS相关推荐

Java并发编程系列
Java并发编程系列 2018-03-08 Java 并发编程:核心理论 Java并发编程:Synchronized及其实现原理 Java并发编程:Synchronized底层优化(轻量级锁.偏向锁) ...
java并发实战编程pdf_「原创」Java并发编程系列25 | 交换器Exchanger
2020年Java面试题库连载中 [000期]Java最全面试题库思维导图 [001期]JavaSE面试题(一):面向对象 [002期]JavaSE面试题(二):基本数据类型与访问修饰符 [003期] ...
reentrantlock非公平锁不会随机挂起线程?_【原创】Java并发编程系列16 | 公平锁与非公平锁...
本文为何适原创并发编程系列第 16 篇,文末有本系列文章汇总. 上一篇提到重入锁 ReentrantLock 支持两种锁,公平锁与非公平锁.那么这篇文章就来介绍一下公平锁与非公平锁. 为什么需要公平锁 ...
Java 并发编程系列之带你了解多线程
早期的计算机不包含操作系统,它们从头到尾执行一个程序,这个程序可以访问计算机中的所有资源.在这种情况下,每次都只能运行一个程序,对于昂贵的计算机资源来说是一种严重的浪费. 操作系统出现后,计算机可以运 ...
Java 并发编程系列之闭锁（CountDownLatch）
在讲闭锁之前,我们先来思考一个问题:在多线程环境下,主线程打印一句话,如何保证这句话最后(其他线程全部执行完毕)打印? 博主目前可以想到的实现方式有两种.一种是通过 join() 方法实现,另一种就是 ...
『死磕Java并发编程系列』并发编程工具类之CountDownLatch
<死磕 Java 并发编程>系列连载中,大家可以关注一波:
『图解Java并发编程系列』10张图告诉你Java并发多线程那些破事
目录线程安全问题活跃性问题性能问题有态度的总结头发很多的程序员:『师父,这个批量处理接口太慢了,有什么办法可以优化?』架构师:『试试使用多线程优化』第二天头发很多的程序员:『师父,我已经使用 ...
java并发编程系列-内存模型基础
java线程之间的通信对程序开发人员是完全透明的,内存的可见性问题很容易困扰很多开发人员.本篇博文将揭开java内存模型的神秘面纱,来看看内存模型到底是怎样的. 并发编程中需要处理的两个关键问题: · ...
Java并发编程系列之CountDownLatch用法及详解
背景前几天一个同事问我,对这个CountDownLatch有没有了解想问一些问题,当时我一脸懵逼,不知道如何回答.今天赶紧抽空好好补补.不得不说Doug Lea大师真的很牛,设计出如此好的类. 1. ...

Java并发编程系列之九：AQS

Java并发编程系列之九：AQS相关推荐

最新文章

热门文章