返回顶部
首页 > 资讯 > 精选 >JUC中的AQS机制的使用方法
  • 252
分享到

JUC中的AQS机制的使用方法

2023-06-15 12:06:57 252人浏览 八月长安
摘要

本篇内容介绍了“JUC中的AQS机制的使用方法”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!为了解决原子性的问题,Java加入了锁机制,同时

本篇内容介绍了“JUC中的AQS机制的使用方法”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

为了解决原子性的问题,Java加入了机制,同时保证了可见性和顺序性。jdk1.5的并发包中新增了Lock接口以及相关实现类来实现锁功能,比synchronized更加灵活,开发者可根据实际的场景选择相应的实现类。

Lock特性

可重入

像synchronized和ReentrantLock都是可重入锁,可重入性表明了锁的分配机制是基于线程的分配,而不是基于方法调用的分配。

举个简单的例子,当一个线程已经获取到锁,当后续再获取同一个锁,直接获取成功。但获取锁和释放锁必须要成对出现。

可响应中断

当线程因为获取锁而进入阻塞状态,外部是可以中断该线程的,调用方通过捕获InterruptedException可以捕获中断

可设置超时时间

获取锁时,可以指定超时时间,可以通过返回值来判断是否成功获取锁

公平性

提供公平性锁和非公平锁(默认)两种选择。

  •  公平锁,线程将按照他们发出请求的顺序来获取锁,不允许插队;

  •  非公平锁,则允许插队:当一个线程发生获取锁的请求的时刻,如果这个锁是可用的,那这个线程将跳过所在队列里等待线程并获得锁。

考虑这么一种情况:A线程持有锁,B线程请求这个锁,因此B线程被挂起;A线程释放这个锁时,B线程将被唤醒,因此再次尝试获取锁;与此同时,C线程也请求获取这个锁,那么C线程很可能在B线程被完全唤醒之前获得、使用以及释放这个锁。

这是种双赢的局面,B获取锁的时刻(B被唤醒后才能获取锁)并没有推迟,C更早地获取了锁,并且吞吐量也获得了提高。在大多数情况下,非公平锁的性能要高于公平锁的性能。

另外,这个公平性是针对线程而言的,不能依赖此来实现业务上的公平性,应该由开发者自己控制,比如通过FIFO队列来保证公布。

读写锁

允许读锁和写锁分离,读锁与写锁互斥,但是多个读锁可以共存,适用于读频次远大于写频次的场景

丰富的api

提供了多个方法来获取锁相关的信息,可以帮助开发者监控和排查问题

  •  isFair():判断锁是否是公平锁

  •  isLocked():判断锁是否被任何线程获取了

  •  isHeldByCurrentThread():判断锁是否被当前线程获取了

  •  hasQueuedThreads():判断是否有线程在等待该锁

  •  getHoldCount():查询当前线程占有lock锁的次数

  •  getQueueLength():获取正在等待此锁的线程数

锁的使用

ReentrantLock

独占锁的实现,拥有上面列举的除读写锁之外的所有特性,使用比较简单

