生產(chǎn)者-消費者（producer-consumer）問題，兩個進(jìn)程共享一個公共的固定大小的緩沖區(qū)。其中一個是生產(chǎn)者，用于將消息放入緩沖區(qū)；另外一個是消費者，用于從緩沖區(qū)中取出消息。
這樣應(yīng)該是生產(chǎn)者生產(chǎn)一個產(chǎn)品，然后消費者取走一個產(chǎn)品，然后再生產(chǎn)、再消費，這個看似很理所當(dāng)然的邏輯在現(xiàn)實中是必然的，但是在程序里卻出現(xiàn)了問題。a：生產(chǎn)者生產(chǎn)了很多消費者卻沒有取，b：生產(chǎn)這還沒有生產(chǎn)完一個完整的產(chǎn)品消費者卻已經(jīng)取走了好幾次了，這樣取走的產(chǎn)品當(dāng)然是不合格的。
下面就用生產(chǎn)和消費鞋子為例，看看程序是怎么運(yùn)行的吧.. .. ..
Demo01
package demo;
class Shoes{
// 鞋子類，兩個屬性：使用者（男/女），大小（大/小）
String user=null;
String size=null;
}
class Pro implements Runnable{
// 生產(chǎn)者，生產(chǎn)
Shoes shoe = null;
public Pro(Shoes s){
this.shoe=s;
}
public void run(){
int i=0;
while(true){
if(i==0){
// 男人穿的鞋子是大號的
shoe.user="男式";
shoe.size="大號";
i=1;
}else{
// 女人穿的鞋子是小號的
shoe.user="女式";
shoe.size="小號";
i=0;
}
}
}
}
class Cus implements Runnable{
Shoes shoe=null;
public Cus(Shoes s){
this.shoe=s;
}
public void run(){
while(true){
System.out.println(shoe.user+"-->"+shoe.size);
}
}
}
public class Demo01 {
/**生產(chǎn)者-消費者問題 producer-consumer
* @param args
*/
public static void main(String[] args) {
// 設(shè)置鞋子的一個生產(chǎn)者和一個消費者，并啟動兩個線程，分別進(jìn)行生產(chǎn)和消費
Shoes shoe = new Shoes();
Pro p = new Pro(shoe);
Cus c = new Cus(shoe);
new Thread(p).start();
new Thread(c).start();
}
}
結(jié)果：
從結(jié)果中可以看到，第一次取時已經(jīng)生產(chǎn)完一雙男鞋，女鞋還沒有生產(chǎn)完就取走了女鞋，第二次到第四次消費都是男鞋，看來是要么生產(chǎn)的太多了，沒有取走，要么就是取的太快，只生產(chǎn)了一雙男鞋卻取了四次。
這樣的程序顯然是不符合實際的，所以就要加以改進(jìn)。
應(yīng)該是生產(chǎn)時，生產(chǎn)者進(jìn)入車間并把車間的門上鎖，生產(chǎn)一雙后生產(chǎn)者出來，消費者進(jìn)入到車間并把車間門上鎖，取到鞋子后出來，這樣車間里只有一個人，要么生產(chǎn)者要么消費者，這樣就可以保證生產(chǎn)合格的產(chǎn)品。
改進(jìn)的程序：
Demo02
package demo2;
class Shoes{
// 鞋子類，兩個屬性：使用者（男/女），大小（大/小）
String user=null;
String size=null;
private boolean flag = true;
public synchronized void set(String user,String size){
//如果flag的值不是true則要等待
if (!flag){
//等待
try{
wait();
}catch(Exception e){}
}
try{
Thread.sleep(100);
}catch (Exception e){}
// 如果向下繼續(xù)執(zhí)行了，則表示可以設(shè)置,flag = true
this.user = user;
this.size = size;
// 修改設(shè)置的標(biāo)志
flag = false;
//喚醒其他線程
notify();
}
//設(shè)置一個輸出方法
public synchronized void get(){
// 如果flag的值為true的時候，表示要等待
if(flag){
try{
wait();
}catch(Exception e){}
}
try{
Thread.sleep(100);
}catch (Exception e){}
//如果向下執(zhí)行了，則表示允許取出
System.out.println(this.user+" --> "+this.size);
//改變標(biāo)志，表示可以生產(chǎn)了
flag = true;
notify();
}
}
class Pro implements Runnable{
// 生產(chǎn)者，生產(chǎn)
Shoes shoe = null;
public Pro(Shoes s){
this.shoe=s;
}
public void run(){
int i=0;
while(true){
if(i==0){
// 男人穿的鞋子是大號的
shoe.set("男式", "大號");
i=1;
}else{
// 女人穿的鞋子是小號的
shoe.set("女式", "小號");
i=0;
}
}
}
}
class Cus implements Runnable{
Shoes shoe=null;
public Cus(Shoes s){
this.shoe = s;
}
public void run(){
while(true){
shoe.get();
}
}
}
public class Demo02 {
/**生產(chǎn)者-消費者問題 producer-consumer
* @param args
*/
public static void main(String[] args) {
// 設(shè)置鞋子的一個生產(chǎn)者和一個消費者，并啟動兩個線程，分別進(jìn)行生產(chǎn)和消費
Shoes shoe = new Shoes();
Pro p = new Pro(shoe);
Cus c = new Cus(shoe);
new Thread(p).start();
new Thread(c).start();
}
}
運(yùn)行結(jié)果：
posted on 2010-11-12 23:30
Mineralwasser 閱讀(261)
評論(0) 編輯 收藏