QThread

[Firefox]

Здравствуйте. Столкнулась с проблемой следующей: хочу запихать в поток класс, в котором есть указатель на другой класс. Пихать все функции в один класс не охота. Думаю есть другое решение, которое я не знаю. Схема у меня следующая

Код:

class A: public QObject
{
Q_OBJECT
public:
explicit  A(QObject *parent,int par1, int par2)
{
cl_B=new B();
connect(cl_B,SIGNAL(...),this,SLOT(...));
};
private:
B *cl_B;
};
class B
{
Q_OBJECT
....
};
class C: public QObject
{
Q_OBJECT
public:
explicit  C(QObject *parent,int par1, int par2)
{
tr=new QThread(this);
class1=new A(this,par1,par2);
class1->moveToThred(tr);
};
private:
QThread *tr;
A *class1;
}

В вывод выдается сообщение Cannot move QObjects with a parrent. Объясните, пожалуйста, как правильно надо.

[Пантер]

1. Это точно полный код? Не вижу в нем проблемы, которая привела бы к выводу такого сообщения.
2. В конструкторе класса A задавай классу B парента this, иначе он не перенесется в поток.

[Firefox]

Приведу код своих классов подробно.

Код:

#ifndef TMK_BC_H
#define TMK_BC_H

#include <QObject>
#include <QSettings>
#include <QTimer>
#include <QDebug>
#include <QTime>

#include "my_tmk/ltmk.h"

class tmk_bc: public QObject
{
    Q_OBJECT
public:
    explicit tmk_bc();
    ~tmk_bc();

};

#endif // TMK_BC_H


//.cpp
#include "tmk_bc.h"

tmk_bc::tmk_bc()

{

}

tmk_bc::~tmk_bc()
{

}

Код:

#ifndef ADAPTER_TMK_H
#define ADAPTER_TMK_H

#include <QObject>
#include "tmk_bc.h"

class adapter_tmk : public QObject
{
    Q_OBJECT
public:
    explicit adapter_tmk(QObject *parent = 0,int par=0, int nTmk=0);

public slots:
    void process();

private:
    tmk_bc *fDrv;



   
};

#endif // ADAPTER_TMK_H
//.cpp
#include "adapter_tmk.h"

adapter_tmk::adapter_tmk(QObject *parent, int par, int nTmk) :
    QObject(parent)
{

    fDrv= new tmk_bc();

}

void adapter_tmk::process()
{
    qDebug()<<__FUNCTION__<<this;

}

Код:

#ifndef GN_PP_H
#define GN_PP_H

#include <QWidget>
#include <QObject>
#include <QDebug>
#include <QDateTime>
#include <QTextStream>
#include <QThread>
#include <QTextCodec>
#include <QFrame>
#include <QKeyEvent>
#include <QTextEdit>
#include <QLineEdit>
#include <QMessageBox>

#include "tmk_bc.h"
#include "my_tmk/adapter_tmk.h"

namespace Ui {
class Widget;
}

class Widget :
               public QWidget
{
    Q_OBJECT
   
public:
    explicit Widget(QWidget *parent = 0,int par=0);
    ~Widget();
private:
    Ui::Widget *ui;

    QThread *thread_bc1;

    adapter_tmk *controller1;

};

#endif
//.cpp
#include "gn_pp.h"
Widget::Widget(QWidget *parent, int par) :
    QWidget(parent),
    ui(new Ui::Widget)
{
    ui->setupUi(this);


    thread_bc1= new QThread(this);
    controller1= new adapter_tmk(this,par,0);
    controller1->moveToThread(thread_bc1);

    connect(thread_bc1,SIGNAL(started()),controller1,SLOT(process()));

    //thread_bc1->start();

}

Widget::~Widget()
{
    delete ui;
    if(thread_bc1->isRunning())
        thread_bc1->terminate();

}

Посмотрите, пожалуйста.

[Пантер]

