【JUC2022】第七章 AQS、ReentrantReadWriteLock 和 StampedLock
创始人
2024-05-29 14:53:20
0

【JUC2022】第七章 AQS

文章目录

  • 【JUC2022】第七章 AQS
  • 一、AQS
    • 1.概述
    • 2.同步器
    • 3.抽象的
    • 4.队列式
  • 二、ReentrantReadWriteLock
    • 1.概述
    • 2.案例
    • 3.存在的问题
  • 三、StampedLock
    • 1.概述
    • 2.案例
    • 3.存在的问题

一、AQS

1.概述

在这里插入图片描述
AQS(AbstractQueueSynchronizer,抽象的队列式同步器),它提供了一个基于 FIFO 队列,可以用于构建锁或者其他相关同步器的基础框架,许多同步类的实现都依赖于它,比如 ReentrantLock、Semaphore、CountDownLatch

AQS 实现了 3 点基本功能:

  • 同步器基本范式、结构
  • 线程的阻塞、唤醒机制
  • 线程阻塞队列的维护

我们来看一下 java.util.concurrent.locks 的类关系图
请添加图片描述
上图中,Lock 的实现类其实都是构建在 AQS 上的,但为何没用 UML 线表示它们之间的关系呢?这是因为每个 Lock 实现类都持有自己内部类 Sync 的实例,而这个 Sync 才是继承自 AQS 的。那为何要实现不同的 Sync 呢?这是因为不同的 Lock 的用途不同

2.同步器

多线程环境下,线程之间可以通过某种状态来同步,比如只有当状态满足某种条件,才能触发线程执行某种操作,能实现这个特性的可以称之为同步器

AQS 里有一个最关键的属性 private volatile int state,可以理解将它为资源数量的抽象。AQS 提供了 getState 和 setState 方法,还有一个线程安全的 compareAndSetState 方法,它利用了 Unsafe 的 CAS 操作,可以做到在并发场景下对 state 进行原子性的修改,并且可以获得修改结果。正式因为这个特性,可以使用 AQS 构建同步器

3.抽象的

AQS 是一个抽象类,需要被子类继承并且重写其中的一些方法,官方对此做了一些说明:AQS 的子类必须重写那些会更改 state 的 protected 方法,以及定义 state 的何种状态意味着需要阻塞。比如,如果要实现一个锁,则 state 可以定义为:0 表示未锁定,1 表示锁定。如果要实现信号量,state 可以表示资源甚于

为此,AQS 提供了以下方法:

  • tryAcquire(int): 试图在独占模式下获取对象的状态
  • tryRelaease(int): 试图设置状态来反映独占模式下的释放
  • tryAcquireShared(int): 试图在共享模式下获取对象的状态
  • tryRelaease(int): 试图设置状态来反映共享模式下的释放
  • isHeldExclusively(): 如果对于当前线程,同步是以独占方式进行的,则返回 true

4.队列式

AQS 将阻塞队列线程封装到了一个内部类 Node 里,并维护了一个 CLH Node FIFO 队列。CLH 队列是一个非阻塞的 FIFO 队列,也就是说,往里面插入或移除一个节点的时候,在并发条件下不会阻塞,而是通过自旋锁和 CAS 保证原子性,实现无锁且快速的修改操作
在这里插入图片描述

以 ReentrantLock 的加锁过程为例:

  1. 尝试加锁
  2. 加锁失败,线程加入队列
  3. 线程入队后进入阻塞状态

二、ReentrantReadWriteLock

1.概述

读写锁定义为:一个资源能够被多个读线程访问,或者被一个写线程访问,并且读写线程不能同时访问

在读多写少的场景下,读写锁具有较高的性能体现

2.案例

package com.sisyphus.ReentrantReadWriteLock;import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;class MyResource{Map map = new HashMap<>();Lock lock = new ReentrantLock();ReadWriteLock rwLock = new ReentrantReadWriteLock();public void write(String key, String value){rwLock.writeLock().lock();try{System.out.println(Thread.currentThread().getName() + "\t" + "正在写入");map.put(key, value);try{TimeUnit.MILLISECONDS.sleep(500);}catch (InterruptedException e){e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "\t" + "完成写入" + value);}finally {rwLock.writeLock().unlock();}}public void read(String key){rwLock.readLock().lock();try{System.out.println(Thread.currentThread().getName() + "\t" + "正在读取");String result = map.get(key);try{TimeUnit.MILLISECONDS.sleep(200);}catch (InterruptedException e){e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "\t" + "完成读取" + result);}finally {rwLock.readLock().unlock();}}
}public class ReentrantReadWriteLockDemo {public static void main(String[] args) {MyResource myResource = new MyResource();for(int i = 0; i < 10; i++){int finalI = i;new Thread(()->{myResource.write(finalI + "", finalI + "");},String.valueOf(i)).start();}for(int i = 0; i < 10; i++){int finalI = i;new Thread(()->{myResource.read(finalI + "");},String.valueOf(i)).start();}for(int i = 0; i < 3; i++){int finalI = i;new Thread(()->{myResource.write(finalI + "", finalI + "");},"新写线程" + String.valueOf(i)).start();}}
}

