Qt - 如何为QProgressBar结合使用QtConcurrent和QThreadPool？

Question

在mainwindow.ui中，我创建了一个名为的名称为progressBar的名为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不响应。这里是progressSpecle成员函数，其中x线程被创建：在while(true)的

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; 
    } 

} 

应用工作没有错误，但因为（我认为）的主窗口概不负责。但我不明白为什么这应该阻止mainWindow，因为整个progressSpecle函数在创建的单独线程中工作，并以QtConcurrent开始。

为什么progressSpecle函数阻塞mainWindow？ 那么我怎样才能让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 
} 

您可以使用，而不是一个拉姆达命名方法，如果你喜欢。

第二种方法是运行一个嵌套的事件循环函数中，其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(); 
}