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

?

轉載于:https://www.cnblogs.com/hujunzheng/p/3920876.html

總結

以上是生活随笔為你收集整理的java中多线程模拟（多生产，多消费，Lock实现同步锁，替代synchronized同步代码块）...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。