2つのスレッドでmovetoThreadを使用して2つのQObject間でシグナルとスロットを接続する方法

Question

私は2つのクラスを持っています：AとBはどちらもQObjectからサブクラスです。

class A:public QObject 
{ 
Q_OBJECT 
public: 
A(); 
~A(); 
} 

私はちょうどthis articleを参照しました。次に、GUIで （メインスレッドを言う）Iは

pA = new A(); 
QThread *workerThread = new QThread; 
pA->moveToThread(workerThread); 
connect(workerThread , SIGNAL(started()), pA, SLOT(doWork())); 
connect(pA, SIGNAL(finished()), workerThread , SLOT(quit())); 
connect(pA, SIGNAL(finished()), pA, SLOT(deleteLater())); 
connect(workerThread , SIGNAL(finished()), workerThread , SLOT(deleteLater())); 
workerThread ->start(); 
pB = new B(); 
connect(pA,SIGNAL(sigProduce(double)),pB,SLOT(slotConsume(double)));//I just don't know where to put this line 
QThread *workerThread = new QThread; 
pB ->moveToThread(workerThread); 
connect(workerThread , SIGNAL(started()), pB , SLOT(doWork())); 
connect(pB , SIGNAL(finished()), workerThread , SLOT(quit())); 
connect(pB , SIGNAL(finished()), pB , SLOT(deleteLater())); 
connect(workerThread , SIGNAL(finished()), workerThread , SLOT(deleteLater())); 
workerThread ->start(); 

sigProduce（二重）を用いて、異なるスレッドでAとBの間でデータを交換しようとするオブジェクトとslotConsume（二重）で定義された信号であります公共スロット：クラスBの ヘッダ：？

public slots: 
void slotConsume(double); 

ので、プログラムは、OBJのBは、誰も私を助けることができる（PA、PB）のコードの位置の問題を接続OBJ A.Doesから二重のデータを取得することはできません開始した後？感謝します。

Answer 1

問題を解決する方法を詳しく説明する前に、最初に問題が有効であることを確認してください。スレッドを使用している唯一の理由は、無限ループが必要なためです。多分スレッドを必要としないかもしれません。ループ内の作業が軽い場合は、QTimerのメインスレッドで行うことができます。これについてもっと知るには、this articleを読んでください。

とにかく問題は、スレッドのイベントループをブロックしているdoWorkメソッドに無限ループがあるためです。このため、processEventsに電話する必要がありました。しかし、これは良いデザインではありません。より良い方法は、無限ループをdoWorkから削除することによってスレッドをイベントループに戻すことです。

これで、タイマーでループをシミュレートし、スレッドを停止したいときにタイマーを停止できます。またはQMetaObject::invokeMethodとQt::QueuedConnectionを使用してイベントループからdoWorkメソッドを呼び出し、bool条件を使用して作業を停止することができます。この例では、invokeMethodオプションを使用しました。

#include <QCoreApplication> 
#include <QThread> 
#include <QTimer> 
#include <QDebug> 

class Worker : public QObject 
{ 
    Q_OBJECT 

public: 
    Worker(QObject *parent = 0) : QObject(parent), _stop(false) {} 

public slots: 
    void doWork() 
    { 
     if(_stop) 
      return; 
     QThread::sleep(1); // simulating some heavy work here 
     emit calculationComplete(1564); 
     QMetaObject::invokeMethod(this, "doWork", Qt::QueuedConnection); 
    } 

    void stop() 
    { 
     _stop = true; 
    } 

signals: 
    void calculationComplete(int result); 

private: 
    bool _stop; 

}; 

class ResultHandler : public QObject 
{ 
    Q_OBJECT 
public: 
    ResultHandler(QObject *parent = 0) : QObject(parent) {} 

public slots: 
    void handleResult(int result) 
    { 
     // do something with result 
     qDebug() << Q_FUNC_INFO << "Result:" << result; 
    } 
}; 

int main(int argc, char *argv[]) 
{ 
    QCoreApplication a(argc, argv); 
    QThread thread_a; 
    Worker worker; 
    ResultHandler handler; 

    QObject::connect(&worker, &Worker::calculationComplete, &handler, &ResultHandler::handleResult); 
    QObject::connect(&thread_a, &QThread::started, &worker, &Worker::doWork); 
    QObject::connect(&thread_a, &QThread::finished, &worker, &Worker::stop); 

    worker.moveToThread(&thread_a); 
    thread_a.start(); 

    QTimer::singleShot(5000, &thread_a, &QThread::quit); // just simulating an exit 

    int result = a.exec(); 
    thread_a.quit(); 
    thread_a.wait(5000); 
    return result; 
} 

#include "main.moc"