生产者消费者qt 实现

在Qt中，生产者消费者模型（Producer-Consumer Problem）是一个经典的并发处理示例，通过信号槽机制实现了线程之间的通信。下面是一个简单的例子，展示了如何使用`QQueue`作为缓冲区，以及`QThread`创建生产者和消费者线程：

1. 创建生产者线程（Producer Thread）：
- 在这个线程里，生产者不断生成数据并放入队列中。

   void producer(Queue *queue) {
       for (; ; ) {
           QString data = generateData(); // 模拟数据生成
           QApplication::postEvent(queue, new QueueItem(data)); // 发送数据到队列
           QThread::sleep(100); // 控制生产频率
       }
   }

2. 创建消费者线程（Consumer Thread）：
- 消费者从队列中取出数据并处理。

   void consumer(Queue *queue) {
       while (true) {
           QueueItem item;
           if (queue->isEmpty()) {
               QApplication::processEvents(); // 检查队列是否为空，如果没有，阻塞等待
           } else {
               item = queue->take(); // 取出队首元素
               processData(item.data()); // 处理数据
           }
       }
   }

3. 使用`QQueue`作为共享数据结构：

   class QueueItem : public QObject {
       Q_OBJECT
       QString data;
   public:
       QueueItem(const QString &data): data(data) {}
       QString getData() const { return data; }
   };

   class Queue {
       QQueue<QueueItem*> items;
       QMutex mutex;
   };

4. 初始化和启动线程：

   Queue queue;
   QThread producerThread;
   Producer producerThreadObject(&queue);
   connect(&producerThreadObject, &Producer::producedData, &queue, &Queue::enqueue);

   producerThread.start(&producerThreadObject);
   QThread consumerThread;
   Consumer consumerThreadObject(&queue);
   connect(&queue, &Queue::dequeue, &consumerThreadObject, &Consumer::receivedData);

   consumerThread.start(&consumerThreadObject);