c++ - QtConcurrent在reportResultsReady崩溃

背景

在我的Qt5.3应用程序中，我处理了几个耗时的过程(统计计算)。为了能够在运行一个或多个计算的同时对应用程序进行操作，我创建了一个名为ProgressManager的类。该管理器注册从抽象类IRunnable继承并实现纯虚拟方法运行的计算对象。

每次启动新的耗时操作时，都会在连接到其进度栏的ProgressManager中注册该操作，并通过以下功能启动该操作:

void ProgressManager::runProgress(const QVariant &id, const QVariant &param) {

  // If progress is not present, exit
  if (!progs.contains(id)) {
    return;
  }

  // If progress is not runnable, exit
  IRunnable* runnable = dynamic_cast<IRunnable*>(progs.value(id));
  if (!runnable) {
    return;
  }

  // Create future watcher
  QFutureWatcher<QVariant>* watcher = new QFutureWatcher<QVariant>();
  connect(watcher, SIGNAL(finished()), this, SLOT(handleFinished()));

  // Register running progress
  running.insert(watcher, id);

  // Paralelize runnable progress
  QFuture<QVariant> future = QtConcurrent::run(runnable, &IRunnable::run, param);
  watcher->setFuture(future);
}

并行处理完成后，应调用以下函数:

void ProgressManager::handleFinished() {

  // Retrieves sender watcher
  QObject* s = this->sender();
  QFutureWatcher<QVariant>* w = dynamic_cast<QFutureWatcher<QVariant>*>(s);

  // Retrieve ID of running progress and delete watcher
  QVariant id = running.value(w);
  running.remove(w);
  delete w;

  // Emit progress has finished
  emit finished(id);
}

问题

一切运行顺利，直到并行处理结束。然后，在调用完成的信号和handleFinished插槽之前，应用程序每次都会因分段错误而崩溃。

在第211行的函数reportResults中的文件qfutureinterface.h中报告了崩溃，其中函数为reportResultsReady，称为:

194 template <typename T>
195 inline void QFutureInterface<T>::reportResult(const T *result, int index)
196 {
197     QMutexLocker locker(mutex());
198     if (this->queryState(Canceled) || this->queryState(Finished)) {
199         return;
200     }
201
202     QtPrivate::ResultStore<T> &store = resultStore();
203
204
205     if (store.filterMode()) {
206         const int resultCountBefore = store.count();
207         store.addResult(index, result);
208         this->reportResultsReady(resultCountBefore, resultCountBefore + store.count());
209     } else {
210         const int insertIndex = store.addResult(index, result);
211         this->reportResultsReady(insertIndex, insertIndex + 1);
212     }
213 }

最佳答案

我有一个类似的问题。当前，我使用的是QFutureInterface而不使用QtConcurrent，并且我正在手动报告QFuture已准备就绪。由于某些原因，从不同的线程调用QFutureInterface类的函数时，有时会导致崩溃，这意味着QFutureInterface可能不是可重入的，这会自动导致以下事实:尽管其代码中存在互斥体，但它不是线程安全的，等等。没有Qt文档，无论它是导出类。我采取wysota's approach commented here的方式应该查看QtConcurrent的有关QFutureInterface的自定义用法的来源，但如果即使被QtConcurrent使用时崩溃，QFutureInterface的代码也可能存在问题。我正在使用Qt 5.3.2。