Java多线程进阶（二）—— J.U.C之locks框架：接口

本文首发于一世流云的专栏： https://segmentfault.com/blog...

本系列文章中所说的juc-locks锁框架就是指java.util.concurrent.locks包，该包提供了一系列基础的锁工具，用以对synchronizd、wait、notify等进行补充、加强。
juc-locks锁框架中一共就三个接口：Lock、Condition、ReadWriteLock，接下来对这些接口做介绍，更详细的信息能够参考Oracle官方的文档。

1、Lock接口简介

Lock接口能够视为synchronized的加强版，提供了更灵活的功能。该接口提供了限时锁等待、锁中断、锁尝试等功能。

1.1 接口定义

该接口的方法声明以下：

须要注意lock()和lockInterruptibly()这两个方法的区别：

lock()方法相似于使用synchronized关键字加锁，若是锁不可用，出于线程调度目的，将禁用当前线程，而且在得到锁以前，该线程将一直处于休眠状态。
lockInterruptibly()方法顾名思义，就是若是锁不可用，那么当前正在等待的线程是能够被中断的，这比synchronized关键字更加灵活。

1.2 使用示例

能够看到，Lock做为一种同步器，通常会用一个finally语句块确保锁最终会释放。

Lock lock = ...;
if (lock.tryLock()) {
    try {
        // manipulate protected state
    } finally {
        lock.unlock();
    }
} else {
    // perform alternative actions
}

2、Condition接口简介

Condition能够看作是Obejct类的wait()、notify()、notifyAll()方法的替代品，与Lock配合使用。
当线程执行condition对象的await方法时，当前线程会当即释放锁，并进入对象的等待区，等待其它线程唤醒或中断。

JUC在实现Conditon对象时，实际上是经过实现AQS框架，来实现了一个Condition等待队列，这个在后面讲AQS框架时会详细介绍，目前只要了解Condition如何使用便可。

2.1 接口定义

2.2 使用示例

Oracle官方文档中给出了一个缓冲队列的示例：

假定有一个缓冲队列，支持 put 和 take 方法。若是试图在空队列中执行 take 操做，则线程将一直阻塞，直到队列中有可用元素；若是试图在满队列上执行 put 操做，则线程也将一直阻塞，直到队列不满。

class BoundedBuffer {
    final Lock lock = new ReentrantLock();
    final Condition notFull = lock.newCondition();
    final Condition notEmpty = lock.newCondition();
 
    final Object[] items = new Object[100];
    int putptr, takeptr, count;
 
    public void put(Object x) throws InterruptedException {
        lock.lock();
        try {
            while (count == items.length)    //防止虚假唤醒，Condition的await调用通常会放在一个循环判断中
                notFull.await();
            items[putptr] = x;
            if (++putptr == items.length)
                putptr = 0;
            ++count;
            notEmpty.signal();
        } finally {
            lock.unlock();
        }
    }
 
    public Object take() throws InterruptedException {
        lock.lock();
        try {
            while (count == 0)
                notEmpty.await();
            Object x = items[takeptr];
            if (++takeptr == items.length)
                takeptr = 0;
            --count;
            notFull.signal();
            return x;
        } finally {
            lock.unlock();
        }
    }
}

等待 Condition 时，为了防止发生“虚假唤醒”， Condition 通常都是在一个循环中被等待，并测试正被等待的状态声明，如上述代码注释部分。
虽然上面这个示例程序即便不用while，改用if判断也不会出现问题，可是最佳实践仍是作while循环判断—— Guarded Suspension模式，以防遗漏状况。

3、ReadWriteLock接口简介

ReadWriteLock接口是一个单独的接口（未继承Lock接口），该接口提供了获取读锁和写锁的方法。

所谓读写锁，是一对相关的锁——读锁和写锁，读锁用于只读操做，写锁用于写入操做。读锁能够由多个线程同时保持，而写锁是独占的，只能由一个线程获取。

3.1 接口定义

3.2 使用注意

读写锁的阻塞状况以下图：

举个例子，假设我有一份共享数据——订单金额，大多数状况下，线程只会进行高频的数据访问（读取订单金额），数据修改（修改订单金额）的频率较低。
那么通常状况下，若是采用互斥锁，读/写和读/读都是互斥的，性能显然不如采用读写锁。

另外，因为读写锁自己的实现就远比独占锁复杂，所以，读写锁比较适用于如下情形：

1. 高频次的读操做，相对较低频次的写操做；
2. 读操做所用时间不会过短。（不然读写锁自己的复杂实现所带来的开销会成为主要消耗成本）