多线程系列(十) -ReadWriteLock用法详解

2024-02-27 09:53 由程序员志哥发表于 #后端开发

一、摘要

在上篇文章中，我们讲到ReentrantLock可以保证了只有一个线程能执行加锁的代码。

但是有些时候，这种保护显的有点过头，比如下面这个方法，它仅仅就是只读取数据，不修改数据，它实际上允许多个线程同时调用的。

public class Counter {

    private final Lock lock = new ReentrantLock();

    private int count;

    public int get() {
        // 加锁
        lock.lock();
        try {
            return count;
        } finally {
            // 释放锁
            lock.unlock();
        }
    }
}

站在程序性能的角度，实际上我们想要的是这样的效果。

1.读和读之间不互斥，因为只读操作不会有数据安全问题
2.写和写之间互斥，避免一个写操作影响另外一个写操作，引发数据计算错误问题
3.读和写之间互斥，避免读操作的时候写操作修改了内容，引发数据脏读问题

总结起来就是，允许多个线程同时读，但只要有一个线程在写，其他线程就必须排队等待。

在 JDK 中有一个读写锁ReadWriteLock，使用它就可以解决这个问题，它可以保证以下两点：

1.只允许一个线程写入，其他线程既不能写入也不能读取
2.没有写入时，多个线程允许同时读，可以提高程序并发性能

实际上，读写锁ReadWriteLock里面有两个锁实现，一个是读操作相关的锁，称为共享锁，当多个线程同时操作时，不会让多个线程进行排队等待，大大的提升了程序并发读的执行效率；另一个是写操作相关的锁，称为排他锁，当多个线程同时操作时，只允许一个线程写入，其他线程进入排队等待；两者进行组合操作，就可以实现上面的预期效果。

下面我们一起来看看它的基本用法！

二、ReadWriteLock 基本用法

2.1、读和读共享

读和读之间不互斥，当多个线程进行读的时候，不会让多个线程进行排队等待。

我们可以看一个简单的例子！

public class Counter {

    private final ReadWriteLock lock = new ReentrantReadWriteLock();

    private int count;

    public void read() {
        // 加读锁
        lock.readLock().lock();
        try {
            String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS").format(new Date());
            System.out.println(time + " 当前线程：" + Thread.currentThread().getName() + "获得了读锁，count:" + count);
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放读锁
            lock.readLock().unlock();
        }
    }
}

public class MyThreadTest {

    public static void main(String[] args) {
        Counter counter = new Counter();
        Thread threadA = new Thread(new Runnable() {
            @Override
            public void run() {
                counter.read();
            }
        });

        Thread threadB = new Thread(new Runnable() {
            @Override
            public void run() {
                counter.read();
            }
        });

        threadA.start();
        threadB.start();
    }
}

看一下运行结果：

2023-10-23 16:12:28:119 当前线程：Thread-0获得了读锁，count:0
2023-10-23 16:12:28:119 当前线程：Thread-1获得了读锁，count:0

从日志时间上可以很清晰的看到，尽管加锁了，并且休眠了 5 秒，但是两个线程还是几乎同时执行try()方法里面的代码，证明了读和读之间是不互斥的，可以显著提高程序的运行效率。

2.2、写和写之间互斥

写和写之间互斥，当多个线程进行写的时候，只允许一个线程写入，其他线程进入排队等待。

我们可以看一个简单的例子！

public class Counter {

    private final ReadWriteLock lock = new ReentrantReadWriteLock();

    private int count;

    public void write() {
        // 加写锁
        lock.writeLock().lock();
        try {
            count++;
            String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS").format(new Date());
            System.out.println(time + " 当前线程：" + Thread.currentThread().getName() + "获得了写锁，count:" + count);
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放写锁
            lock.writeLock().unlock();
        }
    }
}

public class MyThreadTest {

    public static void main(String[] args) {
        Counter counter = new Counter();
        Thread threadA = new Thread(new Runnable() {
            @Override
            public void run() {
                counter.write();
            }
        });

        Thread threadB = new Thread(new Runnable() {
            @Override
            public void run() {
                counter.write();
            }
        });

        threadA.start();
        threadB.start();
    }
}

看一下运行结果：

2023-10-23 16:29:59:103 当前线程：Thread-0获得了写锁，count:1
2023-10-23 16:30:04:108 当前线程：Thread-1获得了写锁，count:2

从日志时间上可以很清晰的看到，两个线程进行串行执行，证明了写和写之间是互斥的。

2.3、读和写之间互斥

读和写之间互斥，当多个线程交替进行读写的时候，操作上互斥，只有一个线程能进入，其他线程进入排队等待。

我们可以看一个简单的例子！

public class Counter {

    private final ReadWriteLock lock = new ReentrantReadWriteLock();

    private int count;

    public void read() {
        // 加读锁
        lock.readLock().lock();
        try {
            String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS").format(new Date());
            System.out.println(time + " 当前线程：" + Thread.currentThread().getName() + "获得了读锁，count:" + count);
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放读锁
            lock.readLock().unlock();
        }
    }

    public void write() {
        // 加写锁
        lock.writeLock().lock();
        try {
            count++;
            String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS").format(new Date());
            System.out.println(time + " 当前线程：" + Thread.currentThread().getName() + "获得了写锁，count:" + count);
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放写锁
            lock.writeLock().unlock();
        }
    }
}

public class MyThreadTest {

