生產者消費者模型

生產者—消費者問題：多執行緒訪問的乙個經典案例，即按物件導向的思想來分析問題的話，這個問題涉及四個物件，生產者procedure、消費者consumer、產品product、倉庫warehouse。下面以乙個簡單的例子來進行實現。

一、產品product

每個產品有乙個屬性id，這個id值由生產者賦予。即生產者呼叫產品的構造方法來設定該屬性id。

class product
public string tostring()
}

二、倉庫warehouse

1、倉庫有兩個屬性：庫存num、容量，庫存用int表示，初始化為0；容量用陣列的長度表示。庫存即該產品陣列中的前num個產品。

2、兩個方法：增加庫存add和減少庫存del。在add中將傳入的產品引數放入庫存陣列，將庫存量加一。減少庫存del中將庫存量num減

一、並返回消費產品。

3、在add和del方法中，執行前後應該檢查庫存，若執行add方法，當庫存為庫存的容量時，使得當前執行緒wait，該執行緒(為生產者物件)放棄鎖。直到當消費者執行緒執行del使得庫存量小於倉庫容量時，喚醒當前程序，重新獲得鎖，繼續執行生產add。若執行del，當庫存為0時，使得當前程序wait，釋放鎖，直到生產者程序獲取鎖之後執行add後庫存大於0，此時喚醒程序重新獲得鎖，執行消費del。

4、在add和del方法中，可能出現多個生產者和多個消費者同時訪問庫存並執行add和del，所以這兩個方法都應設定為同步方法。

class warehouse
catch(exception e)
} this.notifyall();
list[num]=p;
num++;
} public synchronized product del()catch(exception e)
} this.notifyall();
num--;
return list[num];
}}

三、生產者procedure

生產者構造方法傳入乙個warehouse引數生成生產者。每個produre都是乙個程序，所以實現runnable介面和相應的run方法，在run方法中，每個procedure可以生產10件產品。

class procedure implements runnable
public void run()
}}

四、消費者consumer

消費者由傳入乙個warehouse引數構造。同理，每個consumer也實現了runnable介面和run方法，在run方法中，設定每個消費者可以消費5件產品。

class consumer implements runnable
public void run()
}}

五、測試類：在main方法中首先建立乙個warehouse物件，然後利用warehouse物件新建procedure物件和consumer物件各倆，最後利用procedure和consumer物件新建四個程序，然後start這四個程序。

public class p_c
}

生產者消費者模型

生產者消費者模型

生產者消費者模型

生產者消費者模型

相關推薦