class X {     // 创建独占锁实例     private final ReentrantLock lock = new ReentrantLock();     // ...     public void m() {       lock.lock();  // block until condition holds       try {         // ... method body       } finally {         // 必须要释放锁,unlock与lock成对出现         lock.unlock()       }     }   }

ReentrantReadWriteLock

读写锁的实现,拥有上面列举的所有特性。并且写锁可降级为读锁,反之不行。

class CachedData {     Object data;     volatile boolean cacheValid;     final ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();     void processCachedData() {       rwl.readLock().lock();       if (!cacheValid) {         // Must release read lock before acquiring write lock         rwl.readLock().unlock();         rwl.writeLock().lock();         try {           // Recheck state because another thread might have           // acquired write lock and changed state before we did.           if (!cacheValid) {            data = ...             cacheValid = true;           }          // Downgrade by acquiring read lock before releasing write lock           rwl.readLock().lock();         } finally {           rwl.writeLock().unlock(); // Unlock write, still hold read         }       }       try {         use(data);       } finally {         rwl.readLock().unlock();       }     }   }

StampedLock

StampedLock也是一种读写锁,提供两种读模式:乐观读和悲观读。乐观读允许读的过程中也可以获取写锁后写入!这样一来,我们读的数据就可能不一致,所以,需要一点额外的代码来判断读的过程中是否有写入。

乐观锁的意思就是乐观地估计读的过程中大概率不会有写入,因此被称为乐观锁。反过来,悲观锁则是读的过程中拒绝有写入,也就是写入必须等待。显然乐观锁的并发效率更高,但一旦有小概率的写入导致读取的数据不一致,需要能检测出来,再读一遍就行。

public class Point {      private final StampedLock stampedLock = new StampedLock();      private double x;      private double y;      public void move(double deltaX, double deltaY) {          long stamp = stampedLock.writeLock(); // 获取写锁          try {              x += deltaX;              y += deltaY;          } finally {              stampedLock.unlockWrite(stamp); // 释放写锁          }      }      public double distanceFromOrigin() {          long stamp = stampedLock.tryOptimisticRead(); // 获得一个乐观读锁          // 注意下面两行代码不是原子操作          // 假设x,y = (100,200)          double currentX = x;          // 此处已读取到x=100,但x,y可能被写线程修改为(300,400)          double currentY = y;          // 此处已读取到y,如果没有写入,读取是正确的(100,200)          // 如果有写入,读取是错误的(100,400)          if (!stampedLock.validate(stamp)) { // 检查乐观读锁后是否有其他写锁发生              stamp = stampedLock.readLock(); // 获取一个悲观读锁              try {                  currentX = x;                  currentY = y;              } finally {                  stampedLock.unlockRead(stamp); // 释放悲观读锁              }          }          return Math.sqrt(currentX * currentX + currentY * currentY);      }  }

Condition

Condition成为条件队列或条件变量,为一个线程挂起执行(等待)提供了一种方法,直到另一线程通知某些状态条件现在可能为真为止。由于对该共享状态信息的访问发生在不同的线程中,因此必须由互斥锁对其其进行保护。

await方法:必须在获取锁之后的调用,表示释放当前锁,阻塞当前线程;等待其他线程调用锁的signal或signalAll方法,线程唤醒重新获取锁。

Lock配合Condition,可以实现synchronized 与 对象(wait,notify)同样的效果,来进行线程间基于共享变量的通信。但优势在于同一个锁可以由多个条件队列,当某个条件满足时,只需要唤醒对应的条件队列即可,避免无效的竞争。

// 此类实现类似阻塞队列(ArrayBlockingQueue)  class BoundedBuffer {   final Lock lock = new ReentrantLock();   final Condition notFull  = lock.newCondition();    final Condition notEmpty = lock.newCondition();    final Object[] items = new Object[100];   int putptr, takeptr, count;   public void put(Object x) throws InterruptedException {     lock.lock();     try {       while (count == items.length)         notFull.await();       items[putptr] = x;       if (++putptr == items.length) putptr = 0;       ++count;       notEmpty.signal();     } finally {       lock.unlock();     }   }   public Object take() throws InterruptedException {     lock.lock();     try {       while (count == 0)         notEmpty.await();       Object x = items[takeptr];      if (++takeptr == items.length) takeptr = 0;       --count;       notFull.signal();       return x;     } finally {       lock.unlock();     }   }  }

BlockingQueue

BlockingQueue阻塞队列实际上是一个生产者/消费者模型,当队列长度大于指定的最大值,生产线程就会被阻塞;反之当队列元素为空时,消费线程就会被阻塞;同时当消费成功时,就会唤醒阻塞的生产者线程;生产成功就会唤醒消费者线程;

内部使用就是ReentrantLock + Condition来实现的,可以参照上面的示例。

CountDownLatch

称之为倒计时器锁,初始化指定数值,调用countDown可以对数值减一,当数值减为0时,就会唤醒所有因为调用await方法而阻塞的线程。

可以达到一组线程等待另外一组线程都完成任务的效果。

class Driver { // ...     void main() throws InterruptedException {       CountDownLatch startSignal = new CountDownLatch(1);       CountDownLatch doneSignal = new CountDownLatch(N);       for (int i = 0; i < N; ++i) // create and start threads         new Thread(new Worker(startSignal, doneSignal)).start();       doSomethingElse();            // don't let run yet       startSignal.countDown();      // let all threads proceed       doSomethingElse();       doneSignal.await();           // wait for all to finish     }  }  class Worker implements Runnable {     private final CountDownLatch startSignal;     private final CountDownLatch doneSignal;     Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {       this.startSignal = startSignal;       this.doneSignal = doneSignal;     }     public void run() {       try {         startSignal.await();         doWork();         doneSignal.countDown();       } catch (InterruptedException ex) {} // return;     }     void doWork() { ... }  }

CyclicBarrier

称之为同步屏障,它使得一组线程互相等待,直到到达某个公共屏障点。

初始化指定数值,调用await方法会使得线程阻塞,直到指定数量的线程都调用await方法时,所有被阻塞的线程会被唤醒,继续执行。

与CountDownLatch的区别是,CountDownLatch是一组线程等待另外一组线程,而CyclicBarrier是一组线程之间相互等待。

Semaphore

称之为信号量,与互斥锁ReentrantLock用法类似,区别就是Semaphore共享的资源是多个,允许多个线程同时竞争成功。

AQS原理

AQS 是 AbstractQueuedSynchronizer的缩写,中文 抽象队列同步器,是构建各类锁和同步器的基础实现。内部维护了共享变量state (int类型) 和 双向队列 (包含头指针和尾指针)

JUC中的AQS机制的使用方法

并发问题解决

原子性

Unsafe.compareAndSwapXXX 实现CAS更改 state 和 队列指针 内部依赖CPU提供的原子指令

可见性与有序性

volatile 修饰 state 与 队列指针 (prev/next/head/tail)

线程阻塞与唤醒

Unsafe.park Unsafe.parkNanos Unsafe.unpark

Unsafe类是在sun.misc包下,不属于Java标准。提供了内存管理、对象实例化、数组操作、CAS操作、线程挂起与恢复等功能,Unsafe类提升了Java运行效率,增强了Java语言底层的操作能力。很多Java的基础类库,包括一些被广泛使用的高性能开发库都是基于Unsafe类开发的,比如Netty、Cassandra、hadoopkafka

AQS内部有两种模式:独占模式和共享模式

AQS 的设计是基于模板方法的,使用者需要继承 AQS 并重写指定的方法。不同的自定义同步器争用共享资源的方式不同,比如可重入、公平性等都是子类来实现。

自定义同步器在实现时只需要实现共享资源state的获取与释放方式即可,至于具体线程等待队列的维护(如获取资源失败入队/唤醒出队等),由AQS内部处理。

独占模式

