導讀:建站知識建站知識本文的代碼都是ChatGPT生成，我只是做了微小的調(diào)整和整合，AI提示詞如下： 設計一個C++類，支持生產(chǎn)者-消費者模型，可以通過size函數(shù)獲取剩余數(shù)量 可能seo網(wǎng)站優(yōu)化個業(yè)網(wǎng)站建設公司。

本文的代碼都是ChatGPT生成，我只是做了微小的調(diào)整和整合，AI提示詞如下： 設計一個C++類，支持生產(chǎn)者-消費者模型，可以通過size函數(shù)獲取剩余數(shù)量 可能第一次生成的不一定合適，多刷新幾次。 生成的 ProducerConsumerQueue.h 代碼如下： #ifndef PRODUCER_CONSUMER_QUEUE_H#define PRODUCER_CONSUMER_QUEUE_H#include queue#include mutex#include condition_variablet […]

本文的代碼都是ChatGPT生成，我只是做了微小的調(diào)整和整合，AI提示詞如下：

設計一個C++類，支持生產(chǎn)者-消費者模型，可以通過size函數(shù)獲取剩余數(shù)量

可能第一次生成的不一定合適，多刷新幾次。 生成的ProducerConsumerQueue.h代碼如下：

#ifndef PRODUCER_CONSUMER_QUEUE_H #define PRODUCER_CONSUMER_QUEUE_H #include <queue> #include <mutex> #include <condition_variable> template<typename T> class ProducerConsumerQueue { public: ProducerConsumerQueue(int size) : m_maxSize(size), m_curSize(0) {} void push(T& val) { std::unique_lock<std::mutex> lock(m_mutex); wh網(wǎng)站seo優(yōu)化診斷工具ile (m_curSize >= m_maxSize) { m_notFull.wait(lock); } m_queue.push(val); ++m_curSize; m_notEmpty.notify_one(); } T pop() { std::unique_lock<std::mutex> lock(m_mutex); while (m_curSize <= 0) { m_notEmpty.wait(lock); } T val = m_queue.front(); m_queue.pop(); --m_curSize; m_notFull.notify_one(); return val; } int size() { std::unique_lock<std::mutex> lock(m_mutex); r公司網(wǎng)站建設eturn m_curSize; } private: std::queue<T> m_queue; int m_maxSize; int m_curSize; std::mutex m_mutex; std::condition_variable m_notEmpty; std::condition_variable m_notFu網(wǎng)站建設制作ll; }; #endif //PRODUCER_CONSUMER_QUEUE_H

在上面的代碼中，我們定義了一個ProducerConsumerQueue類:

• ProducerConsumerQueue類有最大容量和當前容量兩個屬性，使用std::queue<int>存儲數(shù)據(jù)，使用std::mutex保證線程安全，使用std::condition_variable實現(xiàn)線程同步。
• 在push函數(shù)中，如果當前容量已滿，等待消費者消費；否則插入數(shù)據(jù)，當前容量加1，通知消費者。
• 在pop函數(shù)中，如果當前容量為0，等待生產(chǎn)者生產(chǎn)；否則取出數(shù)據(jù)，當前容量減1，通知生產(chǎn)者。
• 在size函數(shù)中，使用std::unique_lockstd::mutex保證線程安全，獲取當前容量并返回。

測試示例代碼如下：

關鍵詞標簽: 生產(chǎn)者 隊列