c++ - 使用 Qt 线程的最小示例？

Question

长话短说:

我一直在寻找 Qt 线程的简明示例，但我发现的只是复杂的“吸引眼球”，声称可以展示 QThreads 的工作原理，但它们实在是太难理解了。

我接受了 Zen 的回答，因为他向我展示了我的尝试所遗漏的确切内容，然后添加了我自己的内容作为我想看到的示例。单击此处跳转到它:https://stackoverflow.com/a/34561122/3491308

我的原问题如下:

---

看来我一定遗漏了什么，但我似乎无法按照我认为应该的方式完成这项工作。我的完整应用程序需要有两个或三个线程，所有线程(几乎)一起启动并永远运行:

• 图形用户界面
  • 在启动其他两个线程处理它们之前从文件中加载一堆对象。
• 实时处理器
  • 具有 TimeCriticalPriority 和周期性 QTimer“中断”，试图将 PC 用作比我开始使用的系统更强大的嵌入式系统。这个项目一开始是完全嵌入式的，但很快就变得过于复杂而无法在那里进行管理。
• USB HID 驱动程序
  • 连接到仍然嵌入的项目部分。

核心功能当然是在实时处理线程中，其他两个只是调整它的工作方式。因此，根据用户在 GUI 中的操作，实时处理器运行时会创建、修改和销毁处理对象，并且 USB 也会生成和使用其中一些对象中的数据。

我一直在寻找如何在 Qt 中使用线程的示例，但我不断收到复杂的“眼睛糖果”类型的应用程序，这些应用程序使线程部分变得杂乱无章。我尽最大努力尝试解释它们并编写自己的代码，但是我在 Qt 本身中不断遇到段错误，我的小型“ Playground ”项目说我什至没有获得第二个线程:

#ifndef MAIN_H
#define MAIN_H

#include <QtWidgets>

class MainWindow : public QMainWindow
{
    Q_OBJECT
public:
    MainWindow(QWidget* parent = 0);
    ~MainWindow() {}
private:
    QObject* mythingy;
private slots:
    void deleteObject(QObject* thingy);
};

class Worker : public QObject
{
    Q_OBJECT
public:
    Worker(QObject* thingy, QObject* parent = 0);
private:
    QObject* mythingy;
signals:
    void deleteObject(QObject* thingy);
private slots:
    void doWork();
};

#endif // MAIN_H

/***************
*** main.cpp ***
***************/
#include "main.h"
#include <QApplication>

int main(int argc, char* argv[])
{
    QApplication a(argc, argv);
    MainWindow w;
    w.show();
    return a.exec();
}



MainWindow::MainWindow(QWidget* parent)
    : QMainWindow(parent)
{
    mythingy = new QObject(this);
    QThread* thisthread = this->thread();
    QThread* mainthread = QCoreApplication::instance()->thread();
    //breakpoint here to check thisthread and mainthread
    Worker* worker = new Worker(mythingy, this);
    connect(worker, SIGNAL(deleteObject(QObject*)), this, SLOT(deleteObject(QObject*)));
}

void MainWindow::deleteObject(QObject* thingy)
{
    QThread* thisthread = this->thread();
    QThread* mainthread = QCoreApplication::instance()->thread();
    //breakpoint here to check thisthread and mainthread
    delete thingy;
}



Worker::Worker(QObject* thingy, QObject* parent)
    : QObject(parent)
{
    mythingy = thingy;
    QThread* thread = new QThread(this);
    this->moveToThread(thread);

    //use a timer to allow the constructor to exit
    QTimer* timer = new QTimer(this);
    timer->setSingleShot(true);
    timer->start(1000);
    connect(timer, SIGNAL(timeout()), this, SLOT(doWork()));

    QThread* thisthread = this->thread();
    QThread* mainthread = QCoreApplication::instance()->thread();
    //breakpoint here to check thisthread and mainthread
    thread->start();
}

void Worker::doWork()
{
    QThread* thisthread = this->thread();
    QThread* mainthread = QCoreApplication::instance()->thread();
    //breakpoint here to check thisthread and mainthread
    deleteObject(mythingy);
}

如果有人可以根据我对项目的描述发布一个如何正确执行 QThreads 的示例，并且尽可能减少困惑(如果可能，最好比我的更短)，我将不胜感激。

---

编辑:

根据 Zen 的回答，这似乎也有效:

MainWindow::MainWindow(QWidget* parent)
    : QMainWindow(parent)
{
    mythingy = new QObject(this);
    QThread* thisthread = this->thread();
    QThread* mainthread = QCoreApplication::instance()->thread();
    Worker* worker = new Worker(mythingy, this);
}

Worker::Worker(QObject* thingy, QObject* parent)
    : QObject(0)    //no real parent, so we can move to a different thread
{
    mythingy = thingy;

    QTimer* timer = new QTimer(this);
    timer->setSingleShot(true);
    timer->start(1000);
    connect(timer, SIGNAL(timeout()), this, SLOT(doWork()));

    QThread* thread = new QThread(parent);
    this->moveToThread(thread);
    thread->start();
}

void Worker::doWork()
{
    QThread* thisthread = this->thread();
    QThread* mainthread = QCoreApplication::instance()->thread();
    delete mythingy;
}

仍在构造函数内部移动自己，现在直接删除对象而不是告诉所有者的线程来做。 (请记住，在整个项目中，所有者已经将对象标记为删除，但实际上没有这样做，因为其他线程可能正在使用它)

有什么问题吗？

Answer 1

这是我在 Zen 的帮助下寻找的简明示例。如果你一直向下滚动它，它很适合(至少在我的屏幕上)。上面的头文件只是让它编译。<​​/p>

#ifndef MAIN_H
#define MAIN_H

#include <QtWidgets>

class Worker : public QObject
{
    Q_OBJECT
public:
    Worker(QObject* thingy, QObject* parent = 0);
private:
    QObject* mythingy;
private slots:
    void doWork();
};

class MainWindow : public QMainWindow
{
    Q_OBJECT
public:
    MainWindow(QWidget* parent = 0);
    ~MainWindow();
private:
    QObject* mythingy;
    Worker* myworker;
};

#endif // MAIN_H

/***************
*** main.cpp ***
***************/
#include "main.h"
#include <QApplication>

int main(int argc, char* argv[])
{
    QApplication a(argc, argv);
    MainWindow w;
    w.show();
    return a.exec();
}

MainWindow::MainWindow(QWidget* parent)
    : QMainWindow(parent)
{
    mythingy = new QObject(this);
    myworker = new Worker(mythingy, this);
}

MainWindow::~MainWindow()
{
    delete myworker;
}

Worker::Worker(QObject* thingy, QObject* parent)
    : QObject(0)    //no real parent, so we can move to a different thread
{
    mythingy = thingy;

    //move myself to a new thread and start it
    QThread* thread = new QThread(parent);
    connect(thread, SIGNAL(started()), this, SLOT(doWork()));
    this->moveToThread(thread);
    thread->start();
}

void Worker::doWork()
{
    //deleting an object from a different thread:
    //requires careful planning to make it safe, but seems to work as expected
    delete mythingy;
}

注释指出了重要的部分，其余的只是让它运行而已。您可以将其添加到 doWork() 以验证它是不同的线程:

QThread* thisthread = this->thread();
QThread* mainthread = QCoreApplication::instance()->thread();

紧接着打个断点，看看指针不一样

---

至于段错误，当我做对时，基于线程的错误似乎消失了，只留下天真编写的、非线程安全的代码来过早地删除东西。