皮皮网

1.Springboot基于Redisson实现Redis分布式可重入锁【案例到源码分析】
2.源码分析： Java中锁的重入种类与特性详解
3.详解Java可重入锁ReentrantLock
4.Redisson可重入锁加锁源码分析
5.Python中可重入锁（RLock）的理解
6.ReentrantLock 源码解析 | 京东云技术团队

Springboot基于Redisson实现Redis分布式可重入锁【案例到源码分析】

       一、前言

       实现Redis分布式锁，锁源实现最初常使用SET命令，码重配合Lua脚本确保原子性。入锁然而手动操作较为繁琐，原理官网推荐使用Redisson，重入棋牌源码源码简化了分布式锁的锁源实现实现。本文将从官网至整合Springboot，码重直至深入源码分析，入锁以单节点为例，原理详细解析Redisson如何实现分布式锁。重入

       二、锁源实现为什么使用Redisson

       通过访问Redis中文官网，码重我们发现官方明确指出Java版分布式锁推荐使用Redisson。入锁官网提供了详细的原理文档和结构介绍，帮助开发者快速上手。

       三、Springboot整合Redisson

       为了实现与Springboot的集成，首先导入Redisson依赖。接下来，参照官网指导进行配置，并编写配置类。结合官网提供的加锁示例，编写简单的Controller接口，最终测试其功能。

       四、lock.lock()源码分析

       在RedissonLock实现类中，`lock`方法的实现揭示了锁获取的流程。深入至`tryLockInnerAsync`方法，发现其核心逻辑。进一步调用`scheduleExpirationRenewal`方法，用于定时刷新锁的过期时间，确保锁的有效性。此过程展示了锁实现的高效与自适应性。

       五、lock.lock(, TimeUnit.SECONDS)源码分析

       当使用带有超时时间的`lock`方法时，实际调用的逻辑与常规版本类似，关键差异在于`leaseTime`参数的不同设置。这允许开发者根据需求灵活控制锁的持有时间。

       六、lock.unlock()源码分析

       解锁操作通过`unlockAsync`方法实现，进一步调用`unlockInnerAsync`方法完成。这一过程确保了锁的释放过程也是异步的，增强了系统的并发处理能力。

       七、总结

       通过本文，我们跟随作者深入Redisson的底层源码，理解了分布式锁的实现机制。这一过程不仅提升了对Redisson的理解，也激发了面对复杂技术挑战时的勇气。希望每位开发者都能勇敢探索技术的边界，共同进步。欢迎关注公众号，怎么编译eclipse 源码获取更多技术文章首发信息。

源码分析： Java中锁的种类与特性详解

       在Java中存在多种锁，包括ReentrantLock、Synchronized等，它们根据特性与使用场景可划分为多种类型，如乐观锁与悲观锁、可重入锁与不可重入锁等。本文将结合源码深入分析这些锁的设计思想与应用场景。

       锁存在的意义在于保护资源，防止多线程访问同步资源时出现预期之外的错误。举例来说，当张三操作同一张银行卡进行转账，如果银行不锁定账户余额，可能会导致两笔转账同时成功，违背用户意图。因此，在多线程环境下，锁机制是必要的。

       乐观锁认为访问资源时不会立即加锁，仅在获取失败时重试，通常适用于竞争频率不高的场景。乐观锁可能影响系统性能，故在竞争激烈的场景下不建议使用。Java中的乐观锁实现方式多基于CAS（比较并交换）操作，如AQS的锁、ReentrantLock、CountDownLatch、Semaphore等。CAS类实现不能完全保证线程安全，使用时需注意版本号管理等潜在问题。

       悲观锁则始终在访问同步资源前加锁，确保无其他线程干预。ReentrantLock、Synchronized等都是典型的悲观锁实现。

       自旋锁与自适应自旋锁是另一种锁机制。自旋锁在获取锁失败时采用循环等待策略，避免阻塞线程。自适应自旋锁则根据前一次自旋结果动态调整等待时间，提高效率。

       无锁、偏向锁、轻量级锁与重量级锁是Synchronized的锁状态，从无锁到重量级锁，锁的竞争程度与性能逐渐增加。Java对象头包含了Mark Word与Klass Pointer，Mark Word存储对象状态信息，而Klass Pointer指向类元数据。

       Monitor是实现线程同步的关键，与底层操作系统的Mutex Lock相互依赖。Synchronized通过Monitor实现，其效率在JDK 6前较低，但JDK 6引入了偏向锁与轻量级锁优化性能。编程猫 源码学生

       公平锁与非公平锁决定了锁的分配顺序。公平锁遵循申请顺序，非公平锁则允许插队，提高锁获取效率。

       可重入锁允许线程在获取锁的同一节点多次获取锁，而不可重入锁不允许。共享锁与独占锁是另一种锁分类，前者允许多个线程共享资源，后者则确保资源的独占性。

       本文通过源码分析，详细介绍了Java锁的种类与特性，以及它们在不同场景下的应用。了解这些机制对于多线程编程至关重要。此外，还有多种机制如volatile关键字、原子类以及线程安全的集合类等，需要根据具体场景逐步掌握。

