reportResultsReady上的QtConcurrent崩溃

Question

背景

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

每次启动新的耗时操作时，它都会在连接到其进度条的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);
}

问题

在并行化过程结束之前，一切都在顺利运行。然后，在调用finished信号和handleFinished插槽之前，应用程序每次都会因分段故障而崩溃。

崩溃报告在函数reportResults的文件qfuturenterface.h的第211行，其中函数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 }

Answer 1

我也有类似的问题。目前，我正在使用QFutureInterface而不使用QtConcurrent，并且我正在手动报告QFuture已准备就绪。由于某种原因，当从不同的线程调用QFutureInterface类的函数时，我不时会发生崩溃，这意味着QFutureInterface可能是不可重入的，这会自动导致它不是线程安全的，尽管它的代码中有互斥体等。无论它是导出的类，都没有关于它的Qt文档。我采用了wysota在这里评论的方法，即应该查看QtConcurrent关于QFutureInterface自定义使用的源代码，但如果QFutureInterface的代码在被QtConccurrent使用时崩溃，则可能存在问题。我使用的是Qt 5.3.2。