QThread 上的函数永远不会被调用

Question

我试图在单独的线程上进行一些繁重的计算，这样我就不会冻结 UI。为此，我使用 Qt 5.5。

我尝试从官方站点实施工作线程 example，但不幸的是没有太大成功。下面你可以看到我的代码：

main.cpp:

int main(int argc, char* argv[]) {
    QApplication app(argc, argv);

    DepthMap* depthmap = new DepthMap();
    DepthMapGrabber* grabber = new DepthMapGrabber(depthmap);

    PointCloudWindow myPointCloudWindow;
    myPointCloudWindow.setDepthMap(grabber);
    myPointCloudWindow.show();

    ProcessorController* controller = new ProcessorController(depthmap);
    controller->startThread();

    return app.exec();
}

ProcessController.h:

class ProcessorController : public QObject
{
Q_OBJECT
// functions
private:
    QThread workerThread;

public:
    ProcessorController(const DepthMap* depthmap);
    ~ProcessorController();

    void startThread();

public slots:
    void handleResults(const QString &);

signals:
    void operate(const QString &);

// variables
private:
    Processor* m_processor;
};

ProcessController.cpp:

ProcessorController::ProcessorController(const DepthMap* depthmap) {
    m_processor = new Processor(depthmap);
}

ProcessorController::~ProcessorController() {
    if (m_processor != nullptr) {
        delete m_processor;
        m_processor = nullptr;
    }

    workerThread.quit();
    workerThread.wait();
}

void ProcessorController::startThread() {
    m_processor->moveToThread(&workerThread);
    connect(&workerThread, &QThread::finished, m_processor, &QObject::deleteLater);
    connect(this, &ProcessorController::operate, m_processor, &Processor::doWork);
    connect(m_processor, &Processor::resultReady, this, &ProcessorController::handleResults);
    workerThread.start();

    // LOG
    std::cout << "Worker thread has been started!" << std::endl;
}

void ProcessorController::handleResults(const QString &) {
    // LOG
    std::cout << "Worker thread finished!" << std::endl;
}

Processor.h:

class Processor : public QObject
{
Q_OBJECT

// functions
public:
    Processor(const DepthMap* depthmap);

public slots:
    void doWork(const QString &parameter);

signals:
    void resultReady(const QString &result);

// variables
private:
    QMutex m_mutex;
    const DepthMap* m_depthmap;
};

Processor.cpp:

Processor::Processor(const DepthMap* depthmap) : m_depthmap(depthmap) {}

void Processor::doWork(const QString &parameter) {
    // LOG
    std::cout << "Worker thread is working..." << std::endl;

    QString result;

    // copy cloud and work on the copy
    PointCloudPtr myCloud;
    m_mutex.lock();
    pcl::copyPointCloud(*m_depthmap->cloud, *myCloud);
    m_mutex.unlock();

    /* ... here is the expensive or blocking operation ... */

    emit resultReady(result);
}

问题是，处理器中的 doWork 永远不会被调用。我究竟做错了什么？在此先感谢您的任何解释和帮助！

编辑：

如果我把

QString result;
emit operate(result);

之后

workerThread.start();

在startThread()中，线程被执行！

谁能解释一下这背后的机制是什么？

Answer 1

很长一段时间以来，Qt 都在我们可以操作的线程上提供了虚拟任务对象。这是通过 QObject::moveToThread 完成的，并且 QObject 派生对象必须具有启动作业的插槽。在这种情况下，插槽是 doWork 并且连接到信号操作。

connect(this, &ProcessorController::operate, m_processor, &Processor::doWork);

这就是为什么：

emit operate(desiredStr);

应该可以解决问题。

顺便说一句。如果不需要来自用户定义信号的特定推送，我们始终可以为此使用 QThread::started 信号。不过，在这种情况下，doWork 插槽不会接收参数。

connect(&workerThread, &QThread::started, m_processor, &Processor::doWorkNoParams);

QThread 上的函数永远不会被调用

function on QThread never gets called

qt

qthread

qt5

qt5.5