主线程无法从工作线程中获取信号

Question

这是主线的一部分。

这段代码创建了一个worker和一个workerthread。

worker被移动到workerthread。

然后工人等待信号要求它工作。

工作完成后，工作人员会发出带有结果的信号。

main 应该捕获该信号并在 main 中初始化一个变量。

main()
{.........
// This is the variable to be changed
variableToGetFromWorker = 0;

qDebug() << "Main thread: " << QThread::currentThreadId();

QThread workerThread;
worker* stupidTom = new stupidTom(number);

worker->moveToThread(&workerThread);
connect(&workerThread, &QThread::finished, &workerThread, &QObject::deleteLater);
connect(&workerThread, SIGNAL(start()), stupidTom, SLOT(doJob()));
connect(stupidTom, SIGNAL(jobDone(int)), this, SLOT(jobDone(int)));

workerThread.start();
workerThread.wait();
...........}


// This is a slot at main. Suppose to catch the signal from the worker

void main::jobDone(int result)
{
    qDebug() << "Changing variable";
    variableToGetFromWorker = result;
}

这是worker的doJob槽。

void worker::doJob()
{
    qDebug() << "worker::doJob invoked.";
    qDebug() << "worker Thread:" << QThread::currentThreadId();

    // Doing Job here

    emit jobDone(result);
}

是qDebug的结果

Main thread:  0x7ffff7fc6780
worker::doJob invoked.
worker Thread: 0x7fffdab44700

在调试模式下，我发现程序停在workerThread.wait() 永远不要去main::jobDone(int result)。是什么原因？

对主代码稍作修改：

QThread workerThread;
worker* stupidTom = new stupidTom(number);

worker->moveToThread(&workerThread);
connect(&workerThread, &QThread::finished, &workerThread, &QObject::deleteLater);
connect(&workerThread, SIGNAL(started()), stupidTom, SLOT(doJob()));
connect(stupidTom, SIGNAL(jobDone(int)), this, SLOT(jobDone(int)));
connect(stupidTom, SIGNAL(jobDone(int)), &workerThread, SLOT(quit()));

workerThread.start();
workerThread.wait();

Answer 1

只要信号应该调用槽。这不适用于应该运行插槽或特别是 jobDone 信号的主线程上的 wait()。

确保了解您的应用程序中QThread::exec() 和QThread::wait() 之间的区别。通常在实际应用程序中，您的线程将循环（运行），而启动它的线程仍在循环。循环在受保护的QThread::exec() 方法中实现。我们通常不需要显式调用exec()，但我们需要允许线程运行。您可以通过使 main 函数使用 QEventLoop 进行循环来做到这一点：

int main()
{
//...
    workerThread.start();
    QEventLoop eventLoop;
// here you will probably want to hook-up QEventLoop::quit() slot
// to eventually quit the process
    int returnCode = eventLoop.exec();
//...
    return returnCode;
}

这也是错误的：

connect(&workerThread, SIGNAL(start()), stupidTom, SLOT(doJob()));

相反，您应该创建自己的作业对象并为它执行QObject::moveToThread。这是一个很好的article。所以它应该看起来像：

connect(&workerThread, SIGNAL(started()), stupidTom, SLOT(doJob()));

我可能理解您为什么尝试以上述方式运行线程。它类似于许多 C++ 示例。您也可以在 Qt 中执行此操作，但您还需要了解您将如何等待 workerThread 完成。 Qt 最流行的线程间交互方式是使用信号和插槽。这就是为什么我们应该在 main 中使用 QEventLoop。但当然还有另一种选择。对于较低级别的普通 C++，您可以使用互斥锁和条件变量来完成相同的操作。或者同样的wait()，但没有涉及任何信号。

还要观察调试输出，是否所有的连接语句都真正将正确的信号连接到插槽。如果没有连接，它会打印警告。