时间:2021-05-20
读写锁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获得了读锁, 时间为1564018325618Thread-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 2019Thread-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 2019Thread-1获得了写锁, 时间为Tue Jul 30 11:49:26 CST 2019可以看到Thread-0获得读锁执行完10s后Thread-1才获得了写锁,说明读操作和写操作互斥。
另一种输出结果如下
可以看到Thread-1获得写锁执行完10s后Thread-0才获得了读锁,说明写操作和读操作互斥。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文承接上一篇文章《Java多线程实例详解(一)》。四.Java多线程的阻塞状态与线程控制上文已经提到Java阻塞的几种具体类型。下面分别看下引起Java线程阻
Java中CountDownLatch进行多线程同步详解CountDownLatch介绍在前面的Java学习笔记中,总结了Java中进行多线程同步的几个方法:1
详解Java中多线程异常捕获Runnable的实现1、背景:Java多线程异常不向主线程抛,自己处理,外部捕获不了异常。所以要实现主线程对子线程异常的捕获。2、
这篇文章主要介绍了Java多线程线程状态原理详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下java.la
本文实例讲述了Android编程开发实现带进度条和百分比的多线程下载。分享给大家供大家参考,具体如下:继上一篇《java多线程下载实例详解》之后,可以将它移植到