生產者消費者模型

2021-06-21 14:11:47 字數 1290 閱讀 3483

1.    生產者消費者問題(producer-consumer),有限緩衝,多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。

2.    關鍵是保證生產者不會再緩衝區滿時加入資料,消費者不會在緩衝區空時消耗資料。

3.    解決辦法:讓生產者在緩衝區滿時休眠,等下次消費者消耗緩衝區中的資料的時候,生產者才能被喚醒。同樣,讓消費者在緩衝區空時進入休眠,等到生產者生產資料後再喚醒。

4.    通常採用程序間通訊的方法(訊號燈法)

#include#include//需要用到sleep()

#include//執行緒庫

#include//生成隨機數rand()需要此標頭檔案

#include//需要用到訊號量

#define buffer_size 10 //緩衝區儲存單元設定為10

#define producer_num 6 //設定6個生產者

#define consumer_num 6 //設定6個消費者

using namespace std;

typedef int buffer_item;

buffer_item buffer[buffer_size]=;//定義緩衝區每個儲存單元都為預設值0

int in = 0 , out = 0;

pthread_mutex_t mutex;//互斥鎖

sem_t empty; //訊號量的資料型別為結構sem_t,它本質上是乙個長整型的數

sem_t full;

//填充資料

void insert_item(buffer_item item)

//移除資料

void remove_item(buffer_item* item)

//生產者

void *producer(void* param){

buffer_item item;

pthread_t tid=pthread_self();

while(1){

sleep(2);

item =1+(10.0*rand()/(rand_max+1.0));//產生1-10的隨機數

sem_wait(&empty); //若empty大於0,繼續執行,減1;若empty為0,等待其它執行緒增加了這個值使它不再是0為止

pthread_mutex_lock(&mutex);

insert_item(item);

pthread_mutex_unlock(&mutex);

sem_post(&full);

cout<<"執行緒id為: "<

生產者消費者模型

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

生產者消費者模型

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

生產者 消費者模型

在寫生產者 消費者模型時,先談及乙個概念 訊號量。sem函式 1 sem init函式是posix訊號量操作中的函式。sem init 初始化乙個定位在 sem 的匿名信號量。value 引數指定訊號量的初始值。pshared 引數指明訊號量是由程序內線程共享,還是由程序之間共享。如果 pshare...