Qt - 如何将 QtConcurrent 和 QThreadPool 组合成 QProgressBar?

Question

在mainwindow.ui中，我创建了一个名为progressBar的QProgressBar和一个名为speckle的QPushButton，用于启动繁重的计算。

在mainwindow.h里面，我有一个合适的按钮private slot和一个代表繁重计算的私有函数。mainwindow.h：

class MainWindow : public QMainWindow
{
Q_OBJECT
public:
explicit MainWindow(QWidget *parent = 0);
~MainWindow();
private slots:
void on_speckle_clicked();
...
private:
Ui::MainWindow *ui;
QFutureWatcher<std::vector<cv::Mat>> futureWatcher;
std::vector<cv::Mat> progressSpecle();//heavy computation
};

futureWatcher应该监视从QtConcurrent返回的QFuture对象：

MainWindow::MainWindow(QWidget *parent) :
QMainWindow(parent),
ui(new Ui::MainWindow)
{
ui->setupUi(this);
...
connect(&this->futureWatcher, SIGNAL(progressValueChanged(int)), ui->progressBar, SLOT(setValue(int)));
...
}
...
void MainWindow::on_speckle_clicked()
{    
//Start the computation.
QFuture<std::vector<cv::Mat>> future;
future = QtConcurrent::run(this, &MainWindow::progressSpecle);
this->futureWatcher.setFuture(future);
QThreadPool::globalInstance()->waitForDone();
vector<cv::Mat> result = future.result();
specklevisualization *s = new specklevisualization;
s-> setAttribute(Qt::WA_DeleteOnClose);
s-> start(result);
s-> show();
}

但是该应用程序不是那样工作的。编译并单击斑点后，mainwindow没有响应。下面是创建 x 线程的progressSpecle成员函数：

void MainWindow::progressSpecle(){
vector<cv::Mat> input;
...//do something with input
vector<cv::Mat> result;
vector<cv::Mat> *all;
all = &result;
QThreadPool *threadPool = QThreadPool::globalInstance();
for(unsigned int i = 1; i<input.size(); i++) {
cv_speckle_algorithm *work = new cv_speckle_algorithm(input.at(i-1), input.at(i), all, i-1);
work->setAutoDelete(false);
threadPool->start(work);
}
while(true){
if(threadPool->activeThreadCount() == 1) return result;
}
}

该应用程序工作没有错误，但主窗口不负责任，因为(我认为)while(true).但是我不明白为什么这应该阻止mainWindow，因为整个progressSpecle函数在以QtConcurrent创建并启动的单独线程中工作。

为什么progressSpecle函数会阻止主窗口？ 那么我怎样才能让progressBar工作呢？

Answer 1

QFutureWatcher信号从池线程内发出。这意味着QProgressBar槽将通过"排队连接"调用：一个事件将排队到主线程的事件循环，并且在处理此事件时将调用该槽。

对QThreadPool::waitForDone的调用会阻塞主线程，因此事件循环未运行，并且不会调用排队的槽。您需要在主线程等待并发任务完成时保持主线程的事件循环运行。

我能想到两种方法来实现这一点。第一种是将回调连接到QFutureWatcher::finished信号，并将控制权返回到主事件循环：

void MainWindow::on_speckle_clicked()
{
//Start the computation.
QFuture<std::vector<cv::Mat>> future;
future = QtConcurrent::run(this, &MainWindow::progressSpecle);
connect(&futureWatcher, &QFutureWatcherBase::finished, this, [result] {
vector<cv::Mat> result = future.result();
specklevisualization *s = new specklevisualization;
s->setAttribute(Qt::WA_DeleteOnClose);
s->start(result);
s->show();
});
this->futureWatcher.setFuture(future);
// return control to event loop
}

如果您愿意，可以使用命名方法代替 lambda。

第二种方法是在函数内运行嵌套事件循环，并将其quit槽连接到QFutureWatcher::finished信号：

void MainWindow::on_speckle_clicked()
{
QEventLoop localLoop;
//Start the computation.
QFuture<std::vector<cv::Mat>> future;
future = QtConcurrent::run(this, &MainWindow::progressSpecle);
connect(futureWatcher, &QFutureWatcherBase::finished, &localLoop, &QEventLoop::quit);
this->futureWatcher.setFuture(future);
localLoop.exec(); // wait for done
vector<cv::Mat> result = future.result();
specklevisualization *s = new specklevisualization;
s->setAttribute(Qt::WA_DeleteOnClose);
s->start(result);
s->show();
}