0

0

Java中ReentrantReadWriteLock写锁和读锁使用

P粉602998670

P粉602998670

发布时间:2025-09-24 15:47:01

|

366人浏览过

|

来源于php中文网

原创

ReentrantReadWriteLock通过读写锁分离实现读多写少场景下的高效并发控制,允许多个读线程同时访问,写线程独占访问,提升性能。

java中reentrantreadwritelock写锁和读锁使用

Java中的ReentrantReadWriteLock,在我看来,它就是并发世界里的一把“分时复用”钥匙,巧妙地平衡了数据的读取效率和写入安全。它的核心思想很简单:当数据只需要被读取时,允许多个线程同时进行,大家互不影响,效率自然就上去了;但一旦有线程想要修改数据,它就必须独占这把钥匙,确保修改过程不被任何读取或写入操作干扰,保证数据的一致性。这种机制特别适合那些“读多写少”的场景,比如一个缓存系统,或者一个配置中心,大部分时间都在被查询,偶尔才更新一次。

当我们需要在Java中实现一个高效且线程安全的数据访问机制,特别是面对读操作远多于写操作的场景时,ReentrantReadWriteLock提供了一个非常优雅的解决方案。它通过区分读锁(ReadLock)和写锁(WriteLock)来优化并发性能。

解决方案

要使用ReentrantReadWriteLock,我们首先需要创建一个实例,然后通过它的readLock()writeLock()方法获取对应的锁。

import java.util.concurrent.locks.ReentrantReadWriteLock;

public class SharedResource {
    private final ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();
    private final ReentrantReadWriteLock.ReadLock readLock = rwLock.readLock();
    private final ReentrantReadWriteLock.WriteLock writeLock = rwLock.writeLock();

    private String data = "Initial Data";

    public String readData() {
        readLock.lock(); // 获取读锁
        try {
            // 模拟读取操作
            System.out.println(Thread.currentThread().getName() + " is reading: " + data);
            Thread.sleep(50); // 模拟耗时
            return data;
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return null;
        } finally {
            readLock.unlock(); // 释放读锁
        }
    }

    public void writeData(String newData) {
        writeLock.lock(); // 获取写锁
        try {
            // 模拟写入操作
            System.out.println(Thread.currentThread().getName() + " is writing: " + newData);
            Thread.sleep(100); // 模拟耗时
            this.data = newData;
            System.out.println(Thread.currentThread().getName() + " finished writing.");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            writeLock.unlock(); // 释放写锁
        }
    }

    public static void main(String[] args) {
        SharedResource resource = new SharedResource();

        // 多个读线程
        for (int i = 0; i < 5; i++) {
            new Thread(() -> {
                resource.readData();
            }, "Reader-" + i).start();
        }

        // 一个写线程
        new Thread(() -> {
            resource.writeData("New Data from Writer-1");
        }, "Writer-1").start();

        // 另一个写线程
        new Thread(() -> {
            resource.writeData("New Data from Writer-2");
        }, "Writer-2").start();

        // 更多的读线程
        for (int i = 5; i < 10; i++) {
            new Thread(() -> {
                resource.readData();
            }, "Reader-" + i).start();
        }
    }
}

在这个例子中,readData()方法通过获取读锁来保护数据读取,允许多个线程同时进入。而writeData()方法则通过获取写锁来保护数据写入,任何时候只有一个线程能持有写锁,并且在写锁被持有时,所有读锁和写锁都无法被其他线程获取,确保了数据修改的原子性和可见性。

立即学习Java免费学习笔记(深入)”;

ReentrantReadWriteLock相比ReentrantLock有哪些优势和应用场景?

ReentrantReadWriteLock最显著的优势,就是它打破了ReentrantLock那种“一夫当关,万夫莫开”的独占模式。ReentrantLock在任何时候都只允许一个线程访问临界区,无论是读还是写,这在读操作频繁的场景下会造成严重的性能瓶颈。比如,一个电商网站的商品详情页,用户点击量巨大,都是在读取商品信息;而商品信息的更新(价格调整、库存变化)相对较少。如果用ReentrantLock,每次有用户读取商品信息,其他所有想读的、想写的都得排队,这显然不合理。

ReentrantReadWriteLock的出现,正是为了解决这种“读多写少”的痛点。它允许:

  1. 多读并发: 多个线程可以同时持有读锁,并行读取数据,大大提升了读取效率。
  2. 写独占: 任何时候只有一个线程能持有写锁,且在写锁被持有时,读锁和写锁都不能被其他线程获取,保证了数据写入的一致性和安全性。

因此,它的应用场景非常明确:

  • 缓存系统: 这是最典型的场景。缓存数据被频繁读取,偶尔才会被更新或失效。读写锁可以确保缓存的高效访问。
  • 配置管理: 应用程序的配置信息,一旦加载后,通常是读多写少。
  • 数据结构封装: 对一些非线程安全的数据结构(如ArrayListHashMap)进行线程安全封装,使其在读多写少的场景下表现更优。
  • 监控数据: 收集到的监控指标,需要被多个组件读取,但更新频率不高。

