Сигналы больше не работают после перемещения объектов QObject в QThreads - PullRequest
Новая
       7

Сигналы больше не работают после перемещения объектов QObject в QThreads

0 голосов
/ 16 сентября 2018

В основном, заголовок ... если QThread отсутствует (или он только что прокомментирован), я получаю следующий результат: 

LOG> Log working!
LOG> PRODUCER: sent resource address: 29980624
PRODUCER: sent resource address: 29980624
CONSUMER: received resource address: 29980624

29980624 или любую соответствующую позицию в памяти.

Но, если оставить комментарий, просто 

LOG> Log working!

mainwindow.h 

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    explicit MainWindow(QWidget *parent = 0);
    ~MainWindow();

public slots:
    void slot_log(QString str);

signals:
    void signal_log(QString str);

private:
    void createConsumer( void );
    void deleteConsumer( void );
    void createProducer( void );
    void deleteProducer( void );
    void createConnections( void );
    SingleConsumer *consumer;
    QThread *thread_consumer;
    SingleProducer *producer;
    QThread *thread_producer;
};

mainwindow.cpp 

#include "mainwindow.h"

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent)
{
    createConsumer();
    createProducer();
    createConnections();
    QTimer::singleShot(1000, producer, SLOT(slot_publishResourceAddress()) );
}

void MainWindow::slot_log(QString str)
{
    qWarning( QString("LOG> %1").arg(str).toUtf8() );
}

void MainWindow::createConnections( void )
{
    connect(this, SIGNAL(signal_log(QString)), this, SLOT(slot_log(QString)));
    emit signal_log(QString("Log working!"));

    connect(producer, SIGNAL(signal_resourceAddress(uint_fast8_t*)), consumer, SLOT(slot_resource(uint_fast8_t*)));
}

void MainWindow::createProducer( void )
{
     producer = new SingleProducer();
     thread_producer = new QThread();
     producer->moveToThread(thread_producer); // THIS LINE DESERVES ATTENTION
     connect(producer, SIGNAL(signal_log(QString)), this, SLOT(slot_log(QString)));
}

singleproducer.h 

#ifndef SINGLEPRODUCER_H
#define SINGLEPRODUCER_H

#include <QWidget>

class SingleProducer : public QObject
{
    Q_OBJECT
public:
    explicit SingleProducer(QObject *parent = nullptr);

signals:
    void signal_resourceAddress( uint_fast8_t* addr );
    void signal_log(QString str);
public slots:

    void slot_publishResourceAddress( void )
    {
        emit signal_log( QString("PRODUCER: sent resource address: %1").arg((long int) &un_resources__) );
        qWarning(QString("PRODUCER: sent resource address: %1").arg((long int) &un_resources__).toUtf8());
        emit signal_resourceAddress( &un_resources__ );
    }


private:
    uint_fast8_t un_resources__;
};

#endif // SINGLEPRODUCER_H

Редактор не позволяет мне публиковать больше кода ... но я думаю, что это самая важная часть ... если нет, дайте мне знать.Но я поделился этим на pastebin

Где моя ошибка?

1 Ответ

0 голосов
/ 16 сентября 2018

Вы забыли фактически запустить QThread s после их создания в MainWindow::createProducer и MainWindow::createConsumer.Из документации конструктора QThread:

Создает новый QThread для управления новым потоком.Родитель становится владельцем QThread. Поток не начинает выполняться, пока start () не будет вызван .

Поэтому все, что вам нужно сделать, это вызвать thread_producer->start() и thread_consumer->start() соответственно после создания потоков.

...