java中多線程模擬（多生產，多消費，Lock實現同步鎖，替代synchronized同步代碼塊）...

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();}
}

?