CountDownLatch源码解析加流程图详解--AQS类注释翻译

2024-06-04 03:38

本文主要是介绍CountDownLatch源码解析加流程图详解--AQS类注释翻译,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

功能定义

这个类是一个叫名Doug Lea的java 并发大神开发的。 是在jdk1.5中添加的。其官方解释为:

A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.

他的意思是CountDownLatch是一个同步工具,他的功能是允许一个或多个线程处于等待状态,直到其他的线程执行完成一组操作后。

CountDownLatch的初始化需要一个计数器, 调用await()方法会被锁住直到当前的计数器由于调用countDown()方法到达0的时候,所有的等待线程会被立即释放并且随后在使用await()方法也会马上结束。不会在有等待效果。这个方法只能使用一次,无法重置计数。如果你想使用重复计数,可以使用CyclicBarrier。

CountDownLatch 是一个多用途同步工具可以用在很多场景中。使用计数器一来初始化CountDownlatch来提供一个插销。可以把这个过程比如 一个门: 所有的线程调用await方法就会在门那里待等,直接到有一个线程调用countDown()方法,拔到了插销,门就打开了。 CountDownLatch 初始计数器设置为N的话,可以让一个线程一直等待,直到有N个线程完成一些工作并调用countDown()方法,或者一些线程完成一些工作后调用N次countDown()方法。

这里有一个问题: 这句话是CountDownLatch 源码中的英文注释 , 我不太会翻译。 如果有能翻译的,请在下方留言。万分感谢。