详解Java可重入锁ReentrantLock

       Java的高级线程同步工具ReentrantLock提供了更灵活的线程同步机制。作为可重入锁，它允许同一线程多次获取锁而不致死锁。ReentrantLock特性包括：

       可重入性：一个线程可以多次获取同一锁。

       公平性和非公平性：ReentrantLock支持两种模式，非公平模式允许新线程直接获取锁，可能导致线程饥饿。

       操作流程：通过try/finally确保锁的获取和释放，增强控制。

       中断响应：支持中断操作。

       条件变量：支持更复杂的条件判断和同步。

       与synchronized对比：ReentrantLock功能更丰富，但使用更复杂。

       使用ReentrantLock时，应确保在finally块中释放锁，以处理异常情况。在非公平锁中，新线程有机会直接获取，但可能导致FIFO原则的中断。

       ReentrantLock的非公平锁实现依赖于锁状态管理、CAS操作和等待队列，提供了性能优势，但需根据应用需求权衡公平与非公平。

       总结，ReentrantLock的公平锁与synchronized在行为、灵活性和性能上存在差异，ReentrantLock提供了更高级的控制选项，但使用时需注意复杂性。

Redisson可重入锁加锁源码分析

       在分布式环境中，控制并发的关键往往需要分布式锁。Redisson，作为Redis的高效客户端，其源码清晰易懂，这里主要探讨Redisson可重入锁的加锁原理，以版本3..5为例，php5.6.9 源码但重点是理解其核心逻辑，而非特定版本。

       加锁始于用户通过`redissonClient`获取RLock实例，并通过`lock`方法调用。这个过程最后会进入`RLock`类的`lock`方法，核心步骤是`tryAcquire`方法。

       `tryAcquire`方法中，首先获取线程ID，用于标识是哪个线程在请求锁。接着，尝试加锁的真正核心在`tryAcquireAsync`，它嵌套了`get`方法，这个get方法会阻塞等待异步获取锁的结果。

       在`tryAcquireAsync`中，如果锁的租期未设置，会使用默认的秒。脚本执行是加锁的核心，一个lua脚本负责保证命令的原子性。脚本中，`keys`和`argv`参数处理至关重要，尤其是判断哈希结构`_come`的键值对状态。

       脚本逻辑分为三个条件：如果锁不存在，会设置并设置过期时间；如果当前线程已持有锁，会增加重入次数并更新过期时间；若其他线程持有，加锁失败并返回剩余存活时间。加锁失败时，系统会查询锁的剩余时间，用于后续的重试策略。

       加锁成功后，会进行自动续期，通过`Future`监听异步操作结果。如果锁已成功获取且未设置过期时间，会定时执行`scheduleExpirationRenewal`，每秒检查锁状态，延长锁的存活时间。

       整个流程总结如下：首先通过lua脚本在Redis中创建和更新锁的哈希结构，对线程进行标识。若无过期时间，定时任务会确保锁的持续有效。重入锁通过`hincrby`增加键值对实现。加锁失败后，客户端会等待锁的剩余存活时间，再进行重试。

       至于加锁失败的处理，客户端会根据剩余存活时间进行阻塞，等待后尝试再次获取锁。这整个流程展现了Redisson可重入锁的简洁设计，主要涉及线程标识、原子操作和定时续期等关键点。

