什么是AQS、ReentrantLock

发布时间:2021-10-21 10:48:52 作者:iii
来源:亿速云 阅读:162

这篇文章主要讲解了“什么是AQS、ReentrantLock”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“什么是AQS、ReentrantLock”吧!

(一)AQS概述

Java并发编程的核心在于java.concurrent.util包,juc中大多数同步器的实现都围绕了一个公共的行为,比如等待队列、条件队列、独占获取、共享获取等,这个行为的抽象就是基于AbstractQueuedSynchronized(AQS)。AQS定义了多线程访问共享资源的同步器框架。

简单来讲,AQS就好比一个行为准则,而并发包中的大多数同步器在这个准则下实现。

AQS具备以下的几个特性:阻塞等待队列、共享/独占、公平/非公平、可重入、允许中断。

如果你点开JUC发源码,会发现大量同步器的实现,比如:Lock、Latch、Barrier等都基于AQS实现。

(二)几个重要的知识点

在AQS中,我们需要记住几个重要的知识点:

什么是AQS、ReentrantLock

1、AQS的实现通常是定义内部类Sync继承AQS,将同步器的所有调用都映射到Sync对应的方法上。

2、AQS内部有个属性叫state,表示资源的可用状态。state有三种访问方式getState()、setState()、compareAndSetState()

3、AQS定义了两种资源的共享方式:独占(Exclusive)如ReentrantLock、共享(Share)如Semaphore或CountDownLatch

4、AQS中定义了同步等待队列,用于存放等待线程的一个队列。

这几个知识点会在后面的内容中使用到。

(三)ReentrantLock

我们通过ReentrantLock这个示例来更深入的了解AQS。我会通过上面四个知识点去讲解ReentrantLock中AQS的使用。

1、首先进入ReentrantLock的源码内部,直接就能看到ReentrantLock中定义的内部类Sync

什么是AQS、ReentrantLock

Sync继承了AQS,按AQS去指定同步规则。

2、既然继承了AQS,ReentrantLock内部也相当于有了state,这个state用来记录上锁的次数,ReentrantLock是个可重入锁,如果多次上锁,state会记录上锁的次数,需要释放同样次数的锁才算把锁释放完。

3、ReentrantLock的资源是独占的,AbstractQueuedSynchronized继承了一个叫AbstractOwnableSynchronizer的抽象类:

什么是AQS、ReentrantLock

在这个类中,有个变量叫exclusiveOwnerThread,这个变量记录着当前是哪个线程独占了锁。

4、同步等待队列:由于ReentrantLock是个独占的锁,当有一个线程在使用这个锁的时候,其他线程就要到队列中去等待,这个队列是一种基于双向链表的队列(类CLH队列),节点中存放线程信息。

什么是AQS、ReentrantLock

(四)可重入锁

在介绍AQS时,我们讲到了AQS中有个状态值state,这个值用来判断当前资源的可用状态。可重入锁的意思就是对一个对象可以实现多次加锁,state就用来记录加锁的次数。下面写一段代码:

public class ReentrantLockTest {
    //定义全局的锁对象
    private static final Lock lock=new ReentrantLock(true);
    public static int count=0;
    public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                testlock();
            }
        },"线程A").start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                testlock();
            }
        },"线程B").start();
    }

    private static void testlock() {
        lock.lock();
        count++;
        System.out.println(Thread.currentThread().getName()+"第一次加锁"+count);
        lock.lock();
        count++;
        System.out.println(Thread.currentThread().getName()+"第二次加锁"+count);
        count--;
        lock.unlock();
        System.out.println(Thread.currentThread().getName()+"第一次解锁"+count);
        count--;
        lock.unlock();
        System.out.println(Thread.currentThread().getName()+"第二次解锁"+count);
    }
}

生成两个线程,让他们去执行testlock方法,然后在testlock方法的开始和结束加锁,保证同时只有一个线程可以执行里面的方法。最后的结果是线程有序执行:

什么是AQS、ReentrantLock

在代码中,我们进行了两次lock,这就是可重入锁。我们通过断点调试,来分析第二次加锁后lock中的值,下面给出了说明。

什么是AQS、ReentrantLock

(五)公平锁与非公平锁

我们在用构造方法创建ReentrantLock的时候,可以传入一个boolean类型的参数,true或false

private static final Lock lock=new ReentrantLock(true);

这里的true和false代表了创建的ReentrantLock对象是公平锁还是非公平锁

什么是AQS、ReentrantLock

感谢各位的阅读,以上就是“什么是AQS、ReentrantLock”的内容了,经过本文的学习后,相信大家对什么是AQS、ReentrantLock这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!

推荐阅读:
  1. 多线程(十一、AQS原理-ReentrantLock的条件队列Condition)
  2. 多线程(十、AQS原理-ReentrantLock公平锁)

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

java aqs reentrantlock

上一篇:如何使用Java实现JActor 2.2.0 RC3发布Actor模式

下一篇:如何实现反向代理、负载均衡

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》