生产者/消费者设计 - 在 Qt 中跨线程共享队列变量

Question

我尝试以生产者-消费者模式创建一个并发队列类。

我基于 http: //www.justsoftwaresolutions.co.uk/threading/implementing-a-thread-safe-queue-using-condition-variables.html

在我的主线程中，我使用 Qt::Concurrent 调用了以下两个方法

QFutureWatcher<void> *loadwatcher;
loadwatcher = new QFutureWatcher<void>();
QString filename("myfile");
QFuture<void> future = QtConcurrent::run(this, &EraserBatch::loadTiles,filename);
loadwatcher->setFuture(future);


QFutureWatcher<bool> *procwatcher;
procwatcher = new QFutureWatcher<bool>();
QFuture<bool> procfuture = QtConcurrent::run(this, &EraserBatch::processTile);
procwatcher->setFuture(procfuture);

所以 loadTiles 是我的生产者，processTile 是我的消费者。

在 loadtiles 中，我有一个循环加载图块，如下所示：

for(int i =0; i < nXBlocks; i++)
{
    for(int j = 0; j < nYBlocks; j++)
    {
        Tile *ipi = new Tile(filename);
        sleep(1);
        qDebug()<<"Tile pushed to queue:"<<i<<" "<<j << " Thread id:"<<this->thread();
        this->tiles->push(ipi);
    }
}

在消费者方法中，我有以下内容：

Tile *tile;
this->tiles->wait_and_pop(tile);

while(!tiles->empty())
{
            qDebug()<<"Tile popped from queue:"<<tile->tilePosX<<" "<<tile->tilePosY<< " Thread id: " << this->thread();
            sleep(5);
             tiles->wait_and_pop(tile);
   }

这似乎将所有图块推送到队列中，但是似乎我的消费者从未将其放入 while循环，因为我弹出第一个图块，然后队列为空。

所以这是一个设计缺陷 - 但我想我需要知道如何告诉生产者等待所有图块添加到队列中，并继续等待直到所有图块都完成。我需要在 while 循环之外弹出第一个图块，以获取将在循环中使用的变量的一些设置信息，并分配一些内存和 suhc，我不想一遍又一遍地这样做。设置此功能的最佳方法是什么？

Answer 1

在这种情况下，生产者需要告诉消费者不会再有数据了。通常，这是通过在队列上使用类似 Close() 方法来实现的。您的消费者测试将变成：

while (!tiles->empty() || !tiles->closed())
{
   ... blocking consume
}