标签：exce unlock sleep api cond com 相关 实现 tac
Condition 将 Object 监视器方法（wait、notify 和 notifyAll）分解成截然不同的对象，以便通过将这些对象与任意 Lock 实现组合使用，为每个对象提供多个等待 set（wait-set）。其中，Lock 替代了 synchronized 方法和语句的使用，Condition 替代了 Object 监视器方法的使用。
Condition 接口描述了可能会与锁有关联的条件变量。这些变量在用法上与使用 Object.wait 访问的隐式监视器类似，但提供了更强大的功能。需要特别指出的是，单个 Lock 可能与多个 Condition 对象关联。为了避免兼容性问题，Condition 方法的名称与对应的 Object 版本中的不同。
在 Condition 对象中，与 wait、notify 和 notifyAll 方法对应的分别是await、signal 和 signalAll。
Condition 实例实质上被绑定到一个锁上。要为特定 Lock 实例获得Condition 实例，请使用其 newCondition() 方法。
api相关方法：
例如：
package com.company; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /* * 生产者消费者案例： */ public class TestProductorAndConsumerForLock { public static void main(String[] args) { Clerk clerk = new Clerk(); Productor pro = new Productor(clerk); Consumer con = new Consumer(clerk); new Thread(pro, "生产者 A").start(); new Thread(con, "消费者 B").start(); // new Thread(pro, "生产者 C").start(); // new Thread(con, "消费者 D").start(); } } class Clerk { private int product = 0; private Lock lock = new ReentrantLock(); private Condition condition = lock.newCondition(); // 进货 public void get() { lock.lock(); try { if (product >= 1) { // 为了避免虚假唤醒，应该总是使用在循环中。 System.out.println("产品已满！"); try { condition.await();//替代this.wait; } catch (InterruptedException e) { } } System.out.println(Thread.currentThread().getName() + " : " + ++product); condition.signalAll();//代替this.notifyall(); } finally { lock.unlock(); } } // 卖货 public void sale() { lock.lock(); try { if (product <= 0) { System.out.println("缺货！"); try { condition.await();//替代this.wait; } catch (InterruptedException e) { } } System.out.println(Thread.currentThread().getName() + " : " + --product); condition.signalAll();//代替this.notifyall(); } finally { lock.unlock(); } } } // 生产者 class Productor implements Runnable { private Clerk clerk; public Productor(Clerk clerk) { this.clerk = clerk; } @Override public void run() { for (int i = 0; i < 20; i++) { try { Thread.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); } clerk.get(); } } } // 消费者 class Consumer implements Runnable { private Clerk clerk; public Consumer(Clerk clerk) { this.clerk = clerk; } @Override public void run() { for (int i = 0; i < 20; i++) { clerk.sale(); } } }
结果：
缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0 缺货！ 生产者 A : 1 消费者 B : 0
标签：exce unlock sleep api cond com 相关 实现 tac
原文地址：http://www.cnblogs.com/androidsuperman/p/6657818.html
