1.Java并发系列 | Semaphore源码分析
2.AQS与ReentrantLock详解
3.后端面经-JavaAQS详解
4.AbstractQueuedSynchronizer详解
5.ReentrantLock 源码解析 | 京东云技术团队
6.Java并发必会，码全面深入剖析Semaphore源码

Java并发系列 | Semaphore源码分析

       在Java并发编程中，码全面Semaphore（信号量）是码全面AQS共享模式的实用工具，它能够控制多个线程对共享资源的码全面并发访问，实现流量控制。码全面Semaphore的码全面源码编程的视频教程核心概念是“许可证”，类似于公共汽车票，码全面只有获取到票的码全面线程才能进行操作。许可证数量有限，码全面当数量耗尽时，码全面后续线程需要等待，码全面直到有线程释放其许可证。码全面Semaphore构造器接受初始许可证数量，码全面可以选择公平或非公平的码全面获取方式。

       Semaphore提供了获取和释放许可证的码全面API，默认每次操作一个许可证。获取许可证有直接和尝试两种方式，直接获取可能阻塞，而尝试不会。acquire方法内部调用的是AQS的acquireSharedInterruptibly，它会尝试公平或非公平地获取，并在获取失败时决定是否阻塞。释放许可证则直接调用AQS的releaseShared方法，通过自旋循环确保同步状态的正确更新。

       Semaphore的应用广泛，本文通过实现一个简单的数据库连接池，展示了Semaphore如何控制连接的并发使用。连接池初始化时创建固定数量的连接，每次线程请求连接时需要获取许可证，释放连接时则释放许可证。测试结果验证了Semaphore有效管理连接并发并确保了流量控制。

       代码示例与测试结果表明，Semaphore通过控制许可证数量，确保了资源使用的合理调度，当连接池中所有连接被占用，后续请求将被阻塞，直到有连接被释放。这清楚地展示了Semaphore在并发控制中的作用。

AQS与ReentrantLock详解

       J.U.C包中的Java.util.concurrent是一个强大的并发工具库，包含多种处理并发场景的中介平台源码组件，如线程池、队列和同步器等，由知名开发者Doug Lea设计。本文将深入讲解Lock接口及其关键实现ReentrantLock，它在并发编程中的重要性不可忽视，因为大部分J.U.C组件都依赖于Lock来实现并发安全。

       Lock接口的出现，弥补了synchronized在某些场景中的不足，提供了更灵活的并发控制。ReentrantLock作为Lock的一种实现，支持重入，即同一线程可以多次获取锁而不必阻塞。这种特性在处理多方法调用场景时避免了死锁问题。

       ReentrantReadWriteLock则允许读写操作并发进行，提高了读操作的并发性，避免了写操作对读写操作的阻塞，适用于读多写少的场景。在内存缓存示例中，读写锁通过HashMap以读写锁保护，确保并发访问的线程安全。

       ReentrantLock的实现核心是AQS（AbstractQueuedSynchronizer），它是Lock实现线程同步的核心组件。AQS提供了独占和共享锁两种功能，如ReentrantLock就基于AQS的独占模式。AQS内部维护了一个volatile状态变量，不同的实现类根据其具体需求定义其含义。

       ReentrantLock的源码分析中，我们看到lock()方法如何通过AQS的队列机制实现线程阻塞和唤醒。例如，NofairSync.lock展示了非公平锁的实现，涉及CAS（Compare and Swap）操作，保证了线程安全。Unsafe类在这其中发挥了关键作用，提供了低层次的内存操作，如CAS操作。

       总结来说，ReentrantLock和AQS是Java并发编程中的重要基石，通过理解它们的工作原理，可以更好地应对并发环境中的恐怖故事源码问题。

