java中的Condition协作线程接口类

在Java的Condition接口中，存在的几个方法跟Synchronized中的wait(),waitall(),wait(time ^)，这个几个方法一一对应起来，但是在Lock.newCondition()返回中可以指定指定的线程释放和等待资源。

请看【唤醒单个线程】实例：

package TestThread.TestCondition;import java.util.concurrent.locks.ReentrantLock;import java.util.concurrent.locks.*;public class TestCondition {	public static void main(String[] args) {		ReentrantLock lock = new ReentrantLock();		Condition condition = lock.newCondition();		Test1 th1 = new Test1(lock, condition, "线程1");		Test1 th2 = new Test1(lock, condition, "线程2");		Test1 th3 = new Test1(lock, condition, "线程3");		Test2 t2 = new Test2(condition, lock, "我是唤醒线程");		th1.start();		th2.start();		th3.start();		try {			Thread.sleep(1000);			t2.start();		} catch (InterruptedException e) {			e.printStackTrace();		}	}}class Test1 extends Thread {	private ReentrantLock lock;	private Condition condition1;	public Test1(ReentrantLock lock, Condition condition1, String name) {		super(name);		this.lock = lock;		this.condition1 = condition1;	}	@Override	public void run() {		for (int i = 0; i < 10; i++) {			try {				lock.lock();// 加锁				if (i == 5) {					try {						condition1.await();						System.out.println(Thread.currentThread().getName() + "当前线程获取到的值为：++++++++++++" + i);					} catch (InterruptedException e) {						System.out.println(Thread.currentThread().getName() + ":线程被中断了！");					}				} else {					System.out.println(Thread.currentThread().getName() + ":当前线程获取到的值为===》" + i);				}			} catch (Exception e) {				System.out.println("系统发生异常！");			} finally {				lock.unlock();// 解锁			}		}	}}class Test2 extends Thread {	private Condition condition;	public ReentrantLock lock;	/**	 * @param condition协作对象	 * @param lock锁对象	 * @param name线程名称	 */	public Test2(Condition condition, ReentrantLock lock, String name) {		super(name);		this.condition = condition;		this.lock = lock;	}	@Override	public void run() {		try {			lock.lock();// 加锁			condition.signal();// 唤醒启动单个线程			System.out.println(Thread.currentThread().getName() + ":已经唤醒了一个线程！");		} catch (Exception e) {			System.out.println(Thread.currentThread().getName() + ":线程挂了！");		} finally {			lock.unlock();// 解锁		}	}}