綜合實戰 「生產者 消費者」模型

2021-08-27 20:47:59 字數 2103 閱讀 5917

本程式的核心結構如下:首先定義兩個類,乙個是生產者執行緒,另外乙個消費者執行緒類,生產者每生產完乙個資料之後,消費者要取走這些資料,那麼假設現在的資料有兩種:

範例:**基本模型

class message 

public void setcontent(string content)

public string getcontent()

public string gettitle()

}class productor implements runnable

@override

public void run() catch (interruptedexception e)

this.msg.setcontent("草泥馬");

} else catch (interruptedexception e)

this.msg.setcontent("不是好孩子");

}} }

}class customer implements runnable

@override

public void run() catch (interruptedexception e)

system.out.println(this.msg.gettitle() + "," + this.msg.getcontent());

} }}public class testdemo

}

遺憾的是,這個時候出現了兩個問題:

要想解決資料的錯位,使用同步處理即可,所以**修改如下。

class message  catch (interruptedexception e) 

this.content = content;

} public synchronized void get() catch (interruptedexception e)

system.out.println(this.title + "," + this.content); }}

class productor implements runnable

@override

public void run() else

} }}class customer implements runnable

@override

public void run() }}

public class testdemo

}

現在的資料沒有任何錯亂,但是重複的操作更嚴重了。

如果要想解決重複的操作必須加入等待與喚醒機制。而這樣的處理機制是由object類提供的方法支援,在object類之中有如下的方法可以使用:

範例:解決問題

class message  catch (interruptedexception e) 

} this.title = title;

try catch (interruptedexception e)

this.content = content;

this.flag = false;

super.notify();

} public synchronized void get() catch (interruptedexception e)

} try catch (interruptedexception e)

system.out.println(this.title + "," + this.content);

this.flag = true;

super.notify();

}}

此部分的**沒有乙個絕對的掌握標準,會了總是好的,如果覺得之前的概念已經沒問題了,可以好好看看。

擴充套件題目:請解釋sleep()和wait()的區別?

生產者消費者模型

1.生產者消費者問題 producer consumer 有限緩衝,多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料,消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠,等下次消費者消耗緩衝區中的資料的時候,生產者才能被喚醒...

生產者消費者模型

生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥,同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...

生產者消費者模型

當佇列滿時,生產者需要等待佇列有空間才能繼續往裡面放入商品,而在等待的期間內,生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權,那麼消費者就無法消費佇列中的商品,就不會讓佇列有空間,那麼生產者就會一直無限等待下去。因此,一般情況下,當佇列滿時,會讓生產者交出對臨界資...