简单来说,当你的程序中存在一个共享资源,其读操作的频率远高于写操作时,ReentrantReadWriteLock就是你提升并发性能的利器。如果读写比例接近,或者写操作非常频繁,那么ReentrantLock或者其他更细粒度的同步机制可能更适合,因为ReentrantReadWriteLock内部的维护开销会相对大一些。

ReentrantReadWriteLock的写锁和读锁有哪些核心特性和使用陷阱?

ReentrantReadWriteLock的设计非常精妙,但要用好它,我们必须理解其读锁和写锁的核心特性以及一些潜在的使用陷阱。

写锁 (WriteLock) 的核心特性:

  1. 独占性: 这是最基本的,任何时候只能有一个线程持有写锁。当一个线程持有写锁时,其他所有试图获取读锁或写锁的线程都会被阻塞。
  2. 重入性: 持有写锁的线程可以再次获取写锁。这在递归调用或者同一线程内部需要多次加锁的场景下非常有用,避免了死锁。
  3. 允许降级: 持有写锁的线程可以获取读锁,然后释放写锁。这个过程称为“锁降级”。它常用于在修改完数据后,需要继续读取修改后的数据,同时允许其他线程读取(但不能写入)的场景。例如:
    writeLock.lock();
    try {
        // 修改数据
        data = "Modified Data";
        readLock.lock(); // 获取读锁
    } finally {
        writeLock.unlock(); // 释放写锁
    }
    // 现在持有读锁,可以安全读取,其他线程也可以读取
    String currentData = data;
    readLock.unlock();

读锁 (ReadLock) 的核心特性:

Digram
Digram

让Figma更好用的AI神器

下载
  1. 共享性: 多个线程可以同时持有读锁。这是它与写锁最大的区别,也是实现高并发读取的关键。
  2. 重入性: 持有读锁的线程可以再次获取读锁。
  3. 阻止写操作: 当有任何线程持有读锁时,其他线程无法获取写锁。这意味着读锁可以阻止数据在读取过程中被修改。
  4. 不允许升级: 读锁不能直接升级为写锁。也就是说,一个线程在持有读锁的情况下,不能直接尝试获取写锁。如果这样做,很可能会导致死锁。

使用陷阱和注意事项:

  1. 读锁升级为写锁的死锁风险: 这是最常见的陷阱。如果线程A持有读锁,尝试获取写锁;同时线程B也持有读锁,也尝试获取写锁。那么两个线程都会因为对方持有读锁而无法获取写锁,导致相互等待,形成死锁。正确的做法是先释放读锁,再尝试获取写锁,但这会引入一个短暂的窗口期,期间数据可能被其他线程修改。所以,通常不建议在持有读锁时直接尝试获取写锁。
  2. 写饥饿: 在高并发的读操作场景下,如果读锁被持续不断地获取和释放,写锁可能会因为无法获取而长时间等待,导致写线程“饥饿”。ReentrantReadWriteLock的默认实现(非公平模式)在一定程度上会缓解这个问题,但公平模式下,如果写锁在等待,后续的读锁请求会被阻塞,直到写锁被释放,这又可能影响读的并发性。这是一个权衡问题,需要根据实际业务场景选择。
  3. 锁粒度: 像所有锁一样,ReentrantReadWriteLock也需要注意锁的粒度。如果锁定的范围过大,会降低并发性;如果过小,又可能导致数据不一致或者增加锁管理的复杂性。
  4. 异常处理: 务必在finally块中释放锁,避免因异常导致锁无法释放,进而造成死锁或资源泄露。这是使用任何Lock接口的黄金法则。

理解这些特性和陷阱,能够帮助我们更安全、高效地利用ReentrantReadWriteLock来构建健壮的并发程序。

如何选择ReentrantReadWriteLock的公平性策略,以及公平性对性能的影响?

ReentrantReadWriteLockReentrantLock一样,都支持公平(Fair)和非公平(Nonfair)两种锁获取策略。在创建ReentrantReadWriteLock实例时,可以通过构造函数指定:new ReentrantReadWriteLock(boolean fair)

