java多线程：ReentrantReadWriteLock读写锁使用

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();

	}

}

结果浏览：

java多线程：ReentrantReadWriteLock读写锁使用

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

秒客网

java多线程：ReentrantReadWriteLock读写锁使用

相关文章