脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → 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的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • 详解spring cloud hystrix 请求合并collapsing

    详解spring cloud hystrix 请求合并collapsing

    这篇文章主要介绍了详解spring cloud hystrix 请求合并collapsing，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2018-05-05
  • java使用Jsoup连接网站超时的解决方法

    java使用Jsoup连接网站超时的解决方法

    jsoup是一个非常好的解析网页的包，用java开发的，提供了类似DOM，CSS选择器的方式来查找和提取文档中的内容,提取文档内容时会出现超时的情况，解决方法可看下文
    2013-11-11
  • JHipster如何修改JDL中的entity

    JHipster如何修改JDL中的entity

    这篇文章主要介绍了JHipster如何修改JDL中的entity问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-11-11
  • java web实现简易收费站

    java web实现简易收费站

    这篇文章主要为大家详细介绍了java web实现简易收费站，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一
    2020-11-11
  • mybatis使用pagehelper插件过程详解

    mybatis使用pagehelper插件过程详解

    这篇文章主要介绍了mybatis使用pagehelper插件过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • 23种设计模式（14）java迭代器模式

    23种设计模式（14）java迭代器模式

    这篇文章主要为大家详细介绍了23种设计模式之java迭代器模式，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2017-12-12
  • Java 多线程并发编程提高数据处理效率的详细过程

    Java 多线程并发编程提高数据处理效率的详细过程

    这篇文章主要介绍了Java 多线程并发编程提高数据处理效率,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2023-04-04
  • Java中JDom解析XML_动力节点Java学院整理

    Java中JDom解析XML_动力节点Java学院整理

    JDOM是一种解析XML的Java工具包。DOM适合于当今流行的各种语言，包括Java,JavaScripte,VB,VBScript，Perl,C,C++等。下面通过本文给大家介绍Java中JDom解析XML的方法，感兴趣的朋友一起学习吧
    2017-07-07
  • IntelliJ IDEA 2017.1.4 x64配置步骤(介绍)

    IntelliJ IDEA 2017.1.4 x64配置步骤(介绍)

    下面小编就为大家带来一篇IntelliJ IDEA 2017.1.4 x64配置步骤(介绍)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-06-06
  • 解决mybatis批量更新(update foreach)失败的问题

    解决mybatis批量更新(update foreach)失败的问题

    这篇文章主要介绍了解决mybatis批量更新(update foreach)失败的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-11-11

最新评论