后端面经-JavaAQS详解

       AQS是什么？

       AQS定义了一套多线程访问共享资源的同步器框架，许多同步类实现都依赖于它，如常用的ReentrantLock。简单来说，AQS定义了一套框架，来实现同步类。

       AQS的核心思想是对于共享资源，维护一个双端队列来管理线程，队列中的线程依次获取资源，获取不到的线程进入队列等待，直到资源释放，队列中的线程依次获取资源。AQS的基本框架如图所示：

       资源state变量表示共享资源，通常是int类型。CLH双向队列是一种基于逻辑队列非线程饥饿的自旋公平锁，具体介绍可参考此篇博客。CLH中每个节点都表示一个线程，处于头部的节点获取资源，而其他资源则等待。Node的方法和属性值如图所示：其中,

       一般来说，一个同步器是资源独占模式或者资源共享模式的其中之一，因此tryAcquire(int)和tryAcquireShared(int)只需要实现一个即可，tryRelease(int)和tryReleaseShared(int)同理。但是同步器也可以实现两种模式的资源获取和释放，从而实现独占和共享两种模式。

       acquire(int)是获取资源的顶层入口，tryAcquire(int)是获取资源的方法，需要自定义同步器实现。addWaiter(Node.EXCLUSIVE)是将线程加入等待队列的尾部，acquireQueued(Node node, int arg)将线程阻塞在等待队列中，直到获取到资源后才返回。

       release(int)是释放资源的顶层入口方法，tryRelease(int)是释放资源的方法，需要自定义同步器自己实现。unparkSuccessor(h)是唤醒后继节点的方法。

       acquireShared(int)和releaseShared(int)是使用共享模式获取共享资源的顶层入口方法，tryAcquireShared(arg)是获取共享资源的方法，doAcquireShared(arg)将线程阻塞在等待队列中，直到获取到资源后才返回。apk源码解密releaseShared(int)是释放共享资源的顶层入口方法，doReleaseShared()方法释放共享资源。

       面试问题模拟：AQS是接口吗？有哪些没有实现的方法？看过相关源码吗？

       A：AQS定义了一个实现同步类的框架，实现方法主要有tryAquire和tryRelease，表示独占模式的资源获取和释放，tryAquireShared和tryReleaseShared表示共享模式的资源获取和释放。源码分析如上文所述。

AbstractQueuedSynchronizer详解

       AbstractQueuedSynchronizer，简称AQS，究竟是什么呢？

       它提供了一个框架，用于实现基于先进先出（FIFO）等待队列的阻塞锁及相关同步器（如信号量、事件等）。这个类的设计目的是为了成为那些依赖单一原子整数值来表示状态的同步器的有效基础。

       从JDK的注释来看，AQS是一个实现阻塞锁和相关同步器的框架，它基于先进先出的等待队列。这个类适用于大多数使用整数来表示状态的同步器。这里提到的框架实际上是一个类。

       那么，在什么情况下我们会使用AQS呢？

       在编程中，我们经常遇到并发问题。有了并发，就涉及资源共享；而资源共享又需要处理资源的同步访问。在处理同步时，我们需要解决竞争发生时的等待问题和竞争解除后的唤醒问题。AQS就是这样一个便于实现这种同步机制的框架。我们日常使用的ReentrantLock、ReentrantReadWriteLock以及ArrayBlockingQueue等都是基于AQS实现的。

       如果没有AQS，又会如何呢？

       在没有AQS的情况下，要实现锁需要怎么做呢？这些问题都是我们在实现锁时需要考虑的。

       在AQS的情况下，情况又是怎样的呢？

       AQS作为基础类，主要解决了在锁不可用时的等待，以及锁释放后的唤醒。锁状态的设定、如何获取锁以及如何释放锁，都是需要相应的同步机制自己实现的。因此，在线tv源码在使用AQS时，需要实现以下方法：

       类似于ReentrantLock，使用state来标识锁的状态，state = 0表示锁未被获取，当state > 0表示锁已被获取。此外，实现了AQS的tryAcquire()和tryRelease()来处理state的状态，以处理锁的状态。这样就可以实现基础的ReentrantLock。因此，在AQS的支持下，实现类似的阻塞锁非常方便。

       以上我们介绍了AQS是什么，以及AQS的具体使用场景，下面我们详细介绍AQS的具体实现机制。

       我们先简单看一下AQS的核心流程。

       接下来，我们将结合ReentrantLock来详细查看基于AQS如何实现排他锁。

       首先，我们来看一下ReentrantLock是如何使用int类型的state来表示锁的状态的。state = 0表示锁未被获取。state > 0表示锁已被持有。由于是可重入锁，state表示了这个锁被同一个线程获取了多少次。

       上面的代码片段是ReentrantLock的核心代码，为了便于解释，省略了其他代码。首先我们可以看到，在使用AQS时，通常不是直接实现AQS，而是创建一个内部的辅助类。

       Subclasses should be defined as non-public internal helper classes that are used to implement the synchronization properties of their enclosing class

       然后加锁和释放锁对应的lock和unlock，直接调用辅助类的lock和unlock。

       下面我们来看一下Sync类的代码。

       上面我们来看一下非公平锁NonfairSync的实现。

       下面我们来看一下AQS中的acquire方法。

       上面我们看了获取锁的方法acquire，下面看下释放锁的release。

       总结一下，AQS通过tryAcquire以及tryRelease两个方法，来进行锁的获取以及释放，两个都是非阻塞的方法。如果获取成功则返回，如果获取失败，则添加队列。在队列中获取锁，获取失败则挂起，等待锁被释放后被重新唤醒。唤醒后还是会去尝试获取锁。释放锁的时候如果检查到已经全部释放，则会唤醒被挂起的线程。这样通过tryAcquire和tryRelease，实现了锁的获取以及等待，以及锁的释放。具体锁状态的控制，子类则是通过tryAcquire和tryRelease进行控制的。

       在介绍ReentrantLock时，我们简化了很多代码。了解基本原理后，再去读源码会事半功倍。

