在QThreadPool中執行插槽

我有一個類應該在一個線程中運行，並且需要一個用於插槽的事件循環，目前我用moveToThread()很好地運行它，但我想使用QThreadPool，並且遇到了問題。在QThreadPool中執行插槽

當QThreadPool我可運行的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。

來源

2013-07-26 Paul

也許你可以在你的class Foo邏輯一分爲二。然後將所有信號轉發給工作對象。所以現在你的插槽將在池線程上調用。
但是，QThreadPool專爲執行大量短任務而不會創建太多併發線程而設計。一些任務已經排隊等待其他人完成。如果這不是你的意圖，你可能想回到老的QThread並改用它。

來源

2013-07-26 08:31:40 spiritwolfform

有趣的是，我會給出這個答案。 – Paul

+1，標記爲答案，因爲我解決了問題，不完全如您所說，因爲我在worker中運行事件循環，而不是在runnable中運行。 – Paul

由於您的連接調用

connect(this, SIGNAL(startWorking()), this, SLOT(doWork()));

用於連接類型的默認參數，這將是一個Qt ::自動連接。該信號是從池池中發出的，並且該池仍然屬於foo，它具有與主線程相關的線程。自動連接將決定將插槽放入主線程的事件隊列中。

有兩種方法可以解決這個問題：

connect(this, SIGNAL(startWorking()), this, SLOT(doWork()), Qt::DirectConnection);

並取出eventloop.exec（）;

在運行方法

，連接信號和時隙之前移動Foo對象到當前線程。用QEventLoop
主控器QRunnable和工人QObject，你的工作線程中調用run()方法QEventLoop::exec之前創建：

來源

2013-07-26 07:50:43

第二個解決方案將不起作用，因爲我沒有引用池中的線程，我不知道哪個線程將被分配到工作。第一個不會工作，因爲信號不會立即發射出去，並且由於我沒有事件循環，所以線程將在run（）返回後退出。 – Paul

您無法將對象移動到當前線程，因爲您只能從所有者線程「推送」。使用Qt :: DirectConnection也是一個壞主意，因爲這並不能保證在工作線程上調用槽（如同op似乎期望的那樣） – spiritwolfform

在QThreadPool中執行插槽

回答

相關問題