Firefox, ты можешь минимальный компилябельный пример ошибки сделать? Вот реально, в твоём коде сейчас не хочется разбираться - много лишнего. Если приложишь пример без лишнего кода, я его скомпилю, поправлю и отвечу.

[Firefox]

исправила предыдущий код. Все собирается, только в дебаг валится сообщение на функции moveToThread()
QObject:moveToThread: Cannot move objects with a parent

[Пантер]

    controller1= new adapter_tmk(nullptr,par,0);

[Firefox]

Спасибо. Без парента работает я это поняла, немогли бы вы мне объяснить для понимания. У меня была еще одна программа и там класс с конструктором, в котором QWidget *parent, помещается в поток и проблем нет. А QObject *parent приводит к таким проблемам?

[Пантер]

QWidget вообще должен быть подальше от потоков. Просто запомни - если хочешь мувать в поток, забудь про парентов.

[Firefox]

Спасибо 

[Firefox]

Возник еще один вопрос. При старте потока в функции я инициализирую некоторые данные, а далее по нажатию на кнопку стартует функция, которая работает циклически. Но по отжатию кнопки функцию надо прервать. Я создала сигнал, который иметируется при нажатии на кнопку и при отжатии. В слоте из потока при нажатии на кнопку выводится флаг и запускается функция. Если же кнопку отжали то в этом же слоте флаг устанавливается в 0. Внутри функции проверяется флаг и если он не 1 то делается return. Но проблема в том, что если функция уже запущено и крутится непрерывно то сигнала обработки нет, Тоесть в слот не попадает. Что можно сделать?   думала что-то типа processEvents (), но не в
могу понять как его в потоке использовать. EventFilter попробовала тоже самое.

[Firefox]

Основной класс

Код:

Widget::Widget(QWidget *parent, int par) :
    QWidget(parent),
    ui(new Ui::Widget)
{
    ui->setupUi(this);

    thread_bc1= new QThread(this);
    controller1= new adapter_tmk(0,par,0);

    controller1->moveToThread(thread_bc1);
    connect(thread_bc1,SIGNAL(started()),controller1,SLOT(process()));
    connect(controller1,SIGNAL(finished()),thread_bc1,SLOT(quit()));
    connect(controller1,SIGNAL(finished()),controller1,SLOT(deleteLater()));
    connect(thread_bc1,SIGNAL(finished()),thread_bc1,SLOT(deleteLater()));

    connect(ui->send_pb,SIGNAL(clicked(bool)),controller1,SLOT(startObmen(bool)),Qt::AutoConnection);

    thread_bc1->start();

}

Widget::~Widget()
{
    delete ui;
    if(thread_bc1->isRunning())
        thread_bc1->terminate();

}

поток

Код:

#include "adapter_tmk.h"

adapter_tmk::adapter_tmk(QObject *parent, int par, int nTmk) :
    QObject()
{   
    tmk_N=nTmk;
    flag_send=false;
    flag_conf=false;
   Subaddress1=2;
   Subaddress1=3;
    connect(this, SIGNAL(sendSinhr_commandW(int,int,int,int,int,short)), this, SLOT(sendCommand_OU_10Format(int,int,int,int,int,short)));
    connect(this,SIGNAL(endSendFormat10(int,int)),this,SLOT(Slot_endSendFormat10(int,int)));
    connect(this, SIGNAL(sendData_7Format(int,int,QByteArray,int,int,int)), this, SLOT(sendData_OU_7Format(int,int,QByteArray,int,int,int)));
    connect(this,SIGNAL(endSendFormat7(int,int,int)),this,SLOT(Slot_endSendFormat7(int,int, int)));
    connect(this, SIGNAL(sendSinhr_command(int,int,int,int,bool,int)), this, SLOT(sendCommand_OU_9Format(int,int,int,int,bool,int)));

    nTmk=0;

    this->installEventFilter(this);

}
adapter_tmk::~adapter_tmk()
{
   
}