  •  只有一个线程都能够获取到锁

  •  锁释放后需要唤醒后继节点

AQS提供的独占模式相关的方法

// 获取独占锁(线程阻塞直至获取成功)  public final void acquire(int)  // 获取独占锁,可被中断  public final void acquireInterruptibly(int)   // 获取独占锁,可被中断 和 指定超时时间  public final boolean tryAcquireNanos(int, long)   // 释放独占锁(释放锁后,将等待队列中第一个等待节点唤醒 )  public final boolean release(int)

AQS子类需要实现的独占模式相关的方法

// 尝试获取独占锁  protected boolean tryAcquire(int)  // 尝试释放独占锁  protected boolean tryRelease(int)

获取独占锁的流程

JUC中的AQS机制的使用方法

JUC中的AQS机制的使用方法

  •  调用子类tryAcquire尝试获取锁,获取成功,直接返回

  •  通过自旋CAS将当前线程封装成节点加入队列末尾

  •  循环等待或尝试tryAcquire获取锁

    •   判断前置节点如果为head,则尝试获取锁

    •   根据队列中节点状态,决定是否需要阻塞当前线程

    •   tryAcquire获取锁成功后,将当前节点设置为head 并 返回

  •  如果当前线程中断或超时,则执行cancelAcquire

    •   将当前节点状态置为CANCELED,并从队列删除

    •   如果前置节点为Head,则将后置节点唤醒

释放独占锁的流程

JUC中的AQS机制的使用方法

共享模式

