java读写锁
2017-01-12 18:55
351 查看
java提供了锁机制,如果是普通的锁或者同步监视器,使用该同步监视器的方法或者代码块一定会串行执行,但是如果是你想用一个同步监视器控制几个方法中的某些串行,某些并行,从而提高执行效率,那么可以用java提供的读写锁。
读写锁,顾名思义,就是分为读锁和写锁,读读可同时,读写不能同时,写写不能同时。
看下面的例子:
class ReadWrite {
private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
public void read() throws InterruptedException{
lock.readLock().lock();
for(int i=0;i<100;i++){
System.out.println("---read---"+Thread.currentThread().getName());
if(i/2==0){
Thread.sleep(500);
}
}
lock.readLock().unlock();
}
public void write() throws InterruptedException{
lock.writeLock().lock();
for(int i=0;i<100;i++){
System.out.println("---write---"+Thread.currentThread().getName());
if(i/2==0){
Thread.sleep(1000);
}
}
lock.writeLock().unlock();
}
}
声明了一个读写类,里面分别提供了读方法和写方法,读方法使用的是ReentrantReadWriteLock的readLock,分别打印100次线程名,然后偶数时候就睡眠;同理,写方法使用的是writeLock,功能与读方法一致。
声明读线程和写线程,调用读方法和写方法。
一个测试类,开启了3个读线程和3个写线程,注意,此处传入的是一个ReadWrite实例,这样才能保证用的是一把读写锁,反之,如果不用同一个线程同步监视器,是不能控制并发的。
这样,运行结果应该是读线程之间可并发,其他的组合不行。
看测试结果:
读写锁,顾名思义,就是分为读锁和写锁,读读可同时,读写不能同时,写写不能同时。
看下面的例子:
class ReadWrite {
private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
public void read() throws InterruptedException{
lock.readLock().lock();
for(int i=0;i<100;i++){
System.out.println("---read---"+Thread.currentThread().getName());
if(i/2==0){
Thread.sleep(500);
}
}
lock.readLock().unlock();
}
public void write() throws InterruptedException{
lock.writeLock().lock();
for(int i=0;i<100;i++){
System.out.println("---write---"+Thread.currentThread().getName());
if(i/2==0){
Thread.sleep(1000);
}
}
lock.writeLock().unlock();
}
}
class ReadThread implements Runnable{ ReadWrite wr ; ReadThread(ReadWrite wr){ this.wr=wr; } @Override public void run() { try { wr.read(); } catch (InterruptedException e) { e.printStackTrace(); } } }
class WriteThread implements Runnable{ ReadWrite wr ; WriteThread(ReadWrite wr){ this.wr=wr; } @Override public void run() { try { wr.write(); } catch (InterruptedException e) { e.printStackTrace(); } } }
public class ReadWriteLockTest { public static void main(String[] args) { //开启3个读线程读 3个线程写 ReadWrite wr = new ReadWrite(); for(int i=0;i<3;i++){ WriteThread w = new WriteThread(wr); ReadThread r = new ReadThread(wr); new Thread(w).start(); new Thread(r).start(); } } }
声明了一个读写类,里面分别提供了读方法和写方法,读方法使用的是ReentrantReadWriteLock的readLock,分别打印100次线程名,然后偶数时候就睡眠;同理,写方法使用的是writeLock,功能与读方法一致。
声明读线程和写线程,调用读方法和写方法。
一个测试类,开启了3个读线程和3个写线程,注意,此处传入的是一个ReadWrite实例,这样才能保证用的是一把读写锁,反之,如果不用同一个线程同步监视器,是不能控制并发的。
这样,运行结果应该是读线程之间可并发,其他的组合不行。
看测试结果:
相关文章推荐
- 基于oracle中锁的深入理解
- C#多线程编程中的锁系统(三)
- MySQL中Innodb的事务隔离级别和锁的关系的讲解教程
- C#使用读写锁三行代码简单解决多线程并发的问题
- Redis数据库中实现分布式锁的方法
- FileShare枚举的使用小结(文件读写锁)
- java多线程和并发包入门示例
- Java 线程同步详解
- 举例说明Java多线程编程中读写锁的使用
- c#线程同步使用详解示例
- php session的锁和并发
- Linux多线程锁属性设置方法
- C#多线程编程中的锁系统基本用法
- Linux线程同步之信号C语言实例
- Python中使用Queue和Condition进行线程同步的方法
- PHP通过插入mysql数据来实现多机互锁实例
- PHP程序中的文件锁、互斥锁、读写锁使用技巧解析
- Java多线程编程中线程锁与读写锁的使用示例
- Java多线程编程中使用Condition类操作锁的方法详解
- Java锁之阻塞锁介绍和代码实例