void adapter_tmk::startSend(int Par_send,int lpi, int subaddr)
{

    if(flag_send==false)
        return;

    switch(Par_send)
    {
        case 0:
        {

            emit sendSinhr_commandW(Adress_ALL,BUS_A,CMD_SYNCHRONIZE_WITH_DATA_WORD,tmk_N,20,5);

        }break;
        case 1:
        {
           
            QByteArray arr_send;
            arr_send.resize(32);
            emit sendData_7Format(Adress_ALL,subaddr,arr_send,lpi,tmk_N,20);///???


        }break;
        case 2:
        {
             usleep(100*1000);

            QByteArray arr_send;
            arr_send.resize(32);
            emit sendData_7Format(Adress_ALL,subaddr,arr_send,lpi,tmk_N,20);///???
            count_line1++;
            if(count_line1==10 || count_line2==10)
            {
                emit sendSinhr_command(Adress_ALL,lpi,CMD_TRANSMIT_STATUS_WORD,tmk_N,false,20);

            }

        }break;
        //ERRORS
        case 1007:
        {
               startSend(0,BUS_A,Subaddress1);

        }break;
        case 1010:
        {
               startSend(1,BUS_A,Subaddress2);

        }break;
    }
}
void adapter_tmk::Slot_endSendFormat10(int rezult,int Lpi)
{
    if(rezult==0)
    {
       startSend(1,BUS_A,Subaddress1);
    }
    else
    {
        startSend(1010,Lpi,Subaddress2);
    }
}
void adapter_tmk::Slot_endSendFormat7(int rezult, int Lpi, int wSubaddress)
{
    if(rezult==0)
    {
        if(wSubaddress==Subaddress1)
            startSend(2,BUS_A,Subaddress2);
        else
            startSend(0,BUS_A,Subaddress1);
    }
    else
    {
        startSend(1007,Lpi,wSubaddress);
    }
}


void adapter_tmk::startObmen(bool mean)
{
   //СЮДА 2-ой РАЗ НЕ ЗАХОДИТ(Обработка события не работает)
    if(!flag_conf)
        return;
     if(mean)
     {
         flag_send=true;
         startSend(0,BUS_A, Subaddress1);
     }
     else
     {
         flag_send=false;
     }

}
void adapter_tmk::process()
{
    if(!tmk_configure(tmk_N))
    {
        flag_conf=false;

    }
    else
    {
        flag_conf=true;
    }
}


bool adapter_tmk::tmk_configure(int tmkNumber)
{
    return true;
}


void adapter_tmk::sendData_OU_7Format(int tmkAddress,int wxSubaddress, QByteArray send_data, int busNumber, int tmkNumb,int time_wait)
{
    emit endSendFormat7(0,lpi,wxSubaddress);
}
void adapter_tmk::sendCommand_OU_9Format(int tmkAddress,int busNumber, int command, int tmkNumb, bool rej_rab,int time_wait)
{
      emit endSendFormat9(0, command,lpi,rej_rab);
}

void adapter_tmk::sendCommand_OU_10Format(int tmkAddress,int busNumber, int command, int tmkNumb,int time_wait,short sd)
{
    emit endSendFormat10(0,lpi);
}

[Firefox]

Проблема решилась заменой в connect (...,Qt:DirrctConnection)

[Firefox]

Есть еще одна проблема. По кнопке стартует и завершается мой поток. Но внутри потока много раз в секунду с помощью сигналов /слотов и функций вызываемых внутри происходит обработка и завершение terminate () wait ()  потока происходит где-то в течение минуты что очень долго, потому как пока не завершится заново  не запустить. Как то можно ускорить завершение?

[Авварон]

Для начала, не спать.
Долги операции периодически проверять флаг завершения.
И да, возможно конкарент тут будет лучше.
И да, терминейтить тред не стоит.

[Firefox]

Оказалась проблема в том, что внутри класса который помещается в поток были вызовы функции, заменила на сигналы ( внутри одного потока)  и все хорошо и быстро стало завершаться. Убрала терминэйт, как Вы и советуете. Спасибо