QThread不会退出

Question

当我关闭我的应用程序时，线程仍然在运行，即使它应该已经结束。下面的代码将简单挂在workerThread->wait();行上。

主线程

#include "mainwindow.h"
#include "ui_mainwindow.h"

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

    workerThread = new QThread();
    worker = new Worker();

    worker->moveToThread(workerThread);

    connect(this, SIGNAL(ThreadStopSignal()), worker, SLOT(ThreadStopSlot()));
    connect(this, SIGNAL(StartWorkerSignal()), worker, SLOT(RunSlot()));
    connect(worker, SIGNAL(finished()), workerThread, SLOT(quit()));
    connect(worker, SIGNAL(finished()), worker, SLOT(deleteLater()));
    connect(workerThread, SIGNAL(finished()), workerThread, SLOT(deleteLater()));

    workerThread->start();
    emit(StartWorkerSignal());
    qDebug()<<"Main thread: " << QThread::currentThreadId();
}

MainWindow::~MainWindow()
{
    qDebug() << "Asking threads to exit" << QThread::currentThreadId();
    emit(ThreadStopSignal());

    workerThread->wait();

    qDebug() << "thread is dead";
    delete ui;
}

工作者实现

#include "worker.h"

#include <QCoreApplication>

Worker::Worker()
{
    allowRun = true;
}

void Worker::RunSlot()
{
    qDebug() << "Starting";
    int i = 0;
    while(allowRun)
    {
        QThread::msleep(1000);
        QCoreApplication::processEvents();
        qDebug() << i++ << QThread::currentThreadId();
    }
    emit finished();
    qDebug() << "Done counting";
}

void Worker::ThreadStopSlot()
{
    allowRun = false;
    qDebug() << "Ending HID WORKER" << QThread::currentThreadId();
}

典型的运行将产生以下输出(QT5.1.1clang x86_64)*

Main thread:  0x7fff743b2300 
Starting 
0 0x10b6e1000 
1 0x10b6e1000 
2 0x10b6e1000 
3 0x10b6e1000 
4 0x10b6e1000 
5 0x10b6e1000 
6 0x10b6e1000 
7 0x10b6e1000 
8 0x10b6e1000 
9 0x10b6e1000 
10 0x10b6e1000 
11 0x10b6e1000 
Asking threads to exit 0x7fff743b2300 
Ending HID WORKER 0x10b6e1000 
12 0x10b6e1000 
Done counting 

然而，应用程序仍然在运行，只是没有UI；它偶尔会崩溃，导致Apple发送崩溃报告对话框打开。

*是的，我目前仍然坚持一个稍微老一点的Qt版本。但是，我已经在更新的构建上测试了这一点，并取得了类似的结果。

Answer 1

问题相当简单:当您为线程完成wait时，阻塞主线程中的事件循环。但是，同时，事件循环必须接收workerThread->quit()调用。这样你就陷入了僵局。

简单的解决方法是在quit()之前显式地对线程进行wait()处理。您可以通过修复QThread的固有故障来实现这一点。有关Thread类的安全实现，请参见下面。然后，可以简单地在MainWindow的析构函数中销毁线程。

唉，代码有一些反模式和巫毒。

1. workerThread和worker都不应该是指针。这是过早的悲观，因为您添加了额外的堆分配和额外的间接层。这是没有意义的，并且迫使您在不需要任何内存的情况下进行手动内存管理。
2. threadStopSlot是线程安全的，没有理由从工作线程的事件循环中调用它。你可以直接打给它。这样做时，不需要在QCoreApplication::processEvents中调用runSlot。当您这样做时，您将重新输入事件循环，突然，在该线程中运行的所有对象都会受到重入要求的限制，因此必须对其进行审计。坏主意-别这么做。
3. 由于您可能希望让事件循环在工作线程中运行，所以应该反转控件:与其将控件保存在runSlot中，不如将其保存在事件循环中，并让事件循环反复调用runSlot。这就是零超时定时器成语的作用。
4. 初始化器列表会产生惯用的C++。用它们。
5. emit指的是前缀，而不是函数。你是emit fooSignal()，不是emit(fooSignal())。这是一个风格问题，是真的，但emit是为了文档目的。它只是为了人类的消费，而我们人类更容易阅读事物时，他们没有包装在一个额外的括号层。如果您不关心文档方面，那么根本不要使用emit。信号是具有机器生成实现的规则方法.你不需要用任何特殊的方式给他们打电话。
6. 由于您使用的是Qt 5，所以应该使用编译时检查的connect语法.这不需要C++11编译器--除非您也使用lambda。
7. 在窗口的析构函数中请求线程退出可能是个坏主意，因为当工作线程退出时，您可能在主线程中有其他事情要做--这些事情需要运行事件循环。 解构窗口的唯一方法是它是否具有WA_DeleteOnClose属性，或者如果您退出了主事件循环并在退出main()时正在销毁该窗口。您应该捕捉窗口的关闭事件，并启动操作，只有在完成所有应该完成的操作时，才会删除该窗口。
8. 您可以输出线程本身，而不是将线程id输出到qDebug()。您可以利用线程是对象这一事实，并且可以给它们提供人类可读的名称。然后不需要手动比较线程ids或地址，只需读取线程的名称。

