【JAVA进阶篇教学】第十五篇:Java中AQS讲解

2024-05-14 12:36

本文主要是介绍【JAVA进阶篇教学】第十五篇:Java中AQS讲解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

博主打算从0-1讲解下java进阶篇教学,今天教学第十五篇:Java中AQS讲解。

在Java并发编程中,AQS(AbstractQueuedSynchronizer)是一个重要的框架,用于实现同步器和锁的基础。它提供了一种灵活的方式来实现各种同步器,如ReentrantLock、Semaphore、CountDownLatch等。本文将深入探讨AQS的原理、实现方式以及如何使用它来构建自定义的同步器。

目录

一、前言

二、AQS的原理

三、AQS的使用


一、前言

在 Java 中,AQS(AbstractQueuedSynchronizer)是一个用于实现同步器的抽象类,它提供了一种通用的机制来管理共享资源的访问。AQS 的主要作用是通过维护一个同步队列来实现对共享资源的同步访问,避免了多线程访问共享资源时可能出现的竞态条件和死锁等问题。

二、AQS的原理

AQS是通过一个FIFO(先进先出)的队列来管理等待线程,实现对共享资源的访问控制。它的核心思想是将状态的管理委托给了子类,通过模板方法模式来实现同步器的具体逻辑。AQS内部维护了一个state变量表示同步状态,以及一个双向链表来存放等待线程。
AQS的主要实现包括两个部分:状态管理和线程阻塞与唤醒。

  • 状态管理:AQS通过getState()和setState(int newState)方法来管理同步状态,同时提供了compareAndSetState(int expect, int update)方法来实现原子更新状态。
  • 线程阻塞与唤醒:AQS通过enq(Node node)和addWaiter(Node mode)等方法将等待线程加入到等待队列中,通过release(int arg)和unparkSuccessor(Node node)等方法来唤醒等待线程。

AQS 的原理主要基于以下几个方面: 

同步队列:AQS 依赖内部的同步队列(一个 FIFO 双向队列)来完成同步状态的管理。当前线程获取同步状态失败时,同步器会将当前线程以及等待状态等信息构造成为一个节点(Node)并将其加入同步队列,同时会阻塞当前线程。当同步状态释放时,会把首节点中的线程唤醒,使其再次尝试获取同步状态。

节点:同步队列中的节点(Node)用来保存获取同步状态失败的线程引用、等待状态以及前一个节点和后一个节点。节点的属性类型与名称以及描述如下表所示:

属性类型名称描述
Threadthread获取同步状态失败的线程
intwaitStatus等待状态
Nodeprev前一个节点
Nodenext后一个节点

状态变量:AQS 使用两个原子状态变量来维护同步状态:

  • state:表示资源的状态,可以用于表示锁的占用情况或者其他同步状态。
  • exclusiveOwnerThread:表示当前占用锁的线程。 

AQS 的实现通过维护状态变量和同步队列,确保了多线程对共享资源的访问是有序的,避免了竞态条件和死锁等问题的出现。

三、AQS的使用

下面是一个简单的 AQS 使用示例,演示了如何使用 AQS 来实现一个简单的锁:

