脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java多线程 ReentrantReadWriteLock原理及实例

Java多线程 ReentrantReadWriteLock原理及实例详解

 更新时间：2019年09月06日 09:30:33   作者：慢慢来  
这篇文章主要介绍了Java多线程 ReentrantReadWriteLock原理及实例详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

读写锁ReentrantReadWriteLock概述

读写锁ReentrantReadWriteLock，使用它比ReentrantLock效率更高。

读写锁表示两个锁，一个是读操作相关的锁，称为共享锁；另一个是写操作相关的锁，称为排他锁。

1、读和读之间不互斥，因为读操作不会有线程安全问题

2、写和写之间互斥，避免一个写操作影响另外一个写操作，引发线程安全问题

3、读和写之间互斥，避免读操作的时候写操作修改了内容，引发线程安全问题

多个Thread可以同时进行读取操作，但是同一时刻只允许一个Thread进行写入操作。

读操作和读操作共享

请看例子

ThreadDomain44类和main方法

public class ThreadDomain44 extends ReentrantReadWriteLock
{
  public void read()
  {
    try
    {
      readLock().lock();
      System.out.println(Thread.currentThread().getName() + "获得了读锁, 时间为" +
          System.currentTimeMillis());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      readLock().unlock();
    }
  }
  public static void main(String[] args)
  {
    final ThreadDomain44 td = new ThreadDomain44();
    Runnable readRunnable = new Runnable()
    {
      public void run()
      {
        td.read();
      }
    };
    Thread t0 = new Thread(readRunnable);
    Thread t1 = new Thread(readRunnable);
    t0.start();
    t1.start();
  }
}

输出结果如下

Thread-0获得了读锁, 时间为1564018325618
Thread-1获得了读锁, 时间为1564018325618

尽管加了Thread.sleep(10000);两个线程几乎同时执行lock()后面的方法。说明readLock().lock()允许多个线程执行并且能提高执行效率。

写操作和写操作互斥

请看例子

public class ThreadDomain45 extends ReentrantReadWriteLock {
  public void write()
  {
    try
    {
      writeLock().lock();
      System.out.println(Thread.currentThread().getName() + "获得了写锁, 时间为" +
          new Date());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      writeLock().unlock();
    }
  }

  public static void main(String[] args)
  {
    final ThreadDomain45 td = new ThreadDomain45();
    Runnable readRunnable = new Runnable()
    {
      public void run()
      {
        td.write();
      }
    };
    Thread t0 = new Thread(readRunnable);
    Thread t1 = new Thread(readRunnable);
    t0.start();
    t1.start();
  }
}

输出结果

Thread-1获得了写锁, 时间为Tue Jul 30 11:26:21 CST 2019
Thread-0获得了写锁, 时间为Tue Jul 30 11:26:31 CST 2019

可以看到，后获得锁的Thread-0等待了十秒，说明写和写互斥

读操作和写操作互斥/写操作和读操作互斥

例子如下

public class ThreadDomain46 extends ReentrantReadWriteLock {
  public void write()
  {
    try
    {
      writeLock().lock();
      System.out.println(Thread.currentThread().getName() + "获得了写锁, 时间为" +
          new Date());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      writeLock().unlock();
    }
  }

  public void read()
  {
    try
    {
      readLock().lock();
      System.out.println(Thread.currentThread().getName() + "获得了读锁, 时间为" +
          new Date());
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      e.printStackTrace();
    }
    finally
    {
      readLock().unlock();
    }
  }

  public static void main(String[] args)
  {
    final ThreadDomain46 td = new ThreadDomain46();
    Runnable readRunnable = new Runnable()
    {
      public void run()
      {
        td.read();
      }
    };
    Runnable writeRunnable = new Runnable()
    {
      public void run()
      {
        td.write();
      }
    };
    Thread t0 = new Thread(readRunnable);
    Thread t1 = new Thread(writeRunnable);
    t0.start();
    t1.start();
  }
}

输出结果如下

Thread-0获得了读锁, 时间为Tue Jul 30 11:49:15 CST 2019
Thread-1获得了写锁, 时间为Tue Jul 30 11:49:26 CST 2019

可以看到Thread-0获得读锁执行完10s后Thread-1才获得了写锁，说明读操作和写操作互斥。
另一种输出结果如下

Thread-1获得了写锁, 时间为Tue Jul 30 14:14:07 CST 2019
Thread-0获得了读锁, 时间为Tue Jul 30 14:14:17 CST 2019

可以看到Thread-1获得写锁执行完10s后Thread-0才获得了读锁，说明写操作和读操作互斥。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • Java如何实现通过证书访问Https请求

    Java如何实现通过证书访问Https请求

    这篇文章主要介绍了Java如何实现通过证书访问Https请求，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-01-01
  • Java 数据库连接池 DBCP 的介绍

    Java 数据库连接池 DBCP 的介绍

    这篇文章主要给大家分享的是 Java 数据库连接池 DBCP 的介绍， 是 Apache 旗下 Commons 项目下的一个子项目，提供连接池功能DBCP，下面来看看文章的具体介绍内容吧,需要的朋友可以参考一下
    2021-11-11
  • Java开启JMX远程监控服务配置

    Java开启JMX远程监控服务配置

    这篇文章主要为大家介绍了Java开启JMX远程监控的服务配置，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-05-05
  • 教你使用java实现去除各种空格

    教你使用java实现去除各种空格

    本文给大家汇总介绍了5种java中去除空格的方法，分别是String.trim()、str.replace(" ", "");、replaceAll(" +","");以及自定义的remove函数，非常的简单实用，需要的小伙伴可以参考下。
    2015-03-03
  • Java责任链模式定义与用法分析

    Java责任链模式定义与用法分析

    这篇文章主要介绍了Java责任链模式定义与用法,结合具体实例分析了java责任链模式的功能、定义、使用方法、适用情况等,需要的朋友可以参考下
    2017-06-06
  • Java 八种基本类型和基本类型封装类

    Java 八种基本类型和基本类型封装类

    八种基本数据类型分别是：int、short、float、double、long、boolean、byte、char；下面跟随脚本之家小编一起学习java八种基本类型和基本类型封装类
    2017-09-09
  • Hadoop之Mapreduce序列化

    Hadoop之Mapreduce序列化

    本文主要带我们了解Mapreduce序列化，序列化就是把内存中的对象，转换成字节序列（或其他数据传输协议）以便于存储到磁盘（持久化）和网络传输。想进一步了解更多的小伙伴，可以参考阅读本文
    2023-03-03
  • Java如何基于okhttp请求SSE接口流式返回详解

    Java如何基于okhttp请求SSE接口流式返回详解

    对于流式返回,Spring Boot提供了两种不同的方式,下面这篇文章主要给大家介绍了关于Java如何基于okhttp请求SSE接口流式返回的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2024-03-03
  • MyBatis类型转换模块的实现

    MyBatis类型转换模块的实现

    MyBatis是一个持久层框架ORM框架,实现数据库中数据和Java对象中的属性的双向映射,那么不可避免的就会碰到类型转换的问题,本文主要介绍了MyBatis类型转换模块的实现,感兴趣的可以了解一下
    2023-09-09
  • C#中NAudio音频库的安装与使用教程详解

    C#中NAudio音频库的安装与使用教程详解

    NAudio为.NET平台下的开源库,采用ML-PL协议,它支持许多音频操作,可实现多种API播放与录制、多种不同音频格式等功能,下面就跟随小编一起学习一下NAudio的安装与使用吧
    2023-11-11

最新评论