为阻塞调用构造信号/槽包装器的正确方法是什么？

Question

假设我有一个QObject 和一个阻塞方法（比如说，它是一个库调用，需要在返回之前从网络中获取大量数据）。

class Foo : public QObject { 
Bar* _bar;
public:
    // non blocking call, emits stuffDone when done
    void startStuff(int a, int b);
signals:
    void stuffDone(int sum);
}


class Bar {
public:
    // Blocking call
    int doStuff(int a, b) { 
        for(int i=0; i<=100000000000; i++);
        return a + b;
    }
}

我希望我的 Foo::startStuff 方法在适当的（单独的）线程中运行 doStuff 并在完成时触发 stuffDone 信号。 startStuff 必须立即返回。

Bar可以在必要时成为 QObject，从而允许通过moveToThread设置线程亲和性

这样做的最简单和最惯用（'Qt-like'）的方式是什么？

Answer 1

QtConcurrent::run 可能是最惯用的：

struct Bar {
   // Blocks for 3 seconds
   int doStuff(int a, b) { 
      QThread::sleep(3);
      return a+b+42;
   }
};

class Foo : public QObject {
   Q_OBJECT
   Bar _bar;
public:
   // Non-blocking, emits stuffDone when done
   void startStuff(int a, int b) {
      QtConcurrent::run([a,b,this]{
         auto result = _bar.doStuff(a,b);
         emit stuffDone(result);
      });
   }
   Q_SIGNAL void stuffDone(int sum);
};

您也可以使用QFutureWatcher，而不是使用自定义Foo 类，但恕我直言，它更麻烦，因为没有提供结果的信号 - 您需要连接一个适用于结果的函子。

QSharedPointer<Bar> bar { new Bar };
auto watcher = new QFutureWatcher<int>;
connect(watcher, &QFutureWatcher::finished, watcher, [watcher, bar]{
  watcher->deleteLater();
  int result = watcher->result();
  // use the result here
});
auto future = QtConcurrent::run(&Bar::doStuff, bar, 1, 2);
watcher->setFuture(future);

请注意，“长”加法循环通常会被优化掉，因为它没有副作用，因此是死代码。如果要模拟阻塞，请使用QThread::[|m|u]sleep。