在 "aa方法开始了Thread-0" 输出后 ， 等待了两秒后 ， 通过 await 方法阻塞当前线程 ， 然后把锁资源让给 "Thread-1" ， 输出 "bb方法开始了Thread-1"， 两秒后再输出 "bb方法结束了Thread-1" ， 然后通过signal唤醒 ， 因为这里只有一个 "Thread-0" 线程阻塞所以直接唤醒 "Thread-0" ， 最后输出 "aa方法结束了Thread-0" 执行完毕 。
ReentrantReadWriteLockReentrantReadWriteLock 是一种特殊的 Lock实现类 ， 它除了可以实现上面提到的所有功能外 ， 还能实现 "共享锁" 和 "排他锁"。 它的读锁就是 "共享锁"， 写锁是 "排他锁"。
共享锁共享锁就是不同线程可以同时执行 ， 相当于没有加锁 。 那么问题来了 ， 既然多线程可以同时获取共享锁 ， 那么共享锁的意义是什么呢？答案就是为了和 "排他锁" 互斥 。 下面先看 ReentrantReadWriteLock 共享锁的例子 。
1 public class Test { 2private ReentrantReadWriteLock rwl = new ReentrantReadWriteLock(); 34public static void main(String[] args){ 5final Test test = new Test(); 6new Thread(){ 7public void run() { 8test.get(Thread.currentThread()); 9};10}.start();11new Thread(){12public void run() {13test.get(Thread.currentThread());14};15}.start();16}17public void get(Thread thread) {18rwl.readLock().lock();19try {20long start = System.currentTimeMillis();21while(System.currentTimeMillis() - start <= 1) {22System.out.println(thread.getName()+"正在进行读操作");23}24System.out.println(thread.getName()+"读操作完毕");25} finally {26rwl.readLock().unlock();27}28}29 }结果：
文章插图
可以看到 ， 在调用 readLock的lock()方法后 ， 两个线程依然能交叉执行 ， 这就是共享锁的特点
排它锁排它锁就是我们常见的锁 ， 同一时间锁资源只能被一个线程所占用 ， 它和 "共享锁" 是互斥关系 。 下面还是以上面的代码改成 "写锁"试试 。
1 public class Test { 2private ReentrantReadWriteLock rwl = new ReentrantReadWriteLock(); 34public static void main(String[] args){ 5final Test test = new Test(); 6new Thread(){ 7public void run() { 8test.get(Thread.currentThread()); 9};10}.start();11new Thread(){12public void run() {13test.get(Thread.currentThread());14};15}.start();16}17public void get(Thread thread) {18rwl.writeLock().lock();19try {20long start = System.currentTimeMillis();21while(System.currentTimeMillis() - start <= 1) {22System.out.println(thread.getName()+"正在进行写操作");23}24System.out.println(thread.getName()+"写操作完毕");25} finally {26rwl.writeLock().unlock();27}28}29 }结果：
文章插图
可以看到 ， 两个线程是互斥关系 。
为了严谨 ， 再比较一下 "读锁" 与 "写锁" 的互斥关系
1 public class Test { 2private ReentrantReadWriteLock rwl = new ReentrantReadWriteLock(); 34public static void main(String[] args){ 5final Test test = new Test(); 6new Thread(){ 7public void run() { 8test.getWrite(Thread.currentThread()); 9};10}.start();11new Thread(){12public void run() {13test.getRead(Thread.currentThread());14};15}.start();16}17public void getWrite(Thread thread) {18rwl.writeLock().lock();19try {20long start = System.currentTimeMillis();21while(System.currentTimeMillis() - start