為應(yīng)對(duì)系統(tǒng)的通信上消息收發(fā)的高耦合度，在接受和發(fā)送消息后設(shè)計(jì)一個(gè)緩存隊(duì)列，并使用多線程生產(chǎn)者-消費(fèi)者來(lái)進(jìn)行收發(fā)解耦。避免通信上的擁堵情況。
利用C++內(nèi)置函數(shù)實(shí)現(xiàn)生產(chǎn)者-消費(fèi)者功能：

private:std::deque<T> queue_; //緩存隊(duì)列size_t size_limit_; //緩存隊(duì)列大小的限制std::mutex lock_; //互斥鎖std::condition_variable empty_, full_; //并發(fā)條件變量類std::atomic<int> producer_num_; //生產(chǎn)者數(shù)量

實(shí)現(xiàn)思路是：當(dāng)緩存隊(duì)列滿的時(shí)候，生產(chǎn)者將被掛起，直到隊(duì)列重新?lián)碛锌臻g。但緩存隊(duì)列為空時(shí)，消費(fèi)者線程將被掛起，直到有“商品”被放入隊(duì)列之中。

void Productor(T& item) {{std::unique_lock<std::mutex> lk(lock_); //加鎖防止沖突while (queue_.size() >= size_limit_) {full_.wait(lk);}queue_.emplace_back(item);}empty_.notify_one();}

full_.wait(lk)在queue隊(duì)列滿時(shí)將會(huì)把Productor掛起，直到queue有空間放入新的item。notify_one方法任意從WAITTING狀態(tài)的線程中挑選一個(gè)進(jìn)行通知，使得調(diào)用wait()方法的線程從等待隊(duì)列移入到同步隊(duì)列中，等待有機(jī)會(huì)再一次獲取到鎖，從而使得調(diào)用wait()方法的線程能夠從wait()方法處退出。

bool Consumer(T& item) {{std::unique_lock<std::mutex> lk(lock_);while (queue_.empty() && (producer_num_ != 0)) {empty_.wait(lk);}if (queue_.empty() && (producer_num_ == 0)) {return false;} else {item = std::move(queue_.front());queue_.pop_front();full_.notify_one();return true;}}}

同理，empty_.wait(lk)會(huì)在生產(chǎn)者數(shù)量為0或者隊(duì)列queue為空的時(shí)候，將Consumer掛起。直到有商品進(jìn)入到隊(duì)列中。這樣就可以實(shí)現(xiàn)一個(gè)簡(jiǎn)單的生產(chǎn)者消費(fèi)者。

總結(jié)

以上是生活随笔為你收集整理的C++实现生产者消费者的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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