import java.util.concurrent.locks.AbstractQueuedSynchronizer;public class MyLock extends AbstractQueuedSynchronizer {@Overrideprotected boolean tryAcquire(int arg) {// 判断是否可以获取锁if (getState() == 0) {if (compareAndSetState(0, 1)) {setExclusiveOwnerThread(Thread.currentThread());return true;}}return false;}@Overrideprotected boolean tryRelease(int arg) {// 判断是否可以释放锁if (getState() == 1 && getExclusiveOwnerThread() == Thread.currentThread()) {setExclusiveOwnerThread(null);setState(0);return true;}return false;}public void lock() {acquire(1);}public void unlock() {release(1);}public static void main(String[] args) {MyLock lock = new MyLock();// 线程 1 获取锁new Thread(() -> {lock.lock();try {System.out.println("Thread 1 获取锁成功");Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();System.out.println("Thread 1 释放锁成功");}}).start();// 线程 2 获取锁new Thread(() -> {lock.lock();try {System.out.println("Thread 2 获取锁成功");Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();System.out.println("Thread 2 释放锁成功");}}).start();}
}

在上述示例中,我们创建了一个名为MyLock的类,它继承自AbstractQueuedSynchronizer。在MyLock类中,我们重写了tryAcquire和tryRelease方法,用于实现锁的获取和释放逻辑。
在main方法中,我们创建了一个MyLock对象,并启动了两个线程。每个线程在执行任务之前,都需要先获取锁,然后在任务执行完毕后释放锁。由于锁是互斥的,所以只有一个线程能够同时获取锁。
通过使用 AQS,我们可以方便地实现各种同步器,如锁、信号量、栅栏等。AQS 的优点是通用性强、效率高、扩展性好,可以满足不同场景下的同步需求。

点下关注,不会迷路! 

这篇关于【JAVA进阶篇教学】第十五篇:Java中AQS讲解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/988760

相关文章

java中long的一些常见用法

《java中long的一些常见用法》在Java中,long是一种基本数据类型,用于表示长整型数值,接下来通过本文给大家介绍java中long的一些常见用法,感兴趣的朋友一起看看吧... 在Java中,long是一种基本数据类型,用于表示长整型数值。它的取值范围比int更大,从-922337203685477

java Long 与long之间的转换流程

《javaLong与long之间的转换流程》Long类提供了一些方法,用于在long和其他数据类型(如String)之间进行转换,本文将详细介绍如何在Java中实现Long和long之间的转换,感... 目录概述流程步骤1:将long转换为Long对象步骤2:将Longhttp://www.cppcns.c

SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程

《SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程》LiteFlow是一款专注于逻辑驱动流程编排的轻量级框架,它以组件化方式快速构建和执行业务流程,有效解耦复杂业务逻辑,下面给大... 目录一、基础概念1.1 组件(Component)1.2 规则(Rule)1.3 上下文(Conte

SpringBoot服务获取Pod当前IP的两种方案

《SpringBoot服务获取Pod当前IP的两种方案》在Kubernetes集群中,SpringBoot服务获取Pod当前IP的方案主要有两种,通过环境变量注入或通过Java代码动态获取网络接口IP... 目录方案一:通过 Kubernetes Downward API 注入环境变量原理步骤方案二:通过

Springboot整合Redis主从实践

《Springboot整合Redis主从实践》:本文主要介绍Springboot整合Redis主从的实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言原配置现配置测试LettuceConnectionFactory.setShareNativeConnect

Java中Map.Entry()含义及方法使用代码

《Java中Map.Entry()含义及方法使用代码》:本文主要介绍Java中Map.Entry()含义及方法使用的相关资料,Map.Entry是Java中Map的静态内部接口,用于表示键值对,其... 目录前言 Map.Entry作用核心方法常见使用场景1. 遍历 Map 的所有键值对2. 直接修改 Ma

Java中实现线程的创建和启动的方法

《Java中实现线程的创建和启动的方法》在Java中,实现线程的创建和启动是两个不同但紧密相关的概念,理解为什么要启动线程(调用start()方法)而非直接调用run()方法,是掌握多线程编程的关键,... 目录1. 线程的生命周期2. start() vs run() 的本质区别3. 为什么必须通过 st

关于跨域无效的问题及解决(java后端方案)

《关于跨域无效的问题及解决(java后端方案)》:本文主要介绍关于跨域无效的问题及解决(java后端方案),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录通用后端跨域方法1、@CrossOrigin 注解2、springboot2.0 实现WebMvcConfig

Java SWT库详解与安装指南(最新推荐)

《JavaSWT库详解与安装指南(最新推荐)》:本文主要介绍JavaSWT库详解与安装指南,在本章中,我们介绍了如何下载、安装SWTJAR包,并详述了在Eclipse以及命令行环境中配置Java... 目录1. Java SWT类库概述2. SWT与AWT和Swing的区别2.1 历史背景与设计理念2.1.

使用SpringBoot整合Sharding Sphere实现数据脱敏的示例

《使用SpringBoot整合ShardingSphere实现数据脱敏的示例》ApacheShardingSphere数据脱敏模块,通过SQL拦截与改写实现敏感信息加密存储,解决手动处理繁琐及系统改... 目录痛点一:痛点二:脱敏配置Quick Start——Spring 显示配置:1.引入依赖2.创建脱敏