import java.util.concurrent.locks.*;
class DuckMsg{int size;//烤鸭的大小String id;//烤鸭的厂家和标号
    DuckMsg(){}DuckMsg(int size, String id){this.size=size;this.id=id;}public String toString(){return id + " 大小为:"  + size;}
}
class Duck{private int count=0;//生产烤鸭的总数private int putId=0, takeId=0;//分别表示存入的Id 和 取出烤鸭的Id
    Lock lock = new ReentrantLock();DuckMsg[] dk = new DuckMsg[100];//烤鸭的容器Condition conProduce = lock.newCondition();Condition conConsume = lock.newCondition();public void put(int sz){lock.lock();try{while(count==dk.length)//一直等到烤鸭全部生产完毕之后所有的生产线程都停止....
               conProduce.await();dk[putId++]=new DuckMsg(sz, Thread.currentThread().getName()+":"+(putId-1));if(putId==dk.length)  putId=0;//啥意思呢？烤鸭的编号就是1到100， 如果过了100，那么再从编号1开始！++count;conConsume.signal();}catch(InterruptedException e){}finally{lock.unlock();}        }public void get(){lock.lock();try{while(count==0)conConsume.await();System.out.println(dk[takeId++]);System.out.println("......." + Thread.currentThread().getName());//打印消费的厂家if(takeId==dk.length)  takeId=0;--count;conProduce.signal();}catch(InterruptedException e){}finally{lock.unlock();}}
}class Producer implements Runnable{Duck duck;Producer(Duck duck){this.duck=duck;}public void run(){for(int i=1; ; ++i)duck.put(i);}
}class Consumer implements Runnable{Duck duck;Consumer(Duck duck){this.duck=duck;}public void run(){while(true)duck.get();}
}public class ProduceConsumeDemo{public static void main(String[] args){Duck duck=new Duck();Thread t1 = new Thread(new Producer(duck), "生产厂家 1");Thread t2 = new Thread(new Producer(duck), "生产厂家 2");Thread t3 = new Thread(new Consumer(duck), "消费厂家 1");Thread t4 = new Thread(new Consumer(duck), "消费厂家 2");t1.start();t2.start();t3.start();t4.start();}
}