博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
java多线程:ReentrantReadWriteLock读写锁使用
阅读量:6115 次
发布时间:2019-06-21

本文共 2503 字,大约阅读时间需要 8 分钟。

Lock比传统的线程模型synchronized更多的面向对象的方式。锁和生活似,应该是一个对象。两个线程运行的代码片段要实现同步相互排斥的效果。它们必须用同一个Lock对象。

读写锁:分为读锁和写锁。多个读锁不相互排斥,读锁与写锁相互排斥,这是由jvm自己控制的,你仅仅要上好对应的锁就可以。假设你的代码仅仅读数据,能够非常多人同一时候读。但不能同一时候写,那就上读锁。假设你的代码改动数据。仅仅能有一个人在写。且不能同一时候读取,那就上写锁。总之。读的时候上读锁,写的时候上写锁!

ReentrantReadWriteLock会使用两把锁来解决这个问题。一个读锁。一个写锁
线程进入读锁的前提条件:没有其它线程的写锁,没有写请求或者有写请求,但调用线程和持有锁的线程是同一个。

线程进入写锁的前提条件:没有其它线程的读锁。没有其它线程的写锁。

总结这个锁机制的特性:

(a).重入方面其内部的WriteLock能够获取ReadLock,可是反过来ReadLock想要获得WriteLock则永远都不要想。

 
     (b).WriteLock能够降级为ReadLock。顺序是:先获得WriteLock再获得ReadLock。然后释放WriteLock,这时候线程将保持Readlock的持有。反过来ReadLock想要升级为WriteLock则不可能,为什么?參看(a),呵呵. 
     (c).ReadLock能够被多个线程持有而且在作用时排斥不论什么的WriteLock,而WriteLock则是全然的相互排斥。

这一特性最为重要。由于对于高读取频率而相对较低写入的数据结构。使用此类锁同步机制则能够提高并发量。 
     (d).无论是ReadLock还是WriteLock都支持Interrupt,语义与ReentrantLock一致。 
     (e).WriteLock支持Condition而且与ReentrantLock语义一致。而ReadLock则不能使用Condition,否则抛出UnsupportedOperationException异常。

代码典例:

package cn.itcast.lesson12;import java.io.ObjectOutputStream.PutField;import java.util.Random;import java.util.concurrent.locks.ReentrantLock;import java.util.concurrent.locks.ReentrantReadWriteLock;import org.omg.CORBA.PUBLIC_MEMBER;public class ReadWriteLockTest {	public static void main(String[] args) {		final Queue3 q3 = new Queue3();		for (int i=0; i < 3; i++) {			new Thread() {				public void run() {					while (true) {						q3.get();					}				}			}.start();			new Thread() {				public void run() {					while (true) {						//传入一个data值						q3.put(new Random().nextInt(10000));					}				}			}.start();		}	}}class Queue3{		private Object data = null;//共享數據,仅仅能有一个线程能写该数据。但有多个线程能读该数据	private ReentrantReadWriteLock rw1 = new ReentrantReadWriteLock();		public void get(){			rw1.readLock().lock();			System.out.println(Thread.currentThread().getName()+" be ready to read data!");			try{				Thread.sleep((long) (Math.random()*1000));			}catch (Exception e) {				e.printStackTrace();			}			System.out.println(Thread.currentThread().getName()+"have read data: " + data);		rw1.readLock().unlock();		} 		public void put(Object data){			rw1.writeLock().lock();			System.out.println(Thread.currentThread().getName()+" be ready to write data!");			try{				Thread.sleep((long) (Math.random()*1000));			}catch (Exception e) {				e.printStackTrace();			}			this.data = data;			System.out.println(Thread.currentThread().getName()+"have write data: "+ data);		rw1.writeLock().unlock();	}}
结果浏览:

结果分析:.ReadLock能够被多个线程持有而且在作用时排斥不论什么的WriteLock,而WriteLock则是全然的相互排斥。这一特性最为重要,由于对于高读取频率而相对较低写入的数据结构。使用此类锁同步机制则能够提高并发量。 

版权声明:本文博客原创文章。博客,未经同意,不得转载。

你可能感兴趣的文章
angularjs表达式中的HTML内容,如何不转义,直接表现为html元素
查看>>
css技巧
查看>>
Tyvj 1728 普通平衡树
查看>>
[Usaco2015 dec]Max Flow
查看>>
javascript性能优化
查看>>
多路归并排序之败者树
查看>>
java连接MySql数据库
查看>>
转:Vue keep-alive实践总结
查看>>
android studio修改新项目package名称
查看>>
深入python的set和dict
查看>>
C++ 11 lambda
查看>>
Hadoop2.5.0 搭建实录
查看>>
实验吧 recursive write up
查看>>
High-speed Charting Control--MFC绘制图表(折线图、饼图、柱形图)控件
查看>>
go test命令參数问题
查看>>
linux 搜索文本
查看>>
超实用Mac软件分享(二)
查看>>
Android JSON数据解析
查看>>
DEV实现日期时间效果
查看>>
java注解【转】
查看>>