ReentrantLock 源码解析 | 京东云技术团队

       并发指同一时间内进行了多个线程。并发问题是多个线程对同一资源进行操作时产生的问题。通过加锁可以解决并发问题，ReentrantLock 是锁的一种。

       1 ReentrantLock

       1.1 定义

       ReentrantLock 是 Lock 接口的实现类，可以手动的对某一段进行加锁。ReentrantLock 可重入锁，具有可重入性，并且支持可中断锁。其内部对锁的控制有两种实现，一种为公平锁，另一种为非公平锁.

       1.2 实现原理

       ReentrantLock 的实现原理为 volatile+CAS。想要说明 volatile 和 CAS 首先要说明 JMM。

       1.2.1 JMM

       JMM (java 内存模型 Java Memory Model 简称 JMM) 本身是一个抽象的概念，并不在内存中真实存在的，它描述的是一组规范或者规则，通过这组规范定义了程序中各个变量的访问方式.

       由于 JMM 运行的程序的实体是线程。而每个线程创建时 JMM 都会为其创建一个自己的工作内存 (栈空间), 工作内存是每个线程的私有数据区域。而 java 内存模型中规定所有的变量都存储在主内存中，主内存是共享内存区域，所有线程都可以访问，但线程的变量的操作 (读取赋值等) 必须在自己的工作内存中去进行，首先要将变量从主存拷贝到自己的工作内存中，然后对变量进行操作，操作完成后再将变量操作完后的新值写回主内存，不能直接操作主内存的变量，各个线程的工作内存中存储着主内存的变量拷贝的副本，因不同的线程间无法访问对方的工作内存，线程间的通信必须在主内存来完成。

       如图所示：线程 A 对变量 A 的操作，只能是从主内存中拷贝到线程中，再写回到主内存中。

       1.2.2 volatile

       volatile 是 JAVA 的关键字用于修饰变量，是 java 虚拟机的轻量同步机制，volatile 不能保证原子性。 作用：

       作用：CAS 会使用现代处理器上提供的高效机器级别原子指令，这些原子指令以原子方式对内存执行读 - 改 - 写操作。

       1.2.4 AQSAQS 的全称是 AbstractQueuedSynchronizer（抽象的队列式的同步器），AQS 定义了一套多线程访问共享资源的同步器框架。

       AQS 主要包含两部分内容：共享资源和等待队列。AQS 底层已经对这两部分内容提供了很多方法。

       2 源码解析

       ReentrantLock 在包 java.util.concurrent.locks 下，实现 Lock 接口。

       2.1 lock 方法

       lock 分为公平锁和非公平锁。

       公平锁：

       非公平锁：上来先尝试将 state 从 0 修改为 1，如果成功，代表获取锁资源。如果没有成功，调用 acquire。state 是 AQS 中的一个由 volatile 修饰的 int 类型变量，多个线程会通过 CAS 的方式修改 state，在并发情况下，只会有一个线程成功的修改 state。

       2.2 acquire 方法

       acquire 是一个业务方法，里面并没有实际的业务处理，都是在调用其他方法。

       2.3 tryAcquire 方法

       tryAcquire 分为公平和非公平两种。

       公平：

       非公平：

       2.4 addWaiter 方法

       在获取锁资源失败后，需要将当前线程封装为 Node 对象，并且插入到 AQS 队列的末尾。

       2.5 acquireQueued 方法

       2.6 unlock 方法

       释放锁资源，将 state 减 1, 如果 state 减为 0 了，唤醒在队列中排队的 Node。

       3 使用实例

       3.1 公平锁

       1. 代码：

       2. 执行结果：

       3. 小结：

       公平锁可以保证每个线程获取锁的机会是相等的。

       3.2 非公平锁

       1. 代码：

       2. 执行结果：

       3. 小结：

       非公平锁每个线程获取锁的机会是随机的。

       3.3 忽略重复操作

       1. 代码：

       2. 执行结果：

       3. 小结：

       当线程持有锁时，不会重复执行，可以用来防止定时任务重复执行或者页面事件多次触发时不会重复触发。

       3.4 超时不执行

       1. 代码：

       2. 执行结果：

       3. 小结：

       超时不执行可以防止由于资源处理不当长时间占用资源产生的死锁问题。

       4 总结

       并发是现在软件系统不可避免的问题，ReentrantLock 是可重入的独占锁，比起 synchronized 功能更加丰富，支持公平锁实现，支持中断响应以及限时等待等，是处理并发问题很好的解决方案。