    public static void main(String[] args) {
        Counter counter = new Counter();
        Thread threadA = new Thread(new Runnable() {
            @Override
            public void run() {
                counter.read();
            }
        });

        Thread threadB = new Thread(new Runnable() {
            @Override
            public void run() {
                counter.write();
            }
        });

        threadA.start();
        threadB.start();
    }
}

看一下运行结果：

2023-10-23 16:36:08:786 当前线程：Thread-0获得了读锁，count:0
2023-10-23 16:36:13:791 当前线程：Thread-1获得了写锁，count:1

从日志时间上可以很清晰的看到，两个线程进行串行执行，证明了读和写之间是互斥的。

三、小结

总结下来，ReadWriteLock有以下特点：

允许多个线程在没有写入时同时读取，可以提高读取效率
当存在写入情况时，只允许一个线程写入，其他线程进入排队等待
适合读多写少的场景

对于同一个数据，有大量线程读取，但仅有少数线程修改，使用ReadWriteLock可以显著的提升程序并发执行效率。

例如，一个论坛的帖子，浏览可以看做读取操作，是非常频繁的，而回复可以看做写入操作，它是不频繁的，这种情况就可以使用ReadWriteLock来实现。

本文主要围绕ReadWriteLock的基本使用做了一次知识总结，如果有不正之处，请多多谅解，并欢迎批评指出。

四、参考

1、https://www.cnblogs.com/xrq730/p/4855631.html

2、https://www.liaoxuefeng.com/wiki/1252599548343744/1306581002092578

深入解析Python并发编程的多线程和异步编程

本文分享自华为云社区《Python并发编程探秘：多线程与异步编程的深入解析》，作者：柠檬味拥抱。在Python编程中，多线程是一种常用的并发编程方式，它可以有效地提高程序的执行效率，特别是在处理I/O密集型任务时。Python提供了threading模块，使得多线程编程变得相对简单。本文将深入探讨 ...阅读全文

都说了别用BeanUtils.copyProperties，这不翻车了吧

即使再小再简单的需求，作为研发开发完毕之后，我们可以直接上线么？其实很多时候事故往往就是由于“不以为意”发生的。事故的发生往往也遵循“墨菲定律”，这就要求我们更要敬畏线上，再小的需求点都需要经过严格的测试验证才能上线。 ...阅读全文

c++引用和指针

指针和引用当我们需要在程序中传递变量的地址时，可以使用指针或引用。它们都可以用来间接访问变量，但它们之间有一些重要的区别。指针是一个变量，它存储另一个变量的地址。通过指针，我们可以访问存储在该地址中的变量。指针可以被重新分配，可以指向不同的变量，也可以为NULL。指针使用*运算符来访问存储在地址 ...阅读全文

【Django开发】0到1开发美多shop项目：用户登录模块开发。全md文档笔记（附代码文档）

本系列文章md笔记（已分享）主要讨论django商城项目相关知识。项目利用Django框架开发一套前后端不分离的商城项目含代码和文档。功能包括前后端不分离，方便SEO。采用Django Jinja2模板引擎 Vue.js实现前后端逻辑，Nginx服务器（反向代理）Nginx服务器（静态首页、商品... ...阅读全文

掌握字符与字符串：C语言中的神奇函数解析(一）

✨✨ 欢迎大家来到贝蒂大讲堂✨✨ 养成好习惯，先赞后看哦~ 所属专栏：C语言学习贝蒂的主页：Betty‘s blog 引言我们在学习C语言的过程中，除了使用最多的头文件<stdio.h>，还会使用其他头文件，利用其中的库函数帮助我们简化代码的过程，比如像<math.h>，<str ...阅读全文

掌握C语言指针，轻松解锁代码高效性与灵活性(下）

✨✨ 欢迎大家来到贝蒂大讲堂✨✨ 养成好习惯，先赞后看哦~ 所属专栏：C语言学习贝蒂的主页：Betty‘s blog 引言经过前面的刻苦学习，今天我们终于来到了指针的最后一节，这一节将是对前面内容的总结与深化，相信学完之后，大家能对指针有一个更深的理解~ 1. 函数指针 1.1 ...阅读全文

Java - 将TXT文本文件转换为PDF文件

与TXT文本文件，PDF文件更加专业也更适合传输，常用于正式报告、简历、合同等场合。项目中如果有使用Java将TXT文本文件转为PDF文件的需求，可以查看本文中介绍的免费实现方法。免费Java PDF库本文介绍的方法需要用到Free Spire.PDF for Java，该免费库支持多种操作、转 ...阅读全文

云计算 - 以阿里云为例，企业上云策略全览与最佳实践

云采用框架（Cloud Adoption Framework，简称CAF）为企业上云提供策略和技术的指导原则和最佳实践，帮助企业上好云、用好云、管好云，并成功实现业务目标。本云采用框架是基于服务大量企业客户的经验总结，将企业云采用分为四个阶段，并详细探讨企业应在每个阶段采取的业务和技术策略；同时，还 ...阅读全文

Excelize 开源基础发布 2.8.1 版本，2024 年首个更新

Excelize 是 Go 语言编写的用于操作电子表格办公文档的开源基础库，2024年2月26日，社区正式发布了 2.8.1 版本，该版本包含了多项新增功能、错误修复和兼容性提升优化。 ...阅读全文

多线程系列(九) -ReentrantLock常用方法详解

在上一篇文章中，我们介绍了ReentrantLock类的一些基本用法，今天我们重点来介绍一下ReentrantLock其它的常用方法，以便对ReentrantLock类的使用有更深入的理解。 ...阅读全文