Python中可重入锁（RLock）的理解

       理解Python中可重入锁（RLock）的工作原理，首先回顾threading模块的lock、lock.acquire()、sohu源码代下载lock.release()的实现原理：通过机器指令确保"上锁"过程的原子化，当锁被某个线程持有，其他线程获取锁时，会处于忙碌等待状态。

       RLock如何确保线程内部多次调用不会堵塞？答案在于其底层维护的互斥锁和计数器。当一个线程通过acquire()获取锁时，它会检查当前线程是否已经拥有锁。如果是同一线程，则计数器加1，函数立即返回。否则，调用底层锁进行阻塞，实现重入效果。

       以Python语言实现的RLock为例，通过结合acquire()方法的源码和流程图，可以清晰看到：第一次获取锁时，调用_thread模块的acquire()方法，后续获取只需计数器加1；当其他线程尝试获取时，则调用_thread模块的 _allocate_lock()方法阻塞自身。

       这解决了文章开头提出的问题：在多级线程内部多次调用RLock时，只有第一次调用时真正获取锁，后续调用仅增加计数器值，而其他线程获取锁时会因调用底层锁而被阻塞。

       在实现上，Python语言和C语言版本的RLock方法一致，关键在于利用互斥锁和计数器机制确保线程安全与高效性。

       欢迎探讨和指正，希望本文能帮助理解RLock的运作机制。

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中的各种锁详细介绍

       Java提供了多种锁以满足不同的并发需求，这些锁的特性各异，适用于不同的场景。本文旨在概述锁的源码（JDK 8版本），并举例说明使用场景，帮助读者理解锁的知识点以及不同锁的适用情况。接下来，我们将按照以下结构进行分类介绍：乐观锁 vs 悲观锁、自旋锁 vs 适应性自旋锁、无锁 vs 偏向锁 vs 轻量级锁 vs 重量级锁、公平锁 vs 非公平锁、可重入锁 vs 非可重入锁、独享锁 vs 共享锁。

       乐观锁 vs 悲观锁

       乐观锁与悲观锁基于对并发操作的预设不同。悲观锁假设并发操作中一定会出现数据修改，因此在获取数据时会先加锁，以防止数据被修改。在Java中，synchronized关键字和Lock接口的实现类多采用悲观锁策略。相反，乐观锁假设并发操作中不会修改数据，只在尝试修改数据时检查数据是否已被修改，若数据未被修改则成功完成操作，否则根据情况采取不同的策略。

       自旋锁 vs 适应性自旋锁

       自旋锁是一种在无需阻塞线程的情况下，通过循环检查条件来尝试获取锁的机制。当锁长时间未被释放时，自旋锁会导致线程持续消耗处理器资源，因此引入了适应性自旋锁。适应性自旋锁会根据前一次自旋等待的时间和锁的持有者状态来决定是否继续自旋或立即阻塞线程。

       无锁 vs 偏向锁 vs 轻量级锁 vs 重量级锁

       锁的状态从无锁升级到重量级锁，主要依据锁的竞争情况和锁的状态。无锁允许所有线程同时访问资源，但只有一个线程能修改成功。偏向锁是为单线程操作而优化的锁，可以避免不必要的锁操作。轻量级锁在偏向锁被其他线程尝试访问时升级，通过自旋和CAS操作尝试获取锁。重量级锁则在多线程竞争时，通过阻塞等待线程来获取锁。

       公平锁 vs 非公平锁

       公平锁按照申请锁的顺序为线程分配锁，确保等待的线程不会饿死，但可能降低整体吞吐效率。非公平锁则直接尝试获取锁，可能导致后申请锁的线程先获取到锁，从而提高吞吐效率，但存在饿死等待线程的风险。

       可重入锁 vs 非可重入锁

       可重入锁允许线程在嵌套调用时重复获取同一锁，避免死锁。非可重入锁不允许重复获取同一锁，可能导致死锁情况。

       独享锁 vs 共享锁

       独享锁一次只能被一个线程持有，允许多线程同时读取数据但不允许写操作。共享锁则允许多个线程同时读取数据，但不允许写操作，以提高并发读取效率。

       通过以上分类介绍，我们可以更直观地理解Java中锁的特性和适用场景。不同锁的设计旨在解决特定的并发问题，选择合适的锁类型可以显著提升程序的性能和稳定性。

