qt 信号量实现 一个生产者多个消费者

Qt提供了QSemaphore类来实现信号量功能，可以用于实现一个生产者多个消费者的场景。

首先，我们需要创建一个QSemaphore对象，作为生产者和消费者之间共享的信号量。在这个例子中，我们假设生产者线程负责生产产品，消费者线程负责消费产品。

生产者的逻辑如下：
1. 首先，获取信号量的锁定，如果信号量的计数器为0，则阻塞等待信号量的释放；
2. 当信号量的计数器不为0时，生产者线程开始生产产品，并进行相应的操作；
3. 完成产品的生产后，释放信号量的锁定，并增加信号量的计数器。

消费者的逻辑如下：
1. 首先，获取信号量的锁定，如果信号量的计数器为0，则阻塞等待信号量的释放；
2. 当信号量的计数器不为0时，消费者线程开始消费产品，并进行相应的操作；
3. 完成产品的消费后，释放信号量的锁定，并增加信号量的计数器。

下面是一个简化的示例代码：

QSemaphore semaphore; // 创建信号量对象
QVector<QString> products; // 存放产品的容器

// 生产者线程函数
void producer()
{
    while (true) {
        semaphore.acquire(); // 获取信号量的锁定
        // 生产产品的操作
        QString product = generateProduct();
        products.append(product);
        semaphore.release(); // 释放信号量的锁定
        QThread::sleep(1); // 等待一段时间
    }
}

// 消费者线程函数
void consumer()
{
    while (true) {
        semaphore.acquire(); // 获取信号量的锁定
        // 消费产品的操作
        if (!products.isEmpty()) {
            QString product = products.takeFirst();
            consumeProduct(product);
        }
        semaphore.release(); // 释放信号量的锁定
        QThread::sleep(1); // 等待一段时间
    }
}

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    
    // 创建生产者和消费者线程
    QThread producerThread;
    QThread consumerThread1;
    QThread consumerThread2;
    QThread consumerThread3;
    
    // 信号量关联线程
    semaphore.setInitialValue(1);
    semaphore.moveToThread(&producerThread);
    semaphore.moveToThread(&consumerThread1);
    semaphore.moveToThread(&consumerThread2);
    semaphore.moveToThread(&consumerThread3);
    
    // 启动线程
    producerThread.start();
    consumerThread1.start();
    consumerThread2.start();
    consumerThread3.start();
    
    return a.exec();
}

在上面的示例代码中，我们创建了一个QSemaphore对象作为信号量，并使用`acquire()`和`release()`函数来获取和释放信号量的锁定。生产者线程通过`acquire()`函数获取信号量的锁定，如果信号量的计数器为0，则线程会阻塞等待信号量的释放。消费者线程也使用相同的方法来获取和释放信号量的锁定。

这种方式实现了一个生产者多个消费者的场景，多个消费者线程可以在信号量的控制下轮流进行产品的消费。