package ProConDemo;

//創建資源

public class Goods {
private String name;

//計數器
private int count = 1;

//創建一個標記
private boolean flag;

//創建資源的生產行為
public synchronized void Sale(String name) {

//判斷標記
while(flag)

//有資源就等待
try {wait();} catch (InterruptedException e) {e.printStackTrace();}

//沒有資源就生產
this.name = name +"----"+count;
count++;
System.out.println(Thread.currentThread().getName()+"生產了"+this.name);

//生產完畢改標記
flag = true;

//喚醒所有等待線程
notifyAll();

}
//創建資源的消費行為
public synchronized void Buy() {

//判斷標記
while(!flag)

//沒有資源就等待
try {wait();} catch (InterruptedException e) {e.printStackTrace();}

//有資源就消費
System.out.println(Thread.currentThread().getName()+"消費了"+this.name);

//消費完畢改標記
flag = false;

//喚醒所有等待線程
notifyAll();
}
}

?

package ProConDemo;

//創建消費者任務類

public class Cou implements Runnable{
private Goods good;
//將資源對象作為參數傳入消費者的構造函數中
public Cou(Goods good) {
this.good = good;
}
//覆蓋run()
public void run() {
while(true)
good.Buy();

}


}

package ProConDemo;

//創建生產者任務類

public class Pro implements Runnable{
private Goods good;
//將資源對象作為參數傳入生產者構造函數中
public Pro(Goods good) {
this.good = good;
}

//覆蓋run()
public void run() {
while(true)
good.Sale("面包");

}

}

//執行

package ProConDemo;

public class Demo {

public static void main(String[] args) {
// TODO Auto-generated method stub

//創建資源對象
Goods good = new Goods();
//創建生產與消費任務對象
Pro pro = new Pro(good);
Cou cou = new Cou(good);
//創建線程，并將任務對象傳入
Thread t0 = new Thread(pro);
Thread t1 = new Thread(pro);
Thread t2 = new Thread(cou);
Thread t3 = new Thread(cou);

//啟動線程
t0.start();
t1.start();
t2.start();
t3.start();
}

}

轉載于:https://www.cnblogs.com/olddriver123/p/8250863.html

總結

以上是生活随笔為你收集整理的生产者与消费者的全部內容，希望文章能夠幫你解決所遇到的問題。

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