多线程之Condition

等待/通知模式

Sychronized和wait、notify、notifyAll可以实现等待/通知模式，
而ReentrantLock类借助Condition对象也能实现等待/通知模式,
Condition对象的await、signal和signalAll对应着Object类的wait、notify和notifyAll.
Condition使用的时候也和wait一样要获得同步监视器，一般是通过ReentrantLock类的lock实现的。

例子：

public class MyService {
    private Lock lock=new ReentrantLock();
    private 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(){
            lock.lock();
            System.out.println("signal时间为 "+System.currentTimeMillis());
            condition.signal();
            lock.unlock();
    }
}


public class ThreadA extends Thread {
    private MyService myService;

    public ThreadA(MyService myService) {
        this.myService = myService;
    }

    @Override
    public void run() {
        myService.await();
    }
}


public class Run {
    public static void main(String[] args) throws InterruptedException {
        MyService myService = new MyService();
        ThreadA threadA = new ThreadA(myService);
        threadA.start();
        Thread.sleep(1000);
        myService.signal();
    }
}

结果：

await时间为 1545543043026
signal时间为 1545543044025

ReentrantLock类的方法

ReentrantLock lock=new ReentrantLock();
lock.getHoldCount() 查询当前线程保持此锁的个数，也就是调用lock()方法的次数。
lock.getQueueLength() 返回正等待获取此锁定的线程估计数。
lock.getWaitQueueLength() 返回等待此锁定相关的给定条件condition的线程估计数。
lock.hasQueuedThread() 查询指定的线程是否正在等待获取此锁定
lock.hasQueuedThreads() 查询是否有线程正在等待获取此锁定
lock.hasWaiters() 查询是否有线程正在等待与此锁定有关的condition