到底什么是重入锁，拜托，一次搞清楚！

       重入锁在编程中扮演着关键角色，尤其在并发编程中，理解这一概念变得至关重要。在众多锁类型中，`ReentrantLock` 是一个引人注目的存在。今天，让我们深入探讨重入锁及其特性，为理解这一概念提供清晰的视角。

       首先，让我们聚焦于`ReentrantLock`。它是 JDK 1.5 时期引入的一种更为灵活的锁实现，其主要目标是替代 `synchronized` 关键字，提供更高级的功能。从类结构图中可见，`ReentrantLock` 实现了 `Lock` 接口，表明它是一个锁的实现类，而非接口。

       名称“重入锁”源自其核心特性——允许多次进入同一锁，但仅限于当前线程。这种特性源自“Re-Entrant”一词，意味着可以反复进入。设想一下，若锁不具备这种能力，线程反复给自己加锁时，最终会导致死锁。因此，重入锁的设计旨在允许线程多次加锁，同时确保锁的释放次数与加锁次数相匹配。

       接下来，让我们探讨重入锁中几个关键方法及其用途。

       `lock()` 方法用于获取锁，其逻辑涉及三种情况。`lockInterruptibly()` 方法与 `lock()` 类似，但具备在获取锁过程中响应中断的能力。`tryLock()` 方法尝试获取锁，返回值指示是否成功。`tryLock(long timeout, TimeUnit unit)` 方法同样尝试获取锁，但加入了等待时间限制。最后，`unlock()` 方法用于释放锁，每次释放减少锁持有者数量，直至为零。此方法确保锁的释放次数与加锁次数相匹配。

       此外，`ReentrantLock` 提供了 `newCondition` 方法，返回一个锁的 Condition 实例。这使得在多线程通信中实现类似于 `wait` 和 `notify` 的功能变得更为灵活、强大。

       尽管 `synchronized` 关键字通常被视为一种锁实现，但它实际上也具备重入性。我们可以通过一个简单的例子来验证这一点。若一个方法内部调用另一个同样使用 `synchronized` 的方法，后者可以成功获取当前线程已持有的锁，从而证明 `synchronized` 实际上也是重入锁。

       总结而言，重入锁是并发编程中不可或缺的工具，它提供了更为灵活的锁管理机制。通过掌握重入锁的基本概念及其用法，我们能够更高效地处理多线程环境中的同步问题。尽管本文未能涵盖重入锁的所有高级概念与实战应用，但后续文章将深入探讨这一主题，敬请关注。

ReentrantLock的底层原理

       本文总结了Java自带的可重入锁ReentrantLock的底层原理，通过CAS（Compare and Swap）和AQS（AbstractQueuedSynchronizer）队列技术实现。

       CAS（Compare and Swap）是一种无锁算法，通过比较内存值与预期值，当两者相同时更新内存值。在Java中，CAS由sun.misc.Unsafe类通过JNI调用CPU底层指令实现。尽管速度极快，但可能遇到cache miss，导致CPU时间消耗。

       AQS用于构建锁和同步容器，使用FIFO队列表示等待锁的线程。队列头节点称为“哨兵节点”，其他节点与线程关联，每个节点维护等待状态waitStatus。通过CAS操作在队列中进行线程等待。

       ReentrantLock的实现通过2个构造函数：lock()和unlock()。lock()尝试通过CAS修改state，若失败则调用acquire()。acquire()先尝试tryAcquire()，若失败且当前线程已占锁，则重入锁（state++），否则进入等待队列并挂起线程。

       tryAcquire()检查state字段，若为0表示未占用，尝试占用；若不为0，检查是否被当前线程占用，若是则更新state表示重入次数。如果以上两点均未成功，则获取锁失败，返回false。

       addWaiter()将当前线程加入AQS双向链表队列，写入前将线程包装为Node对象。enq()确保一定写入队列，使用自旋加CAS保证并发安全。

       acquireQueued()写入队列后挂起线程。根据上一个节点状态判断是否获取锁，若失败则调用parkAndCheckInterrupt()，利用LockSupport的park方法挂起线程直到被唤醒。

       unlock()释放锁时state--，通过state==0判断完全释放，成功释放后唤起挂起的线程。

       总结，ReentrantLock通过AQS队列记录申请锁线程信息，利用大量CAS保证并发安全，维护state变量实现可重入功能。公平锁通过队列顺序获取锁，但可能产生大量线程上下文切换；非公平锁直接抢占，效率更高。

一次性搞懂：synchronized的简介及原理

       Synchronized的简介及原理详解

       Java中的一种关键内置特性，synchronized确保线程间的同步，提供了可重入的独占锁机制。让我们深入理解它的三种使用方式以及其实现原理。

       使用方式及其区别

       synchronized支持三种操作：对象锁、方法锁和代码块锁。对象锁针对的是实例对象，只有同个实例的线程之间才会产生锁竞争；方法锁（如`synchronized(this)`）和代码块锁（如`synchronized(this lock)`）则涉及对象的this或指定锁对象。静态方法锁对应的是类对象，一旦一个线程获取，其他线程将被阻塞。

       实现原理

       底层机制基于JVM指令和对象的监视器。当线程尝试访问synchronized修饰的代码块或方法时，会先尝试获取对象的监视器，成功则执行代码，否则阻塞。修饰方法时，ACC_SYNCHRONIZED标志；代码块则通过monitorenter和monitorexit指令来管理锁的进出。

       内存布局优化

       在HotSpot虚拟机中，对象内存布局包括对象头、实例数据和填充。对象头包含Mark Word和Klass point，其中Mark Word的后三位用于表示锁状态，如无锁（）、偏向锁（）、轻量级锁（）和重量级锁（）。这些细节在面试中是重要知识点。