/**生產者消費者問題，涉及到幾個類

*?第一，這個問題本身就是一個類，即主類

*?第二，既然是生產者、消費者，那么生產者類和消費者類就是必須的

*?第三，生產什么，消費什么，所以物品類是必須的，這里是饅頭類

*?第四，既然是線程，那么就不是一對一的，也就是說不是生產一個消費一個，既然這樣，多生產的往哪里放，

*??????現實中就是筐了，在計算機中也就是數據結構，筐在數據結構中最形象的就是棧了，因此還要一個棧類

*/

packagethread;

publicclassProduceConsume?{

publicstaticvoidmain(String[]?args)?{

SyncStack?ss?=?newSyncStack();//建造一個裝饅頭的框

Producer?p?=?newProducer(ss);//新建一個生產者，使之持有框

Consume?c?=?newConsume(ss);//新建一個消費者，使之持有同一個框

Thread?tp?=?newThread(p);//新建一個生產者線程

Thread?tc?=?newThread(c);//新建一個消費者線程

tp.start();//啟動生產者線程

tc.start();//啟動消費者線程

}

}

//饅頭類

classSteamBread{

intid;//饅頭編號

SteamBread(intid){

this.id?=?id;

}

publicString?toString(){

return"steamBread:"+id;

}

}

//裝饅頭的框，棧結構

classSyncStack{

intindex?=0;

SteamBread[]?stb?=?newSteamBread[6];//構造饅頭數組，相當于饅頭筐，容量是6

//放入框中，相當于入棧

publicsynchronizedvoidpush(SteamBread?sb){

while(index==stb.length){//筐滿了，即棧滿，

try{

this.wait();//讓當前線程等待

}?catch(InterruptedException?e)?{

//?TODO?Auto-generated?catch?block

e.printStackTrace();

}

}

this.notify();//喚醒在此對象監視器上等待的單個線程，即消費者線程

stb[index]?=?sb;

this.index++;

}

//從框中拿出，相當于出棧

publicsynchronizedSteamBread?pop(){

while(index==0){//筐空了，即棧空

try{

this.wait();

}?catch(InterruptedException?e)?{

//?TODO?Auto-generated?catch?block

e.printStackTrace();

}

}

this.notify();

this.index--;//push第n個之后，this.index++，使棧頂為n+1，故return之前要減一

returnstb[index];

}

}

//生產者類，實現了Runnable接口，以便于構造生產者線程

classProducerimplementsRunnable{

SyncStack?ss?=?null;

Producer(SyncStack?ss){

this.ss?=?ss;

}

@Override

publicvoidrun()?{

//?開始生產饅頭

for(inti=0;i<20;i++){

SteamBread?stb?=?newSteamBread(i);

ss.push(stb);

System.out.println("生產了"+stb);

try{

Thread.sleep(10);//每生產一個饅頭，睡覺10毫秒

}?catch(InterruptedException?e)?{

//?TODO?Auto-generated?catch?block

e.printStackTrace();

}

}

}

}

//消費者類，實現了Runnable接口，以便于構造消費者線程

classConsumeimplementsRunnable{

SyncStack?ss?=?null;

publicConsume(SyncStack?ss)?{

super();

this.ss?=?ss;

}

@Override

publicvoidrun()?{

//?TODO?Auto-generated?method?stub

for(inti=0;i<20;i++){//開始消費饅頭

SteamBread?stb?=?ss.pop();

System.out.println("消費了"+stb);

try{

Thread.sleep(100);//每消費一個饅頭，睡覺100毫秒。即生產多個，消費一個

}?catch(InterruptedException?e)?{

//?TODO?Auto-generated?catch?block

e.printStackTrace();

}

}

}

}

運行結果：

總結

以上是生活随笔為你收集整理的java多线程 生产者消费者_java多线程之生产者消费者经典问题 - 很不错的范例的全部內容，希望文章能夠幫你解決所遇到的問題。

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