A useful property of a {@code CountDownLatch} is that it
doesn’t require that threads calling {@code countDown} wait for
the count to reach zero before proceeding, it simply prevents any
thread from proceeding past an {@link #await await} until all
threads could pass.

下面一个案例:

/*** description:* author: 田培融* date: 2020-08-07 10:18*/
public class Driver {public static void main(String[] args) throws InterruptedException {int n = 5;CountDownLatch startSignal = new CountDownLatch(1);CountDownLatch doneSignal = new CountDownLatch(n);for (int i = 0; i < n; i++) {new Thread(new Worker(startSignal,doneSignal)).start();}System.out.println("开始工作");startSignal.countDown();doneSignal.await();System.out.println("工作结束 ");}static class Worker implements  Runnable{private final  CountDownLatch startSignal;private final  CountDownLatch doneSignal;public Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {this.startSignal = startSignal;this.doneSignal = doneSignal;}@Overridepublic void run() {try {startSignal.await();doWork();doneSignal.countDown();} catch (InterruptedException e) {e.printStackTrace();}}void doWork(){System.out.println("工作...");}}
}

解析全生命周期

创建

创建只需要一个 new 出一个新对象来就可以了。

 CountDownLatch startSignal = new CountDownLatch(1);

源码

 public CountDownLatch(int count) {if (count < 0) throw new IllegalArgumentException("count < 0");this.sync = new Sync(count);}

count如果小于零就会抛出异常。 通过count构建出Sync对象。

Sync做为CountDownLatch的内部类, 继承AbstractQueueSynchronizer。这个类为CountDownLatch提供同步控制 ,使用AQS 状态来维护计数器。
在这里插入图片描述

创建Sync的时候需要传一个值, 这个值最终被设置到AQS中的state中。

在这里插入图片描述

这段代码就是AbstractQueuedSynchronizer.java中的赋值操作. state 被volatitle修饰来保证内存的可见性。先不介绍AQS中state的具体意思,下面的内容会有介绍。

  /*** The synchronization state.*/private volatile int state;/*** Sets the value of synchronization state.* This operation has memory semantics of a {@code volatile} write.* @param newState the new state value*/protected final void setState(int newState) {state = newState;}

这样初始化的操作就完成了。

await() 等待方法

先来看看await()在CountDownLatch中的代码

 /*** Causes the current thread to wait until the latch has counted down to* zero, unless the thread is {@linkplain Thread#interrupt interrupted}.** <p>If the current count is zero then this method returns immediately.** <p>If the current count is greater than zero then the current* thread becomes disabled for thread scheduling purposes and lies* dormant until one of two things happen:* <ul>* <li>The count reaches zero due to invocations of the* {@link #countDown} method; or* <li>Some other thread {@linkplain Thread#interrupt interrupts}* the current thread.* </ul>** <p>If the current thread:* <ul>* <li>has its interrupted status set on entry to this method; or* <li>is {@linkplain Thread#interrupt interrupted} while waiting,* </ul>* then {@link InterruptedException} is thrown and the current thread's* interrupted status is cleared.** @throws InterruptedException if the current thread is interrupted*         while waiting*/public void await() throws InterruptedException {sync.acquireSharedInterruptibly(1);}

我们来翻译一些这个英文注释 。

让当前线程一直等待,直到 count计数器减到0。除非线程被打断,就会抛出异常。
如果当前计数器是0的话,这个await()方法就会直接放行。
如果当前计数器比0大的话那么当前线程就会停止重新调度并处于休眠状态,直到触发下面的条件:

  1. 调用countDown()方法,使用当前计数器减到0。
  2. 其他的线程调用 intertrupt()方法打断这个线程。

哪果当前线程在进入await()方法之前已经处于中断状态 ,或者等待时被中断那么就会抛出一个InterruptedException异常并且这个线程的打断状态也会被清除。

以上就是官方注释对这个方法的解释,翻译的不是很准确包括了我自己的一点理解 。
await()方法中调用了 AbstractQueueSynchronizer.java 中的 sync.acquireSharedInterruptibly(1); 从方法名上简单理解是 获取同步共享等待

下面我们就到AbstractQueueSynchronizer.java中去看一看这个方法。

/*** Acquires in shared mode, aborting if interrupted.  Implemented* by first checking interrupt status, then invoking at least once* {@link #tryAcquireShared}, returning on success.  Otherwise the* thread is queued, possibly repeatedly blocking and unblocking,* invoking {@link #tryAcquireShared} until success or the thread* is interrupted.* @param arg the acquire argument.* This value is conveyed to {@link #tryAcquireShared} but is* otherwise uninterpreted and can represent anything* you like.* @throws InterruptedException if the current thread is interrupted*/public final void acquireSharedInterruptibly(int arg)throws InterruptedException {if (Thread.interrupted())throw new InterruptedException();if (tryAcquireShared(arg) < 0)doAcquireSharedInterruptibly(arg);}

以共享模式获取,如果调用interrupted()则中止。 首先需要通过检查当前线程的interrupted状态,然后调用tryAcquiredShared(arg)方法。返回值,检查大小。否则线程就会等待,可能会反复的阻塞和取消阻塞直接调用 tryAcquireShared成功或者被打断。

在这里他会调用两个方法,这里我们先看第一个。tryAcquireShared() 这个方法在 CountDownLatch.java中的内部类被重写了。
在这里插入图片描述
这里会获取CountDownLatch刚创建的时候传递给AQS的计数器,这里在重复一遍。 CountDownLatch内部内Sync继承了AQS,在创建CountDownLatch的时候会将计数器传递给AQSAQS就是使用的这个state来接收的。 在JUC的其他并发工具中也有很多继承使用了AQS,都使用了state,但是代表的意思在不同的工具中是不同的。

这里表示的是如果计数器等于0的话就会返回1如果不等0的话就会返回-1。 我们初始化的时候 给计数器设置的值是3,此时获取到的state的值就是3,返回的就是-1。条件就会成立,并执行doAcquireSharedInterruptibly(arg)方法。

  if (tryAcquireShared(arg) < 0)doAcquireSharedInterruptibly(arg);

下面我们就看看这个private void doAcquireSharedInterruptibly(int arg) 方法做了什么。

 /*** Acquires in shared interruptible mode.* @param arg the acquire argument*/private void doAcquireSharedInterruptibly(int arg)throws InterruptedException {final Node node = addWaiter(Node.SHARED);boolean failed = true;try {for (;;) {final Node p = node.predecessor();if (p == head) {int r = tryAcquireShared(arg);if (r >= 0) {setHeadAndPropagate(node, r);p.next = null; // help GCfailed = false;return;}}if (shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt())throw new InterruptedException();}} finally {if (failed)cancelAcquire(node);}}

我们先看开头的方法注释,获取共享可中断模型。这里的参数arg的值是1,是在CountDownLatch方法中传入的。 他这里会进入一个自循环阻塞当前线程,直到state 减到0为止,或者线程被中断。 先整体的理解一下这断代码的意思。 下面我们就开始开始梳理一下这个方法中用到的AQS中的元素。

梳理一下AQS来解释doAcquireSharedInterruptibly方法

首先我们到AQS的类最开始的位置看到有很多英文, 我们就先来翻译一下这些英文。看看 Doug Lea大神给这个类的定义。

提供一个框架用于开发依赖于先进先出等待队列的阻塞锁和相关容器(信号量,事件等等)。这个类被设计为一些依赖于单个原子整型表示状态的同步容器的基础。(也就是说我们在设计开发同步容器的时候,如果使用了单个原子整型表示状态了, 就可以使用AQS。)。 子类必须定义一个protected方法来修改状态,并定义这个状态在这个状态中减或者加是什么意思。(此处翻译的感觉不太对劲。。。)。
根据这些,AQS类中的其他方法执行其他的队列和阻塞机制。子类可以维护其他的状态字段,关于同步操作状态值必须使用getState setState``compareAndSetState这三个方法。

子类应该定义一个非public的内部类,用于初始化封闭类的同步属性。AbstractQueuedSynchronizer类不实现 任何同步接口。(在CountDownLatch中就是Sync类 哪下图

在这里插入图片描述

相反,它定义了方法比如acquireInterruptibly()来调用适合的具体哪种锁和相关同步容器来实现公共方法。

AQS类介绍

这个类支持一个或者两个独占模型和共享模型。当获取独占模型,其他线程不能在试图获取。共享模型可以多个线程获取。当一个共享模型获取他们的区别是机械意义上的。下一个等待线程也必须确定是否可以获取成功。在不同的的模型下线程共享相同的FIFO队列。通常,实现的子类只支持一种模型,但是在ReadWriteLock中两种模型都是可以的。只支持独占模型或者只支持共享模型的不需要定义未使用的模型方法。

ConditionObject类

AQS内部定义了一个内容部ConditionObject,它实现了Condition类,支持isHeldExclusively 方法,报告这个线程是否是独占的。
release 方法:调用getState方法和acquire方法修改保存当前状态值。最终恢复这个对象以前获取到的状态值。没有其他方法来创造这样的条件 ,如果这个条件不被满足请不要使用它。 ConditionObject的行为取决行实现容器的语义。

在次回到AQS中

这个类内部队列提供检查,检测,监控的方法,以及类似于条件对象的方法。可以根据需要将他们导入到类中,以实现他们的同步机制。
这个类的序列化对象中存储底层的原子整型维护状态,因此反序列化对象有一个空的线程队列。需要序列化的典型子类将定义一个readObject方法,在反序列化的时恢复到已知的状态。

案例介绍

使用这个类作为同步容器的基础类,需要重新定义以下方法,如检查或者修改同步状态使用getState方法,setState方法,或者compareAndSetState。 下面的这些方法在juc的工具有很多都有实现如ReentrantLock.java中,可以在里面看到实现方法。 会发现有使用到getState方法。
在这里插入图片描述
上面的第一个方法都会抛出一个UnsupportedOperationException 异常。实现这些方法的通常是内部线程安全的(在这里我理解为通常是由protected修饰的方法) 。通常应该是短的和非阻塞的。 定义这些方法是使用这个类唯一受支持的方法。

推荐博客: AQS介绍

CountDownLatch.await()流程

在这里插入图片描述

交个朋友吧

在这里插入图片描述

这篇关于CountDownLatch源码解析加流程图详解--AQS类注释翻译的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1028960

相关文章

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库,完全使用 Python 语言编写,它对 XPath表达式提供了良好的支 持,因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块,该模块专门用来解析 HTML/XML 文档,下面来介绍一下 lxml 库

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

OpenHarmony鸿蒙开发( Beta5.0)无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息,即可快速实现设备配网,是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递,利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力,实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后,即可发送相关配网数据。同时还支持与常规Sof

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

6.1.数据结构-c/c++堆详解下篇(堆排序,TopK问题)

上篇:6.1.数据结构-c/c++模拟实现堆上篇(向下,上调整算法,建堆,增删数据)-CSDN博客 本章重点 1.使用堆来完成堆排序 2.使用堆解决TopK问题 目录 一.堆排序 1.1 思路 1.2 代码 1.3 简单测试 二.TopK问题 2.1 思路(求最小): 2.2 C语言代码(手写堆) 2.3 C++代码(使用优先级队列 priority_queue)

Java ArrayList扩容机制 (源码解读)

结论:初始长度为10,若所需长度小于1.5倍原长度,则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1:数组默认长度         2:这是一个共享的空数组实例,用于明确创建长度为0时的ArrayList ,比如通过 new ArrayList<>(0),ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL

如何在Visual Studio中调试.NET源码

今天偶然在看别人代码时,发现在他的代码里使用了Any判断List<T>是否为空。 我一般的做法是先判断是否为null,再判断Count。 看了一下Count的源码如下: 1 [__DynamicallyInvokable]2 public int Count3 {4 [__DynamicallyInvokable]5 get

工厂ERP管理系统实现源码(JAVA)

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本,并实时掌握各环节的运营状况。 在采购管理方面,系统能够处理采购订单、供应商管理和采购入库等流程,确保采购过程的透明和高效。仓库管理方面,实现库存的精准管理,包括入库、出库、盘点等操作,确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、

K8S(Kubernetes)开源的容器编排平台安装步骤详解

K8S(Kubernetes)是一个开源的容器编排平台,用于自动化部署、扩展和管理容器化应用程序。以下是K8S容器编排平台的安装步骤、使用方式及特点的概述: 安装步骤: 安装Docker:K8S需要基于Docker来运行容器化应用程序。首先要在所有节点上安装Docker引擎。 安装Kubernetes Master:在集群中选择一台主机作为Master节点,安装K8S的控制平面组件,如AP