【Java并发编程实战】----- AQS(二)：获取锁、释放锁

上篇博客稍微介绍了一下AQS，下面我们来关注下AQS的所获取和锁释放。

AQS锁获取

AQS包含如下几个方法：

acquire(int arg)：以独占模式获取对象，忽略中断。

acquireInterruptibly(int arg)：以独占模式获取对象，如果被中断则中止。

acquireShared(int arg)：以共享模式获取对象，忽略中断。

acquireSharedInterruptibly(int arg)以共享模式获取对象，如果被中断则中止。

tryAcquire(int arg)：试图在独占模式下获取对象状态。

tryAcquireNanos(int arg, long nanosTimeout)：试图以独占模式获取对象，如果被中断则中止，如果到了给定超时时间，则会失败。

tryAcquireShared(int arg)：试图在共享模式下获取对象状态。

tryAcquireSharedNanos(int arg, long nanosTimeout)：试图以共享模式获取对象，如果被中断则中止，如果到了给定超时时间，则会失败。

对于lock.lock()最终都会调用AQS的acquire()方法，Semaphore.acquire()最终会调用AQS的acquireSharedInterruptibly()方法，其中acquire()源代码如下：

public final void acquire(int arg) {

        if (!tryAcquire(arg) &&

            acquireQueued(addWaiter(Node.EXCLUSIVE), arg))

            selfInterrupt();

    }

tryAcquire：去尝试获取锁，获取成功则设置锁状态并返回true，否则返回false。

addWaiter：将当前线程加入到CLH队列队尾。

acquireQueued：当前线程会根据公平性原则来进行阻塞等待,直到获取锁为止；并且返回当前线程在等待过程中有没有中断过。

selfInterrupt：产生一个中断。

其主要流程如下：

1、首先线程尝试获取锁，如果成功则直接返回，不成功则新建一个Node节点并添加到CLH队列中。tryAcquire尝试获取锁，addWaiter则新建节点并添加到CLH队列中。其中tryAcquire，AQS并没有提供实现，它仅仅只是抛出一个异常，具体的实现需要各个锁自己实现。

protected boolean tryAcquire(int arg) {

        throw new UnsupportedOperationException();

    }

addWaiter后面讲述。

2、acquireQueued主要功能是根据该节点寻找CLH队列的头结点，并且尝试获取锁，判断是否需要挂起，并且返回挂起标识。如下：

final boolean acquireQueued(final Node node, int arg) {

        try {

            boolean interrupted = false;

            for (;;) {

                final Node p = node.predecessor();

                if (p == head && tryAcquire(arg)) {

                    setHead(node);

                    p.next = null; // help GC

                    return interrupted;

                }

                if (shouldParkAfterFailedAcquire(p, node) &&

                    parkAndCheckInterrupt())

                    interrupted = true;

            }

        } catch (RuntimeException ex) {

            cancelAcquire(node);

            throw ex;

        }

    }

在acquireQueued()内部仍然调用tryAcquire()来获取锁。更多详情请参考：【Java并发编程实战】—–“J.U.C”：ReentrantLock之二lock方法分析

selfInterrupt：产生一个中断。如果在acquireQueued()中当前线程被中断过，则需要产生一个中断。

private static void selfInterrupt() {

    Thread.currentThread().interrupt();

}

AQS锁释放

AQS释放锁的方法主要有：

release(int arg)：以独占模式释放对象。

releaseShared(int arg)：以共享模式释放对象

tryRelease(int arg)：试图设置状态来反映独占模式下的一个释放。

tryReleaseShared(int arg)：试图设置状态来反映共享模式下的一个释放。

释放锁相对于获取锁来说还是比较简单的，其主要流程如下：

其代码如下（release()）:

public final boolean release(int arg) {

        if (tryRelease(arg)) {

            Node h = head;

            if (h != null && h.waitStatus != 0)

                unparkSuccessor(h);

            return true;

        }

        return false;

    }

tryeRelease()：尝试释放锁，AQS也同样没有提供实现，具体实现方法要其子类自己内部实现，AQS仅仅只是抛出一个异常。

protected boolean tryRelease(int arg) {

        throw new UnsupportedOperationException();

    }

unparkSuccessor：用于唤醒节点。更多，请参考：【Java并发编程实战】—–“J.U.C”：ReentrantLock之三unlock方法分析

参考文献：

1、JAVA并发编程学习笔记之AQS源码分析（获取与释放）

【Java并发编程实战】----- AQS(二)：获取锁、释放锁的更多相关文章

