Сигнализация Qt между потоками, один из потоков графического интерфейса?

Взгляните на Сигналы и интервалы темы. Если вы всегда используете сигналы и слоты для связи с рабочим потоком, Qt обрабатывает moveToThread за вас, если это необходимо и вы использовали правильное соединение.

Изменить: я предполагаю, что автор статьи видел свою проблему, поскольку он вызывал start в конструкторе до того, как поток был фактически создан. Другими словами, не доверяйте слепо стороннему коду.

Изменить: в ответ на ваш комментарий посмотрите на Mandelbrot пример, под заголовком MandelbrotWidget Class Implementation:

При соединениях в очереди Qt должен хранить копию аргументов, которые были переданы сигналу, чтобы впоследствии передать их в слот. Qt умеет копировать многие типы C++ и Qt, но QImage не является одним из них. Поэтому мы должны вызвать функцию шаблона qRegisterMetaType(), прежде чем сможем использовать QImage в качестве параметра в соединениях с очередью.

Я считаю, что это немного устарело, вот действительные мета-типы. Поскольку сигналы и слоты между потоками используют соединения в очереди, в большинстве случаев вам не нужно выполнять вызовы moveToThread.

Изменить: я попытаюсь объяснить ситуацию на аналогичном примере:

мифочит.h:

#ifndef MYTHREAD_H
#define MYTHREAD_H

#include <QThread>
#include <QMutex>

class MyThread : public QThread
{
   Q_OBJECT

protected:
   virtual void run();

signals:
   void signalGUI(QString);
};

#endif // MYTHREAD_H

мифочит.cpp:

#include "mythread.h"
#include <QString>

void MyThread::run()
{
   qDebug("Thread id inside run %d",(int)QThread::currentThreadId());
   static int run = 0;
   QString temp = QString("Run: %1").arg(run++);
   qDebug("String address inside run %p", &temp);
   emit signalGUI(temp);
}

mylineedit.h

#ifndef MYLINEEDIT_H
#define MYLINEEDIT_H

#include <QLineEdit>

class MyLineEdit : public QLineEdit
{
Q_OBJECT
public:
    explicit MyLineEdit(QWidget *parent = 0);

public slots:
    void setText(const QString &string);

};

#endif // MYLINEEDIT_H

mylineedit.cpp

#include "mylineedit.h"
#include <QThread>

MyLineEdit::MyLineEdit(QWidget *parent) :
    QLineEdit(parent)
{
}

void MyLineEdit::setText(const QString &string)
{
   qDebug("Thread id inside setText %d",(int)QThread::currentThreadId());
   qDebug("String address inside setText %p\n", &string);
   QLineEdit::setText(string);
}

основной.cpp:

#include <QApplication>
#include <QPushButton>
#include <QHBoxLayout>
#include "mythread.h"
#include "mylineedit.h"

//GUI calls a thread to do some job and sub update the text box once it is done
int main(int argc, char *argv[])
{
   QApplication a(argc, argv);
   QWidget w;
   QHBoxLayout * pH = new QHBoxLayout(&w);
   QPushButton * pushButton = new QPushButton("Run Thread", &w);
   MyLineEdit * lineEdit = new MyLineEdit(&w);

   pH->addWidget(pushButton);
   pH->addWidget(lineEdit);
   w.show();

   MyThread thread;
   qDebug("Thread id %d",(int)QThread::currentThreadId());
   QObject::connect(pushButton,SIGNAL(clicked()),&thread,SLOT(start())) ;
   QObject::connect(&thread,SIGNAL(signalGUI(const QString&)),lineEdit,SLOT(setText(const QString&)));
   return a.exec();
}

Пример вывода после нажатия кнопки:

Thread id 1088110320
Thread id inside run 1093176208
String address inside run 0x41288350
Thread id inside setText 1088110320
String address inside setText 0x974af58

Как видите, поток выполнения отличается от основного потока графического интерфейса. Кроме того, даже если вы передаете константную ссылку на QString, поскольку она пересекает границы потока, она копирует ее. Я настоятельно рекомендую вам прочитать Threads и QObject.