鉴于以上所述，如果您要求我编写代码，我将按以下方式执行。

首先，可以将工作人员功能抽象到员工基础中：

#include <QtWidgets>

class WorkerBase : public QObject {
   Q_OBJECT
   Q_PROPERTY(bool active READ isActive WRITE setActive)
   QBasicTimer m_runTimer;
   bool m_active;
protected:
   void timerEvent(QTimerEvent * ev) {
      if (ev->timerId() != m_runTimer.timerId()) return;
      work();
   }
   virtual void workStarted() {}
   virtual void work() = 0;
   virtual void workEnded() {}
public:
   WorkerBase(QObject * parent = 0) : QObject(parent), m_active(false) {
      setActive(true);
   }
   /// This method is thread-safe.
   bool isActive() const { return m_active; }
   /// This method is thread-safe.
   void setActive(bool active) {
      QObject source;
      QObject::connect(&source, &QObject::destroyed, this, [this,active]{
         // The functor is executed in the thread context of this object
         if (m_active == active) return;
         if (active) {
            m_runTimer.start(0, this);
            workStarted();
         } else {
            m_runTimer.stop();
            workEnded();
         }
         m_active = active;
      }, thread() ? Qt::QueuedConnection : Qt::DirectConnection);
   }
   ~WorkerBase() {
      Q_ASSERT(QThread::currentThread() == thread() || !thread());
      setActive(false);
   }
};

然后，工人变得直截了当：

class Worker : public WorkerBase {
   Q_OBJECT
   int m_runCount;
protected:
   void workStarted() Q_DECL_OVERRIDE {
      qDebug() << "Starting" << QThread::currentThread();
   }
   void work() Q_DECL_OVERRIDE {
      QThread::msleep(1000);
      ++ m_runCount;
      qDebug() << m_runCount << QThread::currentThread();
   }
   void workEnded() Q_DECL_OVERRIDE {
      qDebug() << "Finishing" << QThread::currentThread();
      emit finished();
   }
public:
   Worker(QObject * parent = 0) : WorkerBase(parent), m_runCount(0) {}
   Q_SIGNAL void finished();
};

最后，我们添加了安全线程实现，并添加了一个主窗口，该窗口保持事件循环中的控制点，并允许循环运行，直到所有操作就绪，以便对该窗口进行销毁：

class Thread : public QThread {
   using QThread::run; // final method
public:
   Thread(QObject * parent = 0) : QThread(parent) {}
   ~Thread() { quit(); wait(); }
};

class MainWindow : public QMainWindow {
   Q_OBJECT
   Worker m_worker;
   Thread m_workerThread;
   QLabel m_label;
protected:
   void closeEvent(QCloseEvent * ev) {
      if (m_worker.isActive()) {
         m_worker.setActive(false);
         ev->ignore();
      } else
         ev->accept();
   }
public:
   MainWindow(QWidget * parent = 0) : QMainWindow(parent),
      m_label("Hello :)\nClose the window to quit.")
   {
      setCentralWidget(&m_label);
      m_workerThread.setObjectName("m_worker");
      m_worker.moveToThread(&m_workerThread);
      connect(&m_worker, &Worker::finished, this, &QWidget::close);
      m_workerThread.start();
      qDebug() << "Main thread:" << QThread::currentThread();
   }
   ~MainWindow() {
      qDebug() << __FUNCTION__ << QThread::currentThread();
   }
};

int main(int argc, char ** argv)
{
   QApplication a(argc, argv);
   QThread::currentThread()->setObjectName("main");
   MainWindow w;
   w.show();
   w.setAttribute(Qt::WA_QuitOnClose);
   return a.exec();
}

#include "main.moc"

请注意，您的方法所需的信号/插槽数量明显不足。您所关心的是，当worker对象完成时，您可以关闭窗口并将所有对象撕成碎片。

注意声明顺序很重要。在这方面，C++的语义并不是随机的:顺序是有意义的。必须在worker对象之后声明工作线程，因为它们将以相反的顺序被销毁。因此，首先退出并销毁线程。在这一点上，m_worker->thread() == nullptr和您可以从任何线程(包括主线程)中销毁工作线程。如果工人的线程仍然存在，这将是一个错误--然后您需要在自己的线程中销毁工作线程。

输出：

Main thread: QThread(0x7fa59b501180, name = "main")
Starting QThread(0x7fff5e053af8, name = "m_worker")
1 QThread(0x7fff5e053af8, name = "m_worker")
2 QThread(0x7fff5e053af8, name = "m_worker")
3 QThread(0x7fff5e053af8, name = "m_worker")
Finishing QThread(0x7fff5e053af8, name = "m_worker")
~MainWindow QThread(0x7fa59b501180, name = "main")