瘋狂

Condition（條件） 將 Object 監(jiān)視器方法（wait、notify 和 notifyAll）分解成截然不同的對(duì)象，以便通過(guò)將這些對(duì)象與任意 Lock 實(shí)現(xiàn)組合使用，為每個(gè)對(duì)象提供多個(gè)等待 set （wait-set）。其中，Lock 替代了 synchronized 方法和語(yǔ)句的使用，Condition 替代了 Object 監(jiān)視器方法的使用。
下面解釋下Condition api里面的例子(生產(chǎn)者，消費(fèi)者)：

public class ConditionTest {

 final Lock lock = new ReentrantLock();
     final Condition notFull  = lock.newCondition(); //生產(chǎn)者的前提條件，沒有達(dá)到次條件就阻塞
     final Condition notEmpty = lock.newCondition(); //消費(fèi)者的前提條件，沒有達(dá)到次條件就阻塞
  
     final Object[] items = new Object[100];
     int putptr, takeptr, count;
  //生產(chǎn)
     public void put(Object x) throws InterruptedException {
       lock.lock();
       try {
         while (count == items.length)//如果滿了，就讓需要條件為：沒滿的的線程(生產(chǎn)者)等
           notFull.await();
         items[putptr] = x;
         if (++putptr == items.length) putptr = 0;
         ++count;
         notEmpty.signal();//如果已經(jīng)生產(chǎn)了，就讓需要條件為不為空的線程(消費(fèi)者)執(zhí)行
       } finally {
         lock.unlock();
       }
     }
  //消費(fèi)
     public Object take() throws InterruptedException {
       lock.lock();
       try {
         while (count == 0)//如果為空就讓需要條件為不為空的線程(消費(fèi)者)等
           notEmpty.await();
         Object x = items[takeptr];
         if (++takeptr == items.length) takeptr = 0;
         --count;
         notFull.signal();//如果消費(fèi)了，就讓條件為不滿的線程(生產(chǎn)者)執(zhí)行
         return x;
       } finally {
         lock.unlock();
       }
     }
   }