引言

生產(chǎn)者消費(fèi)者是一個(gè)經(jīng)典的模式

利用生產(chǎn)者，消費(fèi)者和緩衝區(qū)降低了生產(chǎn)者和消費(fèi)者之間的的耦合度

便於對(duì)生產(chǎn)者和消費(fèi)者的修改

下面記錄的是一個(gè)經(jīng)典的單一生產(chǎn)者多消費(fèi)者的模式

設(shè)計(jì)思路

以隊(duì)列做為緩衝區(qū)，實(shí)現(xiàn)產(chǎn)品的FIFO

生產(chǎn)者調(diào)用緩衝區(qū)的push函數(shù)，將產(chǎn)品加入緩衝區(qū)

消費(fèi)者調(diào)用緩衝區(qū)的pop函數(shù)，將產(chǎn)品從緩衝區(qū)取出

因?yàn)樯a(chǎn)者與消費(fèi)者分屬於不同的線程，所以要設(shè)置鎖

類的聲明

?

class CacheQueue {private:/*** @brief 緩衝隊(duì)列*/queue<int>* _requests;/*** @brief 互斥鎖**/pthread_mutex_t _mutex;/*** @brief Queue not full conditional object**/pthread_cond_t _not_full_cond;/*** @brief Queue not empty conditional object**/pthread_cond_t _not_empty_cond;uint32_t _bufSize;public:ChacheQueue();void SetMaxLength(uint32_t bufSize);/*** @brief 向隊(duì)列添加產(chǎn)品* @param [in] req: 待添加的產(chǎn)品**/void Push(int req);/*** @brief 從隊(duì)列中取出一個(gè)產(chǎn)品* @param [return] : 從隊(duì)列中取出的產(chǎn)品**/int Pop(uint32_t timeout);/*** @brief 析構(gòu)函數(shù)**/~CacheQueue(); };

重要的函數(shù)是Push和Pop，生產(chǎn)者調(diào)用Push向緩衝區(qū)添加產(chǎn)品，消費(fèi)者則調(diào)用Pop函數(shù)獲取產(chǎn)品

線程條件_not_full_cond表示隊(duì)列不滿，可以添加產(chǎn)品

線程條件_not_empty_cond表示隊(duì)列不空，可以獲取產(chǎn)品

Push函數(shù)

?

void CacheQueue::Push(int req) {/*** 上鎖*/pthread_mutex_lock(&_mutex);/*** 如果隊(duì)列滿，等待信號(hào)*/while (_requests->size() == _bufSize){pthread_cond_wait(&_not_full_cond, &_mutex);}_requests->push(req);/*** 發(fā)送非空信號(hào)*/pthread_cond_signal(&_not_empty_cond);/*** 解鎖*/pthread_mutex_unlock(&_mutex); }

?

Pop函數(shù)

?

int CacheQueue::Pop(uint32_t timeout) {int ret = 0;int req = NO_DATA;/*** 上鎖*/pthread_mutex_lock(&_mutex);/*** 若隊(duì)列空等待指定時(shí)間*/struct timeval now;struct timespec timepass;gettimeofday(&now, NULL);timepass.tv_sec = now.tv_sec + timeout;timepass.tv_nsec = 0;while (ret == 0 && _requests->empty()){ret = pthread_cond_timedwait(&_not_empty_cond, &_mutex, &timepass);}/*** 沒有數(shù)據(jù)，返回沒有數(shù)據(jù)標(biāo)識(shí)*/if(ret!=0){pthread_mutex_unlock(&_mutex);return req;}/*** 返回?cái)?shù)據(jù)，發(fā)送隊(duì)列非滿信號(hào)*/req = _requests->front();_requests->pop();pthread_cond_signal(&_not_full_cond);/*** 解鎖*/pthread_mutex_unlock(&_mutex);return req; }

總結(jié)

以上是生活随笔為你收集整理的linux下c++實現簡單的生產者消費者隊列模式的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。