3.存在的问题

写线程饥饿

当读锁被获取时,写锁无法获取,必须等待读锁释放。如果读线程太多,那么写线程将一直被阻塞,使用“公平锁”可以一定程度上缓解这个问题,但是“公平锁”是以牺牲系统吞吐量为代价的

锁降级

锁的颗粒度减小叫锁升级,锁的颗粒度增大叫锁降级。遵循获取写锁、获取读锁再释放写锁的次序,写锁能够降级为读锁。但是无法从读锁升级为写锁,这也是会造成写线程饥饿的原因

三、StampedLock

1.概述

StampedLock 是 JDK1.8 中新增的一个读写锁,是对 JDK1.5 中的 ReentrantReadWriteLock 的优化

StampedLock 有一个重要属性 long stamp,代表了锁的状态。所有获取锁的方法,都会返回一个 stamp,stamp 为 0表示失败;所有释放锁的方法,都需要传入一个 stamp,并且这个 stamp 必须是和成功获取锁得到的 stamp 一致

StampLock 是不可重入的,如果一个线程已经持有了写锁,再去获取写锁将会导致死锁

StampLock 有三种访问模式:

  • Reading(悲观读模式):功能和 ReentrantReadWriteLock 的读锁类似
  • Writeing(写模式):功能和 ReentrantReadWriteLock 的写锁类似
  • Optimistic reading(乐观读模式):无锁机制,支持读写并发,先乐观地认为读取时没人修改,判断被修改再升级为悲观读模式

2.案例

package com.sisyphus.StampedLockDemo;import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.StampedLock;public class StampedLockDemo {static int number = 1;static StampedLock stampedLock = new StampedLock();public void write(){long stamp = stampedLock.writeLock();System.out.println(Thread.currentThread().getName() + "\t" + "写线程准备修改");try{number = number + 1;}finally {stampedLock.unlock(stamp);}System.out.println(Thread.currentThread().getName() + "\t" + "写线程结束修改");}//悲观读public void read(){long stamp = stampedLock.readLock();System.out.println(Thread.currentThread().getName() + "\t" + "come in readLock codeBlock lock, 4 seconds continue ...");for (int i = 0; i < 4; i++){try{TimeUnit.SECONDS.sleep(1);}catch (InterruptedException e){e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "\t" + "正在读取中……");}try{int result = number;System.out.println(Thread.currentThread().getName() + "\t" + "获得成员变量值result:" + result);System.out.println("写线程没有修改成功,读锁未释放,写锁无法接入,传统的读写互斥");}finally {stampedLock.unlockRead(stamp);}}//乐观读public void tryOptimisticRead(){long stamp = stampedLock.tryOptimisticRead();int result = number;//故意间隔 4 秒钟,乐观认为读取过程中没有其他线程修改过 number 值System.out.println("4 秒前 stampedLock.validate 方法值(true无修改,false有修改)" + "\t" + stampedLock.validate(stamp));for(int i = 0; i < 4; i++){try{TimeUnit.SECONDS.sleep(1);}catch (InterruptedException e){e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "\t" + "正在读取..." + i + " 秒后 stampedLock.validate 方法值(true无修改,false有修改)" + stampedLock.validate(stamp));}if(!stampedLock.validate(stamp)){System.out.println("有人修改过-----有写操作");stamp = stampedLock.readLock();try{System.out.println("从乐观读升级为悲观读");result = number;System.out.println("重新悲观读后 result:" + result);}finally {stampedLock.unlockRead(stamp);}}System.out.println(Thread.currentThread().getName() + "\t" + " finally value:" + result);}public static void main(String[] args) {StampedLockDemo resource = new StampedLockDemo();/*传统版new Thread(()->{resource.read();},"readThread").start();try{TimeUnit.SECONDS.sleep(1);}catch (InterruptedException e){e.printStackTrace();}new Thread(()->{System.out.println(Thread.currentThread().getName() + "\t" + "-----come in");resource.write();},"writeThread").start();try{TimeUnit.SECONDS.sleep(1);}catch (InterruptedException e){e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "\t" + "number:" + number);*/new Thread(()->{resource.tryOptimisticRead();},"readThread").start();//暂停 2 秒钟,演示读过程可以介入写操作try{TimeUnit.SECONDS.sleep(2);}catch (InterruptedException e){e.printStackTrace();}new Thread(()->{System.out.println(Thread.currentThread().getName() + "\t" + "-----come in");resource.write();},"writeThread").start();}
}

