我的漫漫程序之旅

專注于JavaWeb開發

隨筆 - 39, 文章 - 310, 評論 - 411, 引用 - 0

數據加載中……

生產者消費者問題(以面包為例)

package Thread;

public class ProducerConsumer

{

public static void main(String[] args)

{

SynchronizedStack ss = new SynchronizedStack();

Producer p = new Producer(ss); //產生一個生產者

Consumer c = new Consumer(ss); //產生一個消費者

new Thread(p).start(); //啟動生產者線程

new Thread(c).start(); //啟動消費者線程

}

class Bread //定義生產面包

{

int id;

Bread(int id)

{

this.id = id;

}

public String toString() //重寫toString方法

{

return "bread :" + id;

}

class SynchronizedStack //定義一個盛面包的容器

{

int index = 0;

Bread[] bread = new Bread[6];

public synchronized void putIn(Bread bread) // 放進方法

{

while(index == this.bread.length)

{

try

{

this.wait(); // 只針對synchronized

//Object對象的wait()方法,表示調用當前對象的wait()方法，運行當前對象的此方法的線程等待，直到被notify()喚醒

}

catch (InterruptedException e)

{

e.printStackTrace();

}

this.notify(); //喚醒一個wait的線程

// this.notifyAll();//喚醒所有wait的線程

this.bread[index] = bread;

index ++;

}

public synchronized Bread putOut() // 拿出方法

{

while(index == 0)

{

try

{

this.wait();

}

catch (InterruptedException e)

{

e.printStackTrace();

}

this.notify(); //喚醒一個wait的線程

// this.notifyAll();//喚醒所有wait的線程

index --;

return bread[index];

}

class Producer implements Runnable

{

SynchronizedStack ss = null;

Producer(SynchronizedStack ss)

{

this.ss = ss;

}

public void run()

{

for(int i=0;i<30;i++)

{

Bread bread = new Bread(i);

ss.putIn(bread);

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

try

{

// Thread.sleep(1000);

Thread.sleep((int)Math.random() * 1000);

}

catch(InterruptedException e)

{

e.printStackTrace();

}

class Consumer implements Runnable

{

SynchronizedStack ss = null;

Consumer(SynchronizedStack ss)

{

this.ss = ss;

}

public void run()

{

for(int i=0;i<30;i++)

{

Bread bread = ss.putOut();

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

try

{

// Thread.sleep(1000);

Thread.sleep((int)Math.random() * 1000);

}

catch(InterruptedException e)

{

e.printStackTrace();

}

posted on 2007-12-10 22:41 々上善若水々閱讀(788) 評論(0) 編輯收藏所屬分類: J2SE

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: 利用jSMSEngine開源包進行短信的收發 JDK中的URLConnection參數詳解網絡數據流的java處理 jad反編譯工具詳解統計一個字符串的重復字符出現的字數刪除指定目錄下的所有空文件夾修改MyEclipse or Eclipse的啟動畫面 JDBC利用游標分頁查詢獲取昨天的日期字符串我的第一個J2ME 程序

我的漫漫程序之旅

生產者消費者問題(以面包為例)

導航

常用鏈接

留言簿(39)

隨筆檔案(43)

文章分類(304)

文章檔案(257)

搜索

最新評論

閱讀排行榜

評論排行榜