c++ - 在 QThreadPool 中执行槽

我有一个应该在线程中运行的类，并且需要一个用于插槽的事件循环，目前我用 moveToThread() 很好地运行它，但是我想使用 QThreadPool 并且我遇到了问题。

当使用 QThreadPool 运行时，我的 runnable 的 run() 方法是从池线程调用的(我用 QThread::currentThread() 进行了检查)，但是我的插槽没有在池线程中运行，所以我认为对象没有移动到线程中水池。

我认为这是因为我知道插槽在接收器的线程中运行，这正是我在使用 moveToThread() 方法和 QThread 时得到的(正确)行为。

如何让我的 QRunnable(下面示例中的 Foo)完全在池线程中运行？
或者是我做错了什么或理解错了？

以下 POC 演示了该问题:

foo.h

#ifndef FOO_H
#define FOO_H

#include <QObject>
#include <QRunnable>
#include <QEventLoop>

class Foo : public QObject, public QRunnable
{
    Q_OBJECT
public:
    explicit Foo(int data, QObject *parent = 0);
    void run();
signals:
    void startWorking();
public slots:
    void doWork();

private:
    QEventLoop eventLoop;
    int data;
};

#endif // FOO_H

foo.cpp

#include "foo.h"

#include <QThread>
#include <QDebug>

Foo::Foo(int d, QObject *parent) :
    QObject(parent), eventLoop(this), data(d)
{
}

void Foo::run()
{
    qDebug() << "run() in: " << QThread::currentThread();
    connect(this, SIGNAL(startWorking()), this, SLOT(doWork()));
    emit startWorking();
    eventLoop.exec();
}

void Foo::doWork()
{
    qDebug() << "doWork() in: " << QThread::currentThread();
}

main.cpp

#include <QCoreApplication>
#include <QThreadPool>

#include "foo.h"

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    Foo *foo = new Foo(42);

    QThreadPool::globalInstance()->start(foo);

    return a.exec();
}

但是请注意，在我的真实代码中，信号不会立即发出，因为它会在我在网络上接收到一些数据之后发出。

PS:POC 也可以在 here 中找到。

最佳答案

也许您可以将 class Foo 中的逻辑分成两部分:
带有 QRunnable 和 worker QEventLoop 的主机 QObject ，您在调用 run() 方法之前在 QEventLoop::exec 的工作线程上创建。然后将所有信号转发给工作对象。
所以现在您的插槽将在池线程上调用。
然而，QThreadPool 是为执行大量短任务而设计的，而不会创建太多的并发线程。一些任务已排队等待其他任务完成。如果这不是您的本意，您可能想回到旧的 QThread 并改用它。

关于c++ - 在 QThreadPool 中执行槽，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/17875500/