Linux 生產者消費者模型 C

面試手撕生產者-消費者模型！！！

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

基於blockingqueue的生產者消費者模型，blockingqueue 在多執行緒程式設計中阻塞佇列(blocking queue)是一種常用於實現生產者和消費者模型的資料結構。其與普通的佇列區別在於，當隊列為空時，從佇列獲取元素的操作將會被阻塞，直到佇列中被放入了元素；當佇列滿時，往佇列裡存放元素的操作也會被阻塞，直到有元素被從佇列中取出(以上的操作都是基於不同的執行緒來說的，執行緒在對阻塞佇列程序操作時會被阻塞)

c++ queue模擬阻塞佇列的生產消費模型(單生產者，單消費者) **：

#include
#include
#include
#include
#define mum 8
class
blockqueue
void
unlockqueue()
void
productwait()
void
consumewait()
void
notifyproduct()
void
notifconsume()
bool
isempty()
bool
isfull()
public
:blockqueue
(int _cap = mum)
:cap
(_cap)
void
pushdata
(const
int&data)
q.push
(data)
;notifconsume()
;unlockqueue()
;}void
popdata
(int
&data)
data = q.
front()
; q.
pop();
notifconsume()
;unlockqueue()
;}~blockqueue()
};void
*consumer
(void
*arg)
}void
*producter
(void
*arg)
}int
main()

前邊講到的生產者 - 消費者的例子是基於queue的, 其空間可以動態分配, 現在基於固定大小的環形佇列重寫這個程式（posix訊號量） :基於環形佇列的生產消費模型環形佇列採用陣列模擬，用模運算來模擬環狀特性環形結構起始狀態和結束狀態都是一樣的，不好判斷為空或者為滿，所以可以通過加計數器或者標記位來判斷滿或者空。另外也可以預留乙個空的位置，作為滿的狀態但是我們現在有訊號量這個計數器，就很簡單的進行多執行緒間的同步過程；

#include
#include
#include
#include
#include
#define mum 16
class
ringqueue
void
putdata
(const
int&data)
void
getdata
(int
&data)
~ringqueue()
};void
*consumer
(void
*arg)
}void
*productor
(void
*arg)
}int
main()

Linux 生產者 消費者模型 C

Linux 生產者消費者模型

生產者消費者模型

生產者消費者模型

相關推薦

Linux 生產者消費者模型 C