  •  多个线程都能够获取到锁

  •  锁释放后需要唤醒后继节点

  •  锁获取后如果还有资源需要唤醒后继共享节点

AQS提供的共享模式相关的方法

// 获取共享锁(线程阻塞直至获取成功)  public final void acquireShared(int)   // 获取共享锁,可被中断  public final acquireSharedInterruptibly(int)  // 获取共享锁,可被中断 和 指定超时时间  public final tryAcquireSharedNanos(int, long)    // 获取共享锁  public final boolean releaseShared(int)

AQS子类需要实现的共享模式相关的方法

// 尝试获取共享锁  protected int tryAcquireShared(int)  // 尝试释放共享锁  protected boolean tryReleaseShared(int)

获取共享锁的流程

JUC中的AQS机制的使用方法

调用子类tryAcquireShared尝试获取锁,获取成功,直接返回

通过自旋CAS将当前线程封装成节点加入队列末尾

循环等待或尝试tryAcquireShared获取锁

  •  判断前置节点如果为head,则尝试获取锁

  •  根据队列中节点状态,决定是否需要阻塞当前线程

  •  tryAcquireShared获取锁成功后,将当前节点设置为head

    •   如果资源有剩余或者原先的head节点状态为SIGNAL/PROPAGATE,则调用doReleaseShared

    •   如果当前head节点状态为SIGNAL,唤醒后继节点

    •   如果当前head节点状态为ZERO,将head节点状态置为PROPAGATE

  •  如果当前线程中断或超时,则执行cancelAcquire

    •   将当前节点状态置为CANCELED,并从队列删除

