脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java读写锁ReadWriteLock

Java读写锁ReadWriteLock的创建使用及测试分析示例详解

 更新时间：2023年01月12日 15:27:35   作者：昵称为空C  
这篇文章主要为大家介绍了Java读写锁ReadWriteLock的创建使用及测试分析示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

简介

摘要：本文主要介绍ReadWriteLock，可重入读写锁的基本使用，该锁只能在单服务实例中使用，不适合分布式多服务实例集群。

A ReadWriteLock维护一对关联的locks，一个用于只读操作，一个用于写操作。read lock可以由多个阅读器同时进行，只要没有作者 write lock 是独家的。

基本意思可分为如下几种场景

  • 写锁不存在、多次加读锁成功
  • 写锁存在、加读锁失败、加写锁失败
  • 读锁不存在、单次加写锁成功、多次加写锁只有第一个写锁能成功
  • 读锁存在、加读锁成功、加写锁失败

基本方法介绍

创建读写锁

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

使用读锁readLock().lock()

如果该锁被写锁占有，则该方法会一直等待锁

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.readLock().lock();

使用读锁readLock().tryLock()；readLock().tryLock(6L, TimeUnit.SECONDS)

如果该锁被写锁占有，第一个方法如果获取不到锁则返回false，第二个方法会等待你设置的时间，在你设置的时间范围内未获取到锁则返回false

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.readLock().tryLock();
readWriteLock.readLock().tryLock(6L, TimeUnit.SECONDS);

使用写锁writeLock().lock()

如果该锁被写锁占有，则该方法会一直等待锁

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.writeLock().lock();

使用读锁writeLock().tryLock()；writeLock().tryLock(6L, TimeUnit.SECONDS)

如果该锁被写锁占有，第一个方法如果获取不到锁则返回false，第二个方法会等待你设置的时间，在你设置的时间范围内未获取到锁则返回false

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
readWriteLock.writeLock().tryLock();
readWriteLock.writeLock().tryLock(6L, TimeUnit.SECONDS);

使用案例

创建LockManager

该实例的读方法用了等待6S

public class LockManager {
    private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    public void write(String message,Long sleep) {
        try{
            if(readWriteLock.writeLock().tryLock()){
                try{
                    Thread.sleep(sleep);
                    System.out.println(Thread.currentThread().getName()+",写写写写写写写写写写，message="+message);
                }catch (Exception ex){
                    System.out.println(Thread.currentThread().getName()+",写入异常"+ex);
                }finally {
                    readWriteLock.writeLock().unlock();
                }
            }else{
                System.out.println(Thread.currentThread().getName()+",获取写锁失败");
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }
    public void read(String message,Long sleep){
        try{
            if(readWriteLock.readLock().tryLock(6L, TimeUnit.SECONDS)){
                try{
                    Thread.sleep(sleep);
                    System.out.println(Thread.currentThread().getName()+",读读读读读读读读读读，message="+message);
                }catch (Exception ex){
                    System.out.println(Thread.currentThread().getName()+",读取异常"+ex);
                }finally {
                    readWriteLock.readLock().unlock();
                }
            }else{
                System.out.println(Thread.currentThread().getName()+",获取读锁失败");
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }
}

测试无写锁，只有读锁

测试方法

第一个线程等待5S输出，第二个线程等待4S输出

@Test
public void testOnlyRead() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.read("001",5000L)).start();
    new Thread(()->lockManager.read("002",4000L)).start();
    Thread.sleep(20000L);
}

输出结果

Thread-2,读读读读读读读读读读，message=002
Thread-1,读读读读读读读读读读，message=001

测试无读锁，只有写锁

测试方法

第一个线程等待5S输出，第二个线程等待4S输出

@Test
public void testOnlyWrite() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.write("001",5000L)).start();
    new Thread(()->lockManager.write("002",4000L)).start();
    Thread.sleep(20000L);
}

输出结果

Thread-2,获取写锁失败
Thread-1,写写写写写写写写写写，message=001

测试先读锁，再写锁

测试方法

第一个线程等待5S输出，第二个线程等待4S输出

