[ JAVA开发技术 ] 【守望者 j2se】并发包-Condition

Condition:Condition 将 Object 监视器方法（wait、notify 和 notifyAll）分解成截然不同的对象，以便通过将这些对象与任意 Lock 实现组合使用，为每个对象提供多个等待 set（wait-set）。其中，Lock 替代了 synchronized 方法和语句的使用，Condition 替代了 Object 监视器方法的使用。条件（也称为条件队列 或条件变量）为线程提供了一个含义，以便在某个状态条件现在可能为 true 的另一个线程通知它之前，一直挂起该线程（即让其“等待”）。因为访问此共享状态信息发生在不同的线程中，所以它必须受保护，因此要将某种形式的锁与该条件相关联。等待提供一个条件的主要属性是：以原子方式 释放相关的锁，并挂起当前线程，就像 Object.wait 做的那样。Condition 实例实质上被绑定到一个锁上。要为特定 Lock 实例获得 Condition 实例，请使用其 newCondition() 方法。

private boolean isFull=false;//未满

private ReentrantLock  lock=new  ReentrantLock();

private  Condition  notfullCondition=lock.newCondition();

private  Condition  notemptCondition=lock.newCondition();

//放入数据

public  void   put()

{    //申请锁

       lock.lock();

    if(!this.isFull)

    {       

      try { 

        System.out.println("放满了,可以来取");

           isFull=!isFull;

           this.notemptCondition.signal();

    } catch(Exception e) {

     e.printStackTrace();

    }finally

    {  //释放锁

       lock.unlock();

    }

    }

    else

    {

     try {

      this.notfullCondition.await();

   } catch (InterruptedException e) {

    

    e.printStackTrace();

   }

    }

  

}

  //取得数据

public  void   get()

{     //申请锁

       lock.lock();

    if(this.isFull)

    {       

      try { 

        System.out.println("取完了,来放");

        isFull=!isFull;

        this.notfullCondition.signal();

    } catch(Exception e) {

     e.printStackTrace();

    }finally

    {  //释放锁

       lock.unlock();

    }

      

    }

    else

    {

       try {

     this.notemptCondition.await();

    } catch (InterruptedException e) {

    

     e.printStackTrace();

    }

    }

  

}

}

//get

public class GetThread  implements  Runnable {

private  CangKu   ck;

public GetThread(CangKu ck) { 

  this.ck = ck;

  new Thread(this).start();

}

public void run() {

    while(true) 

    {

      this.ck.get();

    }

}

}

//put

public class PutThread extends Thread {

private CangKu ck;

public PutThread(CangKu ck) {

  this.ck = ck;

  this.start();

}

    public  void  run()

    {

     while(true)

     {

      this.ck.put();

     }

    }

}

public class ConditionMain {

/**

  *  Condition实例测试

  */

public static void main(String[] args) {

  CangKu     cu=new CangKu();

  PutThread  pth=new PutThread(cu);

  GetThread  gth=new  GetThread(cu);

}

}