Java并发必会，深入剖析Semaphore源码

       在深入理解Java并发编程时，必不可少的是对Semaphore源码的剖析。本文将带你探索这一核心组件，通过实践和源码解析，掌握其限流和共享锁的本质。Semaphore，中文名信号量，就像一个令牌桶，任务执行前需要获取令牌，处理完毕后归还，确保资源访问的有序进行。

       首先，Semaphore主要有acquire()和release()两个方法。acquire()负责获取许可，若许可不足，任务会被阻塞，直到有许可可用。release()用于释放并归还许可，确保资源释放后，其他任务可以继续执行。一个典型的例子是，如果一个线程池接受个任务，但Semaphore限制为3，那么任务将按每3个一组执行，确保系统稳定性。

       Semaphore的源码实现巧妙地结合了AQS（AbstractQueuedSynchronizer）框架，通过Sync同步变量管理许可数量，公平锁和非公平锁的实现方式有所不同。公平锁会优先处理队列中的任务，而非公平锁则按照获取许可的顺序进行。

       acquire()方法主要调用AQS中的acquireSharedInterruptibly()，并进一步通过tryReleaseShared()进行许可更新，公平锁与非公平锁的区别在于判断队列中是否有前置节点。release()方法则调用releaseShared()，更新许可数量。

       Semaphore的简洁逻辑在于，AQS框架负责大部分并发控制，子类只需实现tryReleaseShared()和tryAcquireShared()，专注于许可数量的管理。欲了解AQS的详细流程，可参考之前的文章。

       最后，了解了Semaphore后，我们还将继续探索共享锁CyclicBarrier的实现，敬请期待下篇文章。

信号量（Semaphore）从入门到源码精通

       Semaphore是一个用于同步的工具类，在并发编程中扮演重要角色。PV操作是Semaphore的核心操作，P代表获取许可，V代表释放许可。P操作会检查许可是否可用，若可用则获取并返回，否则阻塞直到许可可用；V操作则释放一个许可。

       Semaphore的使用场景主要涉及线程间的同步，比如在资源有限的情况下控制多个线程对资源的访问。例如，当一个队列只允许一定数量的线程同时访问时，可以使用Semaphore来限制队列访问的线程数量。

       使用Semaphore的方式是通过构造方法创建实例，然后使用acquire和release方法来控制许可的获取和释放。acquire方法接受一个参数，表示需要获取的许可数量，默认为1，如果当前可用许可数不足，线程将阻塞直到许可可用。release方法则释放指定数量的许可，通常为1。

       要深入理解Semaphore源码，建议从AQS（AbstractQueuedSynchronizer）的基础开始。AQS提供了对同步器的基本抽象，Semaphore正是基于AQS实现的一种同步工具。

       对于具体源码分析，可以重点关注Semaphore的构造方法、获取锁方法（acquire）以及释放锁方法（release）。在源码中，acquire方法通过调用tryAcquireShared方法尝试获取许可，如果成功则返回true，否则阻塞直到许可可用。release方法则简单地调用releaseShared方法释放一个许可。

       深入学习Semaphore和并发编程，可以参考内核技术中文网的相关资源。该网站提供了一些学习资料和交流社区，包括Linux内核源码学习路线、视频教程、电子书以及实战项目和代码等。此外，网站还定期更新内核技术资料包，供学习者免费获取。