3.存在的问题

  • StampedLock 不支持重入
  • StampedLock 的悲观读锁和写锁都不支持条件变量 Condition

相关内容

热门资讯

智慧吴江app安卓系统,安卓系... 你知道吗?最近吴江地区掀起了一股智慧风潮,一款名为“智慧吴江app”的应用在安卓系统上大受欢迎。这款...
苹果系统听歌app安卓,跨平台... 你有没有发现,无论是走在街头还是坐在家里,音乐总是能瞬间点燃我们的心情?而在这个音乐无处不在的时代,...
安卓系统卡顿根源,性能瓶颈与优... 手机用久了是不是感觉越来越卡?是不是每次打开应用都要等半天,甚至有时候直接卡死?别急,今天就来跟你聊...
电脑系统怎么装安卓系统,电脑系... 你有没有想过,把安卓系统装在你的电脑上,是不是就像给电脑穿上了时尚的新衣呢?想象你可以在电脑上直接使...
安卓系统华为手环app,健康管... 你有没有发现,现在的生活越来越离不开智能设备了?手机、平板、手表……这些小玩意儿不仅让我们的生活变得...
switch lite刷安卓系... 你有没有想过,你的Switch Lite除了玩那些可爱的任天堂游戏,还能干些什么呢?没错,今天我要给...
想买华为但是安卓系统,尽享安卓... 最近是不是也被华为的新款手机给迷住了?看着那流畅的线条和强大的性能,是不是心动了呢?但是,一想到安卓...
怎么拷安卓系统文件,安卓系统文... 你有没有想过,手机里的那些安卓系统文件,其实就像是一扇通往手机世界的秘密通道呢?想要深入了解你的安卓...
安卓系统移植按键失灵,安卓系统... 最近你的安卓手机是不是也遇到了按键失灵的尴尬情况呢?这可真是让人头疼啊!别急,今天就来给你详细解析一...
安卓系统更新管理在哪,全面解析... 你有没有发现,你的安卓手机最近是不是总在提醒你更新系统呢?别急,别急,今天就来手把手教你,安卓系统更...
安卓系统哪里出的,从诞生地到全... 你有没有想过,我们每天离不开的安卓系统,它究竟是从哪里冒出来的呢?是不是觉得这个问题有点儿像是在问星...
最好的电脑安卓系统,最佳电脑安... 亲爱的电脑迷们,你是否在寻找一款既能满足你工作需求,又能让你畅享娱乐的电脑操作系统呢?今天,我要给你...
安卓系统保密性,守护隐私的坚实... 你知道吗?在这个信息爆炸的时代,保护个人隐私变得比以往任何时候都重要。尤其是对于安卓系统用户来说,了...
苹果系统下载安卓版本,安卓版本... 你有没有想过,为什么苹果系统的手机那么受欢迎,却还有人想要下载安卓版本呢?这背后可是有着不少故事呢!...
安卓系统如何下载carplay... 你是不是也和我一样,对安卓系统上的CarPlay功能充满了好奇?想象在安卓手机上就能享受到苹果Car...
退回安卓系统的理由,揭秘安卓系... 你有没有想过,为什么有些人会选择退回到安卓系统呢?这可不是一件简单的事情,背后可是有着不少原因哦!让...
安卓机系统互通吗,共创智能生态 你有没有想过,你的安卓手机里的应用和电脑上的安卓应用是不是可以无缝对接呢?是不是有时候觉得手机上的某...
安卓源码 添加系统应用,系统应... 你有没有想过,手机里的那些系统应用是怎么来的?是不是觉得它们就像天外来物,神秘又神奇?其实,只要你愿...
安卓系统能否播放flv,全面解... 你有没有想过,你的安卓手机里那些珍贵的FLV视频文件,到底能不能顺利播放呢?这可是个让人挠头的问题,...
奔驰c系安卓系统,智能驾驶体验... 你有没有发现,最近开奔驰C系的小伙伴们都在悄悄地谈论一个新玩意儿——安卓系统!没错,就是那个我们手机...