公平性策略的选择:

  1. 公平锁 (Fair Lock):

    • 工作方式: 当一个线程尝试获取锁时,如果当前锁被占用,它会进入一个等待队列。当锁被释放时,等待队列中最前面的线程(等待时间最长的线程)会优先获取锁。这保证了线程获取锁的顺序与它们请求锁的顺序一致。
    • 优点: 避免饥饿。所有等待的线程都有机会获取锁,不会出现某个线程一直无法获取锁的情况。
    • 缺点: 性能开销较大。因为需要维护一个有序的等待队列,并且在释放锁时进行额外的线程调度,上下文切换的成本更高。这通常会导致吞吐量下降。
    • 适用场景: 对线程公平性有严格要求,或者需要避免写饥饿的特定场景,尽管在ReentrantReadWriteLock中,公平模式下写锁饥饿问题可能会被缓解,但读锁的并发性会受影响。
  2. 非公平锁 (Nonfair Lock):

    • 工作方式: 当一个线程尝试获取锁时,它会先尝试直接获取锁。如果锁当前可用,它就立即获取,而不管等待队列中是否有其他线程。只有当锁不可用时,它才会进入等待队列。
    • 优点: 性能通常优于公平锁。减少了线程调度的开销,提高了吞吐量。
    • 缺点: 可能会导致饥饿。新来的线程可能会“插队”成功,导致等待队列中的线程长时间无法获取锁。
    • 适用场景: 大多数并发编程场景。在没有严格公平性要求,且追求高吞吐量时,非公平锁是更好的选择。这也是ReentrantReadWriteLockReentrantLock的默认行为。

公平性对性能的影响:

公平性策略对ReentrantReadWriteLock的性能影响是显著的。

  • 非公平锁通常提供更高的吞吐量: 这是因为非公平锁减少了线程上下文切换的开销。当锁被释放时,如果当前有线程正在尝试获取锁(而不是等待队列中的线程),它可能直接成功,避免了将等待队列中的线程唤醒、调度、上下文切换等一系列操作。这种“抢占”机制在CPU利用率高时尤其明显。
  • 公平锁在某些情况下可能导致性能下降: 尤其是在高并发场景下,频繁的线程入队、出队以及严格的顺序保证会引入额外的开销。对于读写锁来说,公平性还会影响读写之间的调度。在公平模式下,如果一个写锁在等待,那么所有后续的读锁请求也会被阻塞,直到写锁被释放,这会牺牲读操作的并发性来确保写操作的公平性。而在非公平模式下,如果写锁正在等待,但此时没有线程持有读锁,并且有新的读锁请求到来,这个读锁请求可能会“插队”成功,继续进行读操作。

我的建议:

除非你有明确的业务需求,要求严格的线程公平性或者需要解决特定的饥饿问题,否则我通常会推荐使用非公平锁。默认的非公平模式在大多数情况下都能提供更好的性能和吞吐量。在实际开发中,我们应该根据应用的具体负载特性和性能目标来选择合适的公平性策略,并且在做出决策后进行充分的性能测试。毕竟,理论上的最优解不一定适用于所有实际场景。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
java中boolean的用法
java中boolean的用法

在Java中,boolean是一种基本数据类型,它只有两个可能的值:true和false。boolean类型经常用于条件测试,比如进行比较或者检查某个条件是否满足。想了解更多java中boolean的相关内容,可以阅读本专题下面的文章。

350

2023.11.13

java boolean类型
java boolean类型

本专题整合了java中boolean类型相关教程,阅读专题下面的文章了解更多详细内容。

29

2025.11.30

treenode的用法
treenode的用法

​在计算机编程领域,TreeNode是一种常见的数据结构,通常用于构建树形结构。在不同的编程语言中,TreeNode可能有不同的实现方式和用法,通常用于表示树的节点信息。更多关于treenode相关问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

538

2023.12.01

C++ 高效算法与数据结构
C++ 高效算法与数据结构

本专题讲解 C++ 中常用算法与数据结构的实现与优化,涵盖排序算法(快速排序、归并排序)、查找算法、图算法、动态规划、贪心算法等,并结合实际案例分析如何选择最优算法来提高程序效率。通过深入理解数据结构(链表、树、堆、哈希表等),帮助开发者提升 在复杂应用中的算法设计与性能优化能力。

17

2025.12.22

深入理解算法:高效算法与数据结构专题
深入理解算法:高效算法与数据结构专题

本专题专注于算法与数据结构的核心概念,适合想深入理解并提升编程能力的开发者。专题内容包括常见数据结构的实现与应用,如数组、链表、栈、队列、哈希表、树、图等;以及高效的排序算法、搜索算法、动态规划等经典算法。通过详细的讲解与复杂度分析,帮助开发者不仅能熟练运用这些基础知识,还能在实际编程中优化性能,提高代码的执行效率。本专题适合准备面试的开发者,也适合希望提高算法思维的编程爱好者。

25

2026.01.06

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1099

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

189

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1450

2025.12.29

Python 自然语言处理(NLP)基础与实战
Python 自然语言处理(NLP)基础与实战

本专题系统讲解 Python 在自然语言处理(NLP)领域的基础方法与实战应用,涵盖文本预处理(分词、去停用词)、词性标注、命名实体识别、关键词提取、情感分析,以及常用 NLP 库(NLTK、spaCy)的核心用法。通过真实文本案例,帮助学习者掌握 使用 Python 进行文本分析与语言数据处理的完整流程,适用于内容分析、舆情监测与智能文本应用场景。

10

2026.01.27

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 2.9万人学习

C# 教程
C# 教程

共94课时 | 7.8万人学习

Java 教程
Java 教程

共578课时 | 52.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号