Condition条件，与重入锁合作使用

1、引入Condiion

Condition的作用与Object.wait()和Object.notify()的作用大致是相同的。但是wait()和notify()方法是与synchronized关键字合作使用的，而Condition是与重入锁相关联的。通过Lock接口（重入锁实现了这一接口）的new Condition()方法可以生成一个与当前重入锁绑定的Condition实例。利用Condition对象，可以让线程在合适的时间等待，或者在某一个特定的时间得到通知。

2、Condition接口提供的基本方法

void await() throws InterruptedException;
void awaitUninterrruptibly();
long awaitNanos(long nanosTimeout) throws InterruptedException;
boolean await(long time, TmeUnit unit) throws InterruptedException;
boolean await(Date deadline) throws InterruptedException;
void signal();
void signalAll();

以上方法的含义如下：

• await()方法会使当前线程等待，同时释放当前锁,当其他线程中使用signal()或signalAll()方法时，线程会重新获得锁并继续执行。或者当其他线程被中断时，也能跳出等待。这和Object.wait()很相似。
• awaitUninterruptibly()与await()方法基本相同，但他并不会在中断过程中响应中断。
• signal()方法用于唤醒一个在等待中的线程。相对的signalAll()方法会唤醒所有在等待中的线程。这和Object.notifyAll()很类似。

3、简单演示一下Condition的功能

演示代码如下：

public class ReentrantLockCondition implements Runnable
{
    public static ReentrantLock lock = new ReentrantLock();
    //通过ReentrantLock创建Condition实例，并与之关联
    public static Condition  condition = lock.newCondition();

    @Override
    public void run()
    {
        try
        {
            lock.lock();
            condition.await();
            System.out.println("Thread is going on");
        }
        catch (InterruptedException e)
        {
            e.printStackTrace();
        }
        finally
        {
            lock.unlock();
        }
    }


    public static void main(String[] args) throws InterruptedException
    {
        ReentrantLockCondition tl = new ReentrantLockCondition();
        Thread t1 = new Thread(tl);
        t1.start();
        Thread.sleep(2000);
        //通知t1继续执行
        lock.lock();
        condition.signal();
        lock.unlock();
    }
}

与Object.wait()和Object.notify()方法类似，当前线程使用Condition.await()时，要求线程持有相关的重入锁，在Condition.await()调用后，这个线程会释放这把锁。同理，在Condition.signal()方法调用时，也要求线程先获得相关的锁。在signal()方法调用后，系统会从当前Condtion对象的等待队列中，唤醒一个线程。一旦线程被唤醒，它会重新尝试获得与之绑定的重入锁，一旦成功获取，就可以继续执行了。因此，在signal()方法调用之后，一般需要释放相关的锁，谦让给被唤醒的线程，让它可以继续执行。