【Java并发编程实战】-----“J.U.C”：锁，lock
在java中有两种方法实现锁机制,一种是在前一篇博客中([java7并发编程实战]-----线程同步机制:synchronized)介绍的synchronized,而另一种是比synchronized ...
《Java并发编程实战》第十三章显示锁读书笔记
一.Lock与 ReentrantLock Lock 提供一种无条件的.可轮询的.定时的.可中断的锁获取操作,全部加锁和解锁的方法都是显式的. public interface Lock { void ...
《java并发编程实战》读书笔记10--显示锁Lock，轮询、定时、读写锁
第13章显示锁终于看到了这本书的最后一本分,呼呼呼,真不容易.其实说实在的,我不喜欢半途而废,有其开始,就一定要有结束,否则的话就感觉哪里乖乖的. java5.0之前,在协调对共享对象的访问时可以 ...
java并发编程实战：第十三章----显示锁
一.Lock与ReentrantLock Lock接口中定义了一种无条件.可轮询的.定时的以及可中断的锁获取操作,所有加锁和解锁的方法都是显式的. 1 public interfece Lock 2 ...
那些年读过的书《Java并发编程实战》二、如何设计线程安全类
1.设计线程安全类的过程设计线程安全类的过程就是设计对象状态并发访问下线程间的协同机制(在不破坏对象状态变量的不变性条件的前提下). (1)构建线程安全类的三个基本要素: 1)找出构成对象状态的所有 ...
读书笔记-----Java并发编程实战（二）对象的共享
public class NoVisibility{ private static boolean ready; private static int number; private static c ...
Java并发编程实战第13章显式锁
接口Lock的实现类: ReentrantLock, ReentrantReadWriteLock.ReadLock, ReentrantReadWriteLock.WriteLock Reentra ...
【Java并发编程实战】----- AQS(四)：CLH同步队列
在[Java并发编程实战]-–"J.U.C":CLH队列锁提过,AQS里面的CLH队列是CLH同步锁的一种变形.其主要从两方面进行了改造:节点的结构与节点等待机制.在结构上引入了头 ...
【Java并发编程实战】----- AQS(三)：阻塞、唤醒：LockSupport
在上篇博客([Java并发编程实战]----- AQS(二):获取锁.释放锁)中提到,当一个线程加入到CLH队列中时,如果不是头节点是需要判断该节点是否需要挂起:在释放锁后,需要唤醒该线程的继任节点 ...

随机推荐

ENode框架Conference案例分析系列之 - 事件溯源如何处理重构问题
前言本文可能对大多数不太了解ENode的朋友来说,理解起来比较费劲,这篇文章主要讲思路,而不是一上来就讲结果.我写文章,总是希望能把自己的思考过程尽量能表达出来,能让大家知道每一个设计背后的思考的东 ...
ELF Format 笔记（四）—— 节（Section）
ilocker:关注 Android 安全(新入行,0基础) QQ: 2597294287 ELF 文件可以包含很多 section,所有的 section 都在 section header tab ...
[转载]基于MVC4+EasyUI的Web开发框架经验总结(8)--实现Office文档的预览
在博客园很多文章里面,曾经有一些介绍Office文档预览查看操作的,有些通过转为PDF进行查看,有些通过把它转换为Flash进行查看,但是过程都是曲线救国,真正能够简洁方便的实现Office文档的预览 ...
Windows 配置JAVA的环境变量
Java是由Sun公司开发的一种应用于分布式网络环境的程序设计语言,Java语言拥有跨平台的特性,它编译的程序能够运行在多种操作系统平台上,可以实现“一次编写,到处运行”的强大功能. 工具/原料 JD ...
JS给元素增加className
function(element,value) //给元素添加className { if(!element.className) { element.className=value; } else{ ...
C#有意思的算法题
年底了,特贡献一些C#有意思的算法题 2013年,即将要过去了.屌丝C#程序员们拿到了年终奖不?是不是又想蠢蠢欲动了?是不是想通过跳槽来为自己实现加薪的梦想?好吧,跳槽之前还是做点准备吧,准备好C ...
Java对List进行分页
Java对组装的List分页以前一直是在DAO层直接从数据库里分页,但是今天因为有些数据,需要混合展示,就是根据条件取出了多个对象的集合,然后把这些多个List放到一个List里,然后在从这个Lis ...
tp5问题整理
问题一:致命错误: Class 'think\controller' not found 原因:controller首字母要大写解决:use think\Controller; 问题二:html页面 ...
Leetcode——37.解数独 [##]
@author: ZZQ @software: PyCharm @file: leetcode37_solveSudoku.py @time: 2018/11/20 16:41 思路:递归回溯首先, ...
Sublime Text 3 web 开发常用配置
前沿 Sublime Text 是一个代码编辑器(Sublime Text 2是收费软件,但可以无限期试用),也是HTML和散文先进的文本编辑器.Sublime Text是由程序员Jon Skinne ...