概述
ReadWriteLock是一個接口,在它里面只定義了兩個方法:一個讀的鎖和一個寫的鎖。
讀的鎖:A線程獲取了讀的鎖,那么B線程也可以獲取讀的鎖。
寫的鎖:A線程獲取了寫的鎖,那么B線程不能獲取讀也不能獲取寫的鎖。
public interface ReadWriteLock {/*** Returns the lock used for reading.* 讀的鎖,A線程獲取了讀的鎖,那么B線程也可以獲取讀的鎖* @return the lock used for reading.*/Lock readLock();/*** Returns the lock used for writing.* 寫的鎖,A線程獲取了寫的鎖,那么B線程不能獲取讀也不能獲取寫的鎖。* @return the lock used for writing.*/Lock writeLock();
}
代碼
/*** 使用讀寫鎖,可以實現讀寫分離鎖定,讀操作并發進行,寫操作鎖定單個線程* * 如果有一個線程已經占用了讀鎖,則此時其他線程如果要申請寫鎖,則申請寫鎖的線程會一直等待釋放讀鎖。* 如果有一個線程已經占用了寫鎖,則此時其他線程如果申請寫鎖或者讀鎖,則申請的線程會一直等待釋放寫鎖。* @author**/
public class MyReentrantReadWriteLock {private ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();public static void main(String[] args) {final MyReentrantReadWriteLock test = new MyReentrantReadWriteLock();new Thread(){public void run() {test.get(Thread.currentThread());test.write(Thread.currentThread());};}.start();new Thread(){public void run() {test.get(Thread.currentThread());test.write(Thread.currentThread());};}.start();} /*** 讀操作,用讀鎖來鎖定* @param thread*/public void get(Thread thread) {rwl.readLock().lock();try {long start = System.currentTimeMillis();while(System.currentTimeMillis() - start <= 1) {System.out.println(thread.getName()+"正在進行讀操作");}System.out.println(thread.getName()+"讀操作完畢");} finally {rwl.readLock().unlock();}}/*** 寫操作,用寫鎖來鎖定* @param thread*/public void write(Thread thread) {rwl.writeLock().lock();;try {long start = System.currentTimeMillis();while(System.currentTimeMillis() - start <= 1) {System.out.println(thread.getName()+"正在進行寫操作");}System.out.println(thread.getName()+"寫操作完畢");} finally {rwl.writeLock().unlock();}}
}
運行結果
讀的時候,線程是并行的
寫的時候,是單線程的