多執行緒生產者消費者模型

1.簡介：

生產者消費者模式是通過乙個容器來解決生產者和消費者的強耦合問題。生產者和消費者彼此之間不直接通訊，而通過阻塞佇列來進行通訊，所以生產者生產完資料之後不用等待消費者處理，直接扔給阻塞佇列，消費者不找生產者要資料，而是直接從阻塞佇列裡取，阻塞佇列就相當於乙個緩衝區，平衡了生產者和消費者的處理能力。這個阻塞佇列就是用來給生產者和消費者解耦的

/**
* @author yan
* @create 2019/9/20 17:26 by intellij idea
* @description
*/class goods';
}//生產方法
public synchronized void set(string goodsname)
//消費方法
public synchronized void get()}/*
* 生產者
* */
class producer implements runnable
@override
public void run() }/*
* 消費者
* */
class consumer implements runnable
@override
public void run() 
}//測試類
public class factorydesignmodel 
}

執行結果：

goods

goods

但是將生產者執行緒開啟和消費者執行緒開啟的**換個位置在再測試下。此時問題產生了，生

產者還沒生產商品消費者就消費了導致數量不正確。此時就需要我們的wait()和notify()方法幫忙。

class goods
this.goodsname = goodsname;
this.count = count+1;
thread.sleep(1000);
system.out.println("生產："+tostring());
//生產完商品通知消費者可一消費了
notify();
}//商品消費
public synchronized void get() throws interruptedexception 
//每次消費乙個商品
this.count = this.count -1;
thread.sleep(1000);
system.out.println("消費"+tostring());
//消費完告訴生產者繼續生產
notify();
}@override
public string tostring() ';
}}/*
* 生產者
* */
class produser implements runnable
@override
public void run()  catch (interruptedexception e) 
}}/*
* 消費者
* */
class consumer implements runnable
@override
public void run()  catch (interruptedexception e) 
}}//測試類
public class factorydesignmodel 
}

執行結果：

此時沒有商品，等待生產者生產

生產：goods

消費goods

多生產以及多消費

以上只有乙個生產者生產一次商品和乙個消費者只消費一次就結束了，現在能否改變一下，多個生產者和多個消費者呢？

分析一下，首先notify方法目前是只能喚醒乙個執行緒，如果有多個生產者執行緒和多個消費者執行緒的話，這個notify方法喚醒的執行緒如果是消費者的話應該沒有問題，但是如果是喚醒的也是生產者的執行緒那麼程式就會變成假死狀態了，這個時候顯然這個notify方法不行，我們上一節講過了有乙個notifyall()喚醒當前物件的所有執行緒。這個時候就可以使用該方法了，好了我們開始改造。

class goods
this.goodsname = goodsname;
this.count = count+1;
thread.sleep(1000);
system.out.println(thread.currentthread().getname());
system.out.println("生產"+tostring());
system.out.println("***********************************=");
//生產完商品通知消費者消費
notifyall();
}//商品消費
public synchronized void get() throws interruptedexception 
//每次消費乙個商品
this.count = this.count -1;
thread.sleep(1000);
system.out.println(thread.currentthread().getname());
system.out.println("消費"+tostring());
system.out.println("****************************************");
//消費完告訴生產者繼續生產
notifyall();
}@override
public string tostring() ';
}}/*
* 生產者
* */
class produser implements runnable
@override
public void run()  catch (interruptedexception e) 
}}}/*
* 消費者
* */
class consumer implements runnable
@override
public void run()  catch (interruptedexception e) }}
}//測試類
public class factorydesignmodel 
//6個消費者執行緒
for (int i = 0; i < 6; i++) 
for (thread thread:threadlist) 
}}

多執行緒生產者消費者模型

多執行緒生產者消費者

多執行緒之生產者消費者模型

執行緒，生產者消費者模型

多執行緒 生產者消費者模型

多執行緒 生產者消費者

多執行緒之生產者消費者模型

執行緒，生產者消費者模型

相關推薦

多執行緒生產者消費者模型

多執行緒生產者消費者