@Test
public void testReadWrite() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.read("001",5000L)).start();
    new Thread(()->lockManager.write("002",4000L)).start();
    Thread.sleep(20000L);
}

输出结果

Thread-2,获取写锁失败
Thread-1,读读读读读读读读读读，message=001

测试先写锁，再写锁

测试方法 （由于读锁获取等待了6S，所以可以执行成功）

第一个线程等待5S输出，第二个线程等待4S输出

@Test
public void testWriteRead() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.write("001",5000L)).start();
    new Thread(()->lockManager.read("002",4000L)).start();
    Thread.sleep(20000L);
}

输出结果

Thread-1,写写写写写写写写写写，message=001
Thread-2,读读读读读读读读读读，message=002

测试方法 （由于读锁获取等待了6S，所以读锁获取失败）

第一个线程等待7S输出，第二个线程等待4S输出

@Test
public void testWriteRead2() throws Exception {
    LockManager lockManager = new LockManager();
    new Thread(()->lockManager.write("001",7000L)).start();
    new Thread(()->lockManager.read("002",4000L)).start();
    Thread.sleep(20000L);
}

输出结果

Thread-2,获取读锁失败
Thread-1,写写写写写写写写写写，message=001

以上就是Java读写锁ReadWriteLock的创建使用及测试分析示例详解的详细内容，更多关于Java读写锁ReadWriteLock的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • 一文详解Springboot中filter的原理与注册

    一文详解Springboot中filter的原理与注册

    这篇文章主要为大家详细介绍了Springboot中filter的原理与注册的相关知识，文中的示例代码讲解详细，对我们掌握SpringBoot有一定的帮助，需要的可以参考一下
    2023-02-02
  • Java算法实战之排一亿个随机数

    Java算法实战之排一亿个随机数

    我们在生活中经常遇见一些这样的需求,随机点名、公司年会抽奖、微信拼手气红包等,还有一些游戏比如打地鼠小游戏、俄罗斯方块等,这些场景中都会用到一种算法：随机,这篇文章主要给大家介绍了关于Java算法实战之排一亿个随机数的相关资料,需要的朋友可以参考下
    2021-11-11
  • Java Swing实现QQ登录页面

    Java Swing实现QQ登录页面

    这篇文章主要为大家详细介绍了Java Swing实现QQ登录页面，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2022-02-02
  • springboot2.1.3配置sftp自定义sftp连接池的详细过程

    springboot2.1.3配置sftp自定义sftp连接池的详细过程

    这篇文章主要介绍了springboot2.1.3配置sftp自定义sftp连接池的详细过程,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2021-08-08
  • IntelliJ IDEA 2020.2.3永久破解激活教程(亲测有效)

    IntelliJ IDEA 2020.2.3永久破解激活教程(亲测有效)

    intellij idea 2022是一款市面上最好的JAVA IDE编程工具，该工具支持git、svn、github等版本控制工具，整合了智能代码助手、代码自动提示等功能，本教程给大家分享IDEA 2022最新永久激活码，感兴趣的朋友参考下吧
    2020-10-10
  • 使用dynamic datasource springboot starter实现多数据源及源码分析

    使用dynamic datasource springboot starter实现多数据源及源码分析

    这篇文章主要介绍了使用dynamic-datasource-spring-boot-starter做多数据源及源码分析,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2021-09-09
  • springboot Jpa多数据源(不同库)配置过程

    springboot Jpa多数据源(不同库)配置过程

    这篇文章主要介绍了springboot Jpa多数据源(不同库)配置过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-05-05
  • Java实现十进制与二进制互转的示例详解

    Java实现十进制与二进制互转的示例详解

    这篇文章主要为大家详细介绍了Java如何实现十进制与二进制的互转，文中的示例代码讲解详细，对我们学习Java有一定帮助，需要的可以参考一下
    2022-11-11
  • Java ThreadLocal类使用详解

    Java ThreadLocal类使用详解

    这篇文章主要介绍了Java ThreadLocal类详解，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下
    2022-07-07
  • mybatis一直加载xml,找到错误的解决方案

    mybatis一直加载xml,找到错误的解决方案

    这篇文章主要介绍了mybatis一直加载xml，找到错误的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-02-02

最新评论