QtConcurrent--在数以千计的结果发布到UI线程中保持GUI的响应。

Question

我有一个应用程序，它可能有长期运行的任务，也可能有数千或数百万或结果。

这个特定的应用程序（代码如下）没有任何价值，但它的目的是提供一个一般的使用案例，说明需要在 "成千上万 "的结果中保持一个响应的UI。

要说明的是，我知道应该减少UI的投票次数。我的问题是，在保持响应式UI的过程中，有哪些设计原则可以适用于这种（和其他类似的）情况。

我首先想到的是使用 QTimer 并每隔200毫秒处理一次所有的 "结果"，这个例子可以找到此处但需要进行美化。

有哪些方法可以使用，哪些是保持响应式UI的首选？

我想解释的一个简单例子如下。我有一个UI。

生成一个整数列表
将其传递到一个映射函数中，以pow(x,2)为值，并且
进展

当运行此应用时，点击 "开始 "按钮就会运行该应用，但由于处理结果的频率由排队的连接: QFutureWatcher::resultReadyAt因此，UI无法对任何用户的点击做出反应，因此试图 "暂停 "或 "停止"（取消）是徒劳的。

封装器 对于 QtConcurrent::mapped() 传入函数

#include <functional>

template <typename ResultType>
class MappedFutureWrapper
{
public:
    using result_type = ResultType;

    MappedFutureWrapper<ResultType>(){}
    MappedFutureWrapper<ResultType>(std::function<ResultType (ResultType)> function): function(function){ }
    MappedFutureWrapper& operator =(const MappedFutureWrapper &wrapper) {
        function = wrapper.function;
        return *this;
    }
    ResultType operator()(ResultType i) {
        return function(i);
    }

private:
    std::function<ResultType(ResultType)> function;
};

MainWindow.h UI

class MainWindow : public QMainWindow {
     Q_OBJECT

  public:
     struct IntStream {
         int value;
     };

     MappedFutureWrapper<IntStream> wrapper;
     QVector<IntStream> intList;

     int count = 0;
     int entries = 50000000;

     MainWindow(QWidget* parent = nullptr);
     static IntStream doubleValue(IntStream &i);
     ~MainWindow();

    private:
       Ui::MainWindow* ui;
       QFutureWatcher<IntStream> futureWatcher;
       QFuture<IntStream> future;

       //...
}

MainWindow的实施

MainWindow::MainWindow(QWidget* parent)
     : QMainWindow(parent)
     , ui(new Ui::MainWindow)
{
     ui->setupUi(this);
    qDebug() << "Launching";

     intList = QVector<IntStream>();
     for (int i = 0; i < entries; i++) {
         int localQrand = qrand();
         IntStream s;
         s.value = localQrand;
         intList.append(s);
     }

     ui->progressBar->setValue(0);

}

MainWindow::IntStream MainWindow::doubleValue(MainWindow::IntStream &i)
{
    i.value *= i.value;
    return i;
}

void MainWindow::on_thread1Start_clicked()
{
    qDebug() << "Starting";

    // Create wrapper with member function
    wrapper = MappedFutureWrapper<IntStream>([this](IntStream i){
        return this->doubleValue(i);
    });

    // Process 'result', need to acquire manually
    connect(&futureWatcher, &QFutureWatcher<IntStream>::resultReadyAt, [this](int index){
        auto p = ((++count * 1.0) / entries * 1.0) * 100;
        int progress = static_cast<int>(p);
        if(this->ui->progressBar->value() != progress) {
            qDebug() << "Progress = " << progress;
            this->ui->progressBar->setValue(progress);
        }
    });

    // On future finished
    connect(&futureWatcher, &QFutureWatcher<IntStream>::finished, this, [](){
        qDebug() << "done";
    });

    // Start mapped function
    future = QtConcurrent::mapped(intList, wrapper);
    futureWatcher.setFuture(future);
}

void MainWindow::on_thread1PauseResume_clicked()
{
    future.togglePaused();
    if(future.isPaused()) {
        qDebug() << "Paused";
    } else  {
        qDebug() << "Running";
    }
}

void MainWindow::on_thread1Stop_clicked()
{
    future.cancel();
    qDebug() << "Canceled";

    if(future.isFinished()){
        qDebug() << "Finished";
    } else {
        qDebug() << "Not finished";
    }

}

MainWindow::~MainWindow()
{
     delete ui;
}

解释为什么UI "没有响应"。

除了打印 "Launching "以外，UI加载wo执行任何操作。当方法 on_thread1Start_clicked() 被调用时，它除了添加下面的连接外，还启动了未来。

connect(&futureWatcher, &QFutureWatcher<IntStream>::resultReadyAt, [this](int index){
    auto p = ((++count * 1.0) / entries * 1.0) * 100;
    int progress = static_cast<int>(p);
    if(this->ui->progressBar->value() != progress) {
        qDebug() << "Progress = " << progress;
        this->ui->progressBar->setValue(progress);
    }
});

这个连接监听来自未来的结果，并对其进行操作(这个连接函数运行在... UI线). 由于我正在模拟大量的 "ui更新"，通过以下方式显示出来 int entries = 50000000;每次处理一个结果时，都会在 QFutureWatcher<IntStream>::resultReadyAt 被调用。

当它运行+- 2s时，UI不会对链接到的 "暂停 "或 "停止 "点击作出响应。on_thread1PauseResume_clicked() 和 on_thread1Stop_clicked 分别。