通达信可以用的数据接口-Java多线程编程 16 等待/通知模式接口Condition接口深入分析

前几篇：

Java多通达信可以用的数据接口,线程编程--Java中的队列同步器AQS和ReentrantLock锁原理简要分析

Java多通达信可以用的数据接口,线程编程--读写锁ReentrantReadWriteLock深入分析

Condition接口简介

在上述两篇文章中讲解AQS的时候，我们已经知道了同步队列AQS的内部类ConditionObject实现了Condition接口，使用ReentrantLock和ReentrantReadWriteLock的内部类Sync我们可以通过newCondition()方法创建一个或多个ConditionObject对象。

在使用synchronized作为同步的时候，可以使用任意的Java对象作为锁，这是因为任意的一个Java对象，都拥有一组监视器方法，这些监视器方法是定义在超类Object中的，主要包括：wait、notify、notifyAll这些方法，这些方法与synchronized关键字配合实现等待/通知模式。

Condition接口也提供了类似object的监视器方法，与Lock配合使用也可以实现等待/通知模式，虽然如此，但是两者在使用方式以及功能功能上还是有些许差别的，主要差别如下：

Condition接口定义：

可以看到基本和Object超类中定义的差不多。

各接口的含义如下：

Condition接口使用案例

Java多线程编程 16 等待/通知模式接口Condition接口深入分析

示例代码如下:

public class MyService {

    private Lock lock = new ReentrantLock();
    public Condition condition = lock.newCondition();

    public void await() {
        try {
            lock.lock();
            System.out.println(' await时间为 ' + System.currentTimeMillis());
            condition.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
    }

    public void signal() {
        try {
            lock.lock();
            System.out.println('signal时间为 ' + System.currentTimeMillis());
            condition.signal();
        } finally {
            lock.unlock();
        }
    }
}

测试代码如下：

public class Run {

    public static void main(String[] args) throws InterruptedException {

        MyService service = new MyService();
        new ThreadA(service).start();
        Thread.sleep(3000);
        service.signal();
    }
}

执行结果：

看过《Java多线程编程--线程间通信机制的介绍与使用》这篇文章的小伙伴都应该还记得，我们使用wait和notify实现了一个阻塞队列，现在我们使用Condition对象搞一些事情，使用Condition把这个阻塞队列重写一下，代码如下：

public class MyQueue {

    //1、需要一个承装元素的集合
    private final LinkedList