    •   如果前置节点为Head,则将后置节点唤醒

释放共享锁的流程

JUC中的AQS机制的使用方法

等待队列中节点的状态变化

JUC中的AQS机制的使用方法

ReentrantLock示例

tryAcquire逻辑

JUC中的AQS机制的使用方法

tryRelease逻辑

JUC中的AQS机制的使用方法

“JUC中的AQS机制的使用方法”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站,小编将为大家输出更多高质量的实用文章!

--结束END--

本文标题: JUC中的AQS机制的使用方法

本文链接: https://www.lsjlt.com/news/280211.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • JUC中的AQS机制的使用方法
    本篇内容介绍了“JUC中的AQS机制的使用方法”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!为了解决原子性的问题,Java加入了锁机制,同时...
    99+
    2023-06-15
  • Java JUC的核心类AQS有什么用
    这篇文章主要介绍“Java JUC的核心类AQS有什么用”,在日常操作中,相信很多人在Java JUC的核心类AQS有什么用问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Java JUC的核心类AQS有什么用...
    99+
    2023-06-02
  • Java AQS中ReentrantLock条件锁的使用
    目录一.什么是AQS1.定义2.特性3.属性4.资源共享方式5.两种队列6.队列节点状态7.实现方法二.等待队列1.同步等待队列2.条件等待队列三.condition接口四.Reen...
    99+
    2023-02-02
    Java ReentrantLock条件锁 Java ReentrantLock Java条件锁
  • Python retrying 重试机制的使用方法
    目录循环加判断 retrying 我们在程序开发中,经常会需要请求一些外部的接口资源,而且我们不能保证每次请求一定会成功,所以这些涉及到网络请求的代码片段就需要加上重试机制。下面来说...
    99+
    2024-04-02
  • JUC中的wait与notify方法实现原理详解
    目录1.Object中的wait()实现原理2.Object对象中的wait,notify,notifyAll的理解3.wait 实战1.Object中的wait()实现原理 在进行...
    99+
    2023-03-10
    JUC wait与notify JUC wait JUC notify
  • JAVASPI机制详解使用方法
    目录写在前面什么是SPI使用场景实现约定四种角色基于JAVA原生特性实现的JAVA SPI机制的DEMO1. 主要角色2. 示例代码3. 说明基于SPRING BOOT实现的JAVA...
    99+
    2024-04-02
  • JUC中wait与notify方法的实现原理是什么
    今天小编给大家分享一下JUC中wait与notify方法的实现原理是什么的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考一下,希望大家阅读完这篇文章后有所收获,下面我们一起来了解一下吧。1.O...
    99+
    2023-07-05
  • Linux虚拟机中QEMU的使用方法
    这期内容当中小编将会给大家带来有关Linux虚拟机中QEMU的使用方法,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。  说起虚拟机,大家都不陌生。需要使用虚拟机的场景也非常的多,比如有志于写操作系统的同志...
    99+
    2023-06-13
  • 使用Win8中自带的语音控制的方法
    设置Windows语音识别  首先我们需要找到Windows 8中的“Windows语音识别”,你可以选择通过搜索,也可以在“所有应用”的“Win...
    99+
    2022-06-04
    自带 语音 方法
  • react中props 的使用及进行限制的方法
    组件的props( props是一个对象 ) 作用:接收传递给组件的数据 特点: 可以给组件传递任意类型的数据 props是只读的对象,只能读取属性的值,无法修改对...
    99+
    2024-04-02
  • Java中JUC包(java.util.concurrent)下的常用子类
    目录一、对象锁juc.locks包二、原子类三、四个常用工具类3.1 信号量 Semaphore3.2 CountDownLatch总结一、对象锁juc.locks包 在Java中除...
    99+
    2022-12-20
    java util类 java.util包中的类 juc包有哪些常用的
  • Java AQS中的公平锁与非公平锁怎么使用
    本篇内容主要讲解“Java AQS中的公平锁与非公平锁怎么使用”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Java AQS中的公平锁与非公平锁怎么使用”吧!公平锁和非公平锁ReentrantL...
    99+
    2023-06-02
  • navicat注册机的使用方法
    这篇文章主要介绍navicat注册机的使用方法,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!navicat注册机使用教程:1、 安装 Navicat 11 for Windows 系...
    99+
    2024-04-02
  • Java中AQS的原理及作用是什么
    这篇文章主要介绍“Java中AQS的原理及作用是什么”,在日常操作中,相信很多人在Java中AQS的原理及作用是什么问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Java中AQS的原理及作用是什么”的疑惑有所...
    99+
    2023-06-15
  • 如何使用Spring中的重试机制
    这篇文章主要介绍“如何使用Spring中的重试机制”,在日常操作中,相信很多人在如何使用Spring中的重试机制问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”如何使用Spring中的重试机制”的疑惑有所帮助!...
    99+
    2023-06-15
  • 手机远程控制云服务器设备的使用方法
    1. 选择适合的远程控制工具 要远程控制云服务器设备,首先需要选择适合的远程控制工具。以下是一些常用的远程控制工具: SSH(Secure Shell):SSH 是一种加密的网络协议,可以通过终端或命令行界面远程连接到云服务器设备。它是...
    99+
    2023-10-28
    使用方法 远程控制 服务器
  • 使用手机控制电脑:亿速云服务器的方法
    1. 远程桌面连接 远程桌面连接是一种常见的方法,可以使用手机控制电脑。以下是使用亿速云服务器进行远程桌面连接的步骤: 在亿速云服务器上安装远程桌面服务。确保你的服务器已经安装了远程桌面服务,如果没有安装,可以通过控制面板或者命令行进行...
    99+
    2023-10-27
    服务器 方法 电脑
  • 使用手机控制个人私有云服务器的方法
    1. 安装个人私有云服务器应用 首先,你需要在你的个人私有云服务器上安装一个适用于手机控制的应用程序。有很多不同的应用程序可供选择,例如OwnCloud、Nextcloud、Seafile等。这些应用程序可以在你的服务器上创建一个云存储空...
    99+
    2023-10-28
    服务器 方法 手机
  • 在java项目中运用动态代理机制的方法
    在java项目中运用动态代理机制的方法?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。java 中动态代理机制的实例讲解在java的动态代理机制中,有两个重要的类...
    99+
    2023-05-31
    java ava
  • Qt中的双缓冲机制与应用方法是什么
    本篇内容介绍了“Qt中的双缓冲机制与应用方法是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!1、双缓冲机制所谓双缓冲机制,是指在绘制控件...
    99+
    2023-07-05
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作