c++ - 如何正确处理 QThread 中长时间运行的任务的信号和事件

Question

我正在尝试创建一个在 QT 中运行服务器的线程。服务器在轮询循环中运行，直到它被告知停止。我希望能够向我的类(class)添加插槽，这样我就可以做一些事情，例如停止服务器发出信号。

QT 似乎与 QThread 有着相当复杂的历史，所以我一直在阅读有关正确执行线程的博客，这就是我想出的。

MyServer 是从 QObject 派生的类:

class MyServer : public QObject {
  Q_OBJECT

public slots:
  void run();
  void stop();

signals:
  void finished();

private:
  void init();
  void pollForConnections(int ms);
  void cleanup();
};

我可以通过创建对象、创建 QThread、将服务器移至线程的所有权、连接一些信号并调用 start() 来从线程运行服务器:

MyServer *server = new MyServer();
QThread *serverThread = new QThread();
server.moveToThread(serverThread);
// Cause thread to delete itself when server finishes
QObject::connect(serverThread, SIGNAL(started()), server, SLOT(run()));
QObject::connect(server, SIGNAL(finished()), serverThread, SLOT(deleteLater()));
serverThread->start();

因此，当 QThread 启动时，它会发出一个 started() 信号，并且我的 run() 插槽由 started() 信号调用。 run() 方法是一个循环，它一直旋转直到它被告知停止:

void MyServer::run() {
  init();
  while (true) {
    {
      QMutexLocker lock(&mutex_);
      if (stop_) {
        break;
      }
    }
    pollForConnections(100); // 100ms is timeout
  }
  cleanup();
  emit finished();
}

void MyServer::stop() {
  QMutexLocker lock(&mutex_);
  stop_ = true;
}

这里的问题当然是 started() 不会返回到 QThread，因为它在我的循环中。由于我的循环没有信号处理，我无法将 stop() 连接到另一个信号。所以目前我只是从任何线程调用 stop() 并在我这样做时使用互斥锁来保护标志。

QT 有一个 QEventLoop，我可以修改它的循环:

QEventLoop eventLoop;
while (true) {
    if (stop_) {
      break;
    }
    pollForConnections(100); // 100ms is timeout
    eventLoop.processEvents();
  }

所以可能我可以将 stop() 挂接到某种信号，我不需要互斥体来保护 stop_ 因为它将在我自己的线程上运行。我还可以在旋转时处理事件。

这似乎起作用了，但我想知道这是否是一个好习惯 - 不要忘记我仍然挂起 started() 信号所以这里是否存在重入问题？另外，一旦我退出循环，QThread 是否会进入它的默认 exec() 然后永远运行？通过发出 finished() 并调用 deleteLater() 线程将自己正确地整理就足够了吗？

Answer 1

如果您只使用 QThread 的默认 run() 方法，并使用信号和插槽作为一切的机制，您的设计会更好。

特别是，您可以将信号连接到线程的 quit() 方法，而不是使用互斥锁和轮询 bool 值，当您希望线程离开时，只需发出该信号即可。

此外，几乎肯定有一种比轮询连接更好的方法来检查连接。轮询的问题(无论如何在这种情况下)是它会阻止执行线程的其他职责长达 100 毫秒，这将使线程执行缓慢。这也意味着线程每 100 毫秒就会用完一些 CPU 周期，即使 99% 的时间实际上没有连接传入。假设这些是 TCP 连接，检查 QSocketNotifier和/或 QTCPServer类，其中任何一个都可以在不进行轮询的情况下处理传入的 TCP 连接。

Also, once I drop out of my loop, is the QThread going to drop into it's default exec() and then run forever?

仅当您显式调用 QThread::run() 时。

Is it sufficient that by emitting finished() and invoking deleteLater() that the thread will sort itself out properly

它可能有效，但我认为调用 QThread::quit() 或 QThread::exit() (并使用默认事件循环)会是更好的做法。