2. Метод QThread::start() создает поток и вызывает вашу реализацию run(). Если вы хотите обрабатывать события или полученные сигналы в потоке, вам нужно вызвать QThread::exec() внутри вашей реализации run(). Вы никогда не должны вызывать run() явно, и вы никогда не должны вызывать exec() вне run().

3. Поток-владелец имеет значение только тогда, когда слот подключен к сигналу с типом соединения, отличным от Qt::DirectConnection. Затем Qt обеспечит выполнение слота в потоке-владельце, но для этого поток-владелец должен запускать цикл обработки событий с QThread::exec(). В этом случае вызов myObj.moveToThread(myThread) обеспечит выполнение myObj слотов в потоке myThread.

4. Объект потока принадлежит потоку, в котором он был создан, а не потоку, которым он управляет (и в котором будет выполняться метод run). Таким образом, когда вы подключаете сигнал к слоту объекта потока, этот слот будет работать в потоке, в котором был создан объект потока, если только вы не вызовете moveToThread().

При перемещении объекта между потоками вы решаете, к какому циклу событий он принадлежит. При создании соединений внутри потока сигнальный код напрямую вызывает каждый из слотов (необходимо дождаться их завершения). Передача сигналов через границы потоков помещает вызов signal в цикл обработки событий, позволяя потоку слота выполнить вызов слота, когда он будет готов.

Выполнение прямых вызовов между потоками требует, чтобы вы удостоверились, что ваши функции являются реентерабельными. Вы также должны защитить свои данные с помощью мьютексов или семафоров и в то же время избежать состояния гонки.

В статье я предполагаю, что задержка связана с тем, что звонок прямой, т.е. вообще не обрабатывается в фоновом режиме (но я только бегло просмотрел текст).

#include <QtGui/QApplication>
#include <QPushButton>
#include <QHBoxLayout>
#include <QLineEdit>
#include <QString>
#include "mythread.h"
//GUI calls a thread to do some job and sub update the text box once it is done
int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    QWidget w;
    QHBoxLayout * pH = new QHBoxLayout(&w);
    QPushButton * pushButton = new QPushButton("asdad");
    QLineEdit * lineEdit = new QLineEdit("AAA");
    pH->addWidget(pushButton);
    pH->addWidget(lineEdit);
    w.setLayout(pH);
    w.show();
    MyThread thread;
    thread.moveToThread(&thread);
    thread.start();
    qDebug("Thread id %d",(int)QThread::currentThreadId());
    QObject::connect(pushButton,SIGNAL(clicked()),&thread,SLOT(callRun()),Qt::QueuedConnection) ;
    QObject::connect(&thread,SIGNAL(signalGUI(QString)),lineEdit,SLOT(setText(QString)),Qt::DirectConnection);
    return a.exec();
}

#ifndef MYTHREAD_H
#define MYTHREAD_H

#include <QThread>
#include <QMutex>

class MyThread : public QThread
{
    Q_OBJECT
public:
    MyThread();
public slots:
    void callRun();
    void run();
 signals:
    void signalGUI(QString);
private:
    QMutex mutex;

};

#endif // MYTHREAD_H
#include "mythread.h"
#include <QDebug>
#include <QString>
#include <QMutexLocker>

MyThread::MyThread()
{
}
 void MyThread::callRun()
 {
     QMutexLocker fn_scope(&mutex);
     static int a = 0;
    ++a;
     qDebug("Thread id inside run %d",(int)QThread::currentThreadId());
     this->sleep(3);
     static QString number;
     QString temp;
     number += temp.setNum(a);
     emit signalGUI(number);

 }
 void MyThread::run()
 {
    exec();
 }

Создается новый объект потока, и объект потока перемещается в тот же поток. Сигналы теперь проходят через потоки, а тип соединения — очередь, и все работает как положено.

некоторые объекты могут использоваться только в потоке-владельце. например, если вы создаете и сокетируете объект в одном потоке и хотите отправлять и получать данные в другом потоке, это невозможно. поэтому одним из решений является перемещение вашего объекта из одного потока в другой и работа с ним.