Russian Qt Forum

#ifndef TC_H
#define TC_H

#include <QThread>
#include <QDebug>

class ThreadClass : public QThread
{
public:
	ThreadClass(QObject *parent = 0) : QThread(parent) { }
	void execMethod() {
		qDebug() << "ThreadClass->execMethod()-> ID = " << QThread::currentThreadId();
	}
protected:
	void run() {
		qDebug() << "ThreadClass->run()-> ID = " << QThread::currentThreadId();
		exec();
		qDebug() << "After Exec";
	}
};

#endif

#include <QtCore>
#include <tc.h>

int main(int argc, char *argv[])
{
    QCoreApplication app(argc, argv);
	qDebug() << "QCoreApplication -> ID = " << QThread::currentThreadId();
	ThreadClass *tc = new ThreadClass();
	tc->moveToThread(tc);
	tc->start();
	sleep(1);
	tc->execMethod();
       return app.exec();
}

#ifndef TC_H
#define TC_H

#include <QThread>
#include <QDebug>

class PrintClass : public QObject
{
	Q_OBJECT
public:
	PrintClass() {}
	virtual ~PrintClass() {}
public slots:
	void printMsg() { qDebug() << "PrintClass->printMsg()-> ID = " << QThread::currentThreadId(); }
};

class ThreadClass : public QThread
{
	Q_OBJECT
public:
	ThreadClass() {}
	virtual ~ThreadClass() {}
	void execMethod() {
		qDebug() << "ThreadClass->execMethod()-> ID = " << QThread::currentThreadId();
		emit sigExec();
	}
protected:
	void run() {
		qDebug() << "ThreadClass->run()-> ID = " << QThread::currentThreadId();
		pc = new PrintClass();
		connect(this, SIGNAL(sigExec()), pc, SLOT(printMsg()));
		exec();
		qDebug() << "After Exec";
	}
signals:
	void sigExec();
private:
	PrintClass *pc;
};
#endif

#include <QtCore>
#include "tc.h"
int main(int argc, char *argv[])
{
    QCoreApplication app(argc, argv);
	qDebug() << "QCoreApplication -> ID = " << QThread::currentThreadId();
	ThreadClass *tc = new ThreadClass();
	tc->start();
	sleep(1);
	tc->execMethod();
    return app.exec();
}

#ifndef TC_H
#define TC_H
#include <QThread>
#include <QDebug>
class ThreadClass : public QThread
{
	Q_OBJECT
public:
	ThreadClass() {}
	virtual ~ThreadClass() {}
	void execMethod() {
		qDebug() << "ThreadClass->execMethod()-> ID = " << QThread::currentThreadId();
		emit sigExec();
	}
protected:
	void run() {
		qDebug() << "ThreadClass->run()-> ID = " << QThread::currentThreadId();
		connect(this, SIGNAL(sigExec()), this, SLOT(printMsg()));
		exec();
		qDebug() << "After Exec";
	}
signals:
	void sigExec();
private slots:
	void printMsg() { qDebug() << "ThreadClass->printMsg()-> ID = " << QThread::currentThreadId(); }
};
#endif

#include <QtCore>
#include <QtTest/QtTest>
#include "tc.h"
int main(int argc, char *argv[])
{
    QCoreApplication app(argc, argv);
	qDebug() << "QCoreApplication -> ID = " << QThread::currentThreadId();
	ThreadClass *tc = new ThreadClass();
	tc->moveToThread(tc);  // <---- ВОТ БЕЗ ЭТОГО НЕ ПРАВИЛЬНО РАБОТАЕТ
	tc->start();
	QTest::qSleep(250);
	tc->execMethod();
    return app.exec();
}

void execMethod() {}
QFuture<void> QtConcurrent::run (execMethod)

class A 
{
....
public:
    m_readdata(набор неких параметров);
    m_writedata(набор неких параметров)
}

class A
{
...
signals:
    sigReaddata(параметры)
    sigWritedata(параметры)
....
}

class A : public QThread
{
    Q_OBJECT
public:
    m_read() { emit s_read(); }
    m_write() { emit s_write(); }
signals:
    s_read();
    s_write();
protected:
    run();
private:
   ClassB *B;
}

A : :run() {
    B = new ClassB;
    connect(this, s_read(), B, slotTransactionRead());
    connect(this, s_write(), B, slotTransactionWrite());
    ....
    exec();
}
....

class B : public QObject
{
Q_OBJECT
public slots:
	void slotReadFromNode(int nodeAddress, int startDataAddress, int quantityData) {
		/*
		1. Читает данные из удаленного узла
		2. Сохраняет их в dataNode1 или dataNodeN в зависимости от адреса узла и т.п.
		*/
	}
	void slotWriteToNode(int nodeAddress, int startDataAddress, int quantityData , QByteArray &data) {
		/*
		выполняется отправка данных в удаленный узел и ожидание положительной квитанции от узла
		*/
	}
	void pollingNodes() {
		for (i=0;i<N;i++) { //выполняется опрос всех узлов
			slotReadFromNode(int nodeAddress, int startDataAddress, int quantityData, const QByteArray &data);
		}
	}
public:
	QByteArray readReadyData(int nodeAddress, int startDataAddress, int quantityData) {
		QByteArray data;
		switch (nodeAddress) {
			case 1: 
				data = dataNode1;
				//тут из массива data вырезаем кусок от startDataAddress до startDataAddress+quantityData
				break;
			case N: 
				data = dataNodeN;
				//тут из массива data вырезаем кусок от startDataAddress до startDataAddress+quantityData
				break;
		}
		return data;
	}
	//массивы готовых данных
	QByteArray dataNode1;
	QByteArray dataNode2;
	.....................
	QByteArray dataNodeN;
/*
где:
	nodeAddress - адрес запрашиваемого удаленного узла
	startDataAddress - стартовый адрес данных которые нужно или прочитать или записать
	quantityData - количество байт данных которые нужно записать или прочитать (по порядку)
	data - сами данные
*/
}

class A : public QThread
{
Q_OBJECT
signals:
	void s_readData(int nodeAddress, int startDataAddress, int quantityData, QByteArray &data);
	void s_writeData(int nodeAddress, int startDataAddress, int quantityData, const QByteArray &data);
public:
	void m_readData(int nodeAddress, int startDataAddress, int quantityData, QByteArray &data, bool manual) {
		if (manual) emit s_readData(nodeAddress, startDataAddress, quantityData, data);
		data = cb->readReadyData(nodeAddress, startDataAddress, quantityData);
	}
	void m_writeData(int nodeAddress, int startDataAddress, int quantityData, const QByteArray &data, bool manual) {
		if (manual) emit s_writeData(nodeAddress, startDataAddress, quantityData, data);
	}
protected:
	void run() {
		cb = new B;
		connect(this, SIGNAL(s_readData(парам)), cb, SLOT(slotReadFromNode(парам)));
		connect(this, SIGNAL(s_writeData(парам)), cb, SLOT(slotWriteToNode(парам)));
		QTimer timer;
		connect(timer, SIGNAL(timeout()), cb, SLOT(pollingNodes()));
		timer->start(1000);
		exec();
	}
private:
	B* cb;
}

A::m_A->readData(111,12,1, manual=true, &adata) {
 /* 
если флаг=true - то значит нужно принудительно прочитать данный узел (не знаю для чего - но может понадобится)
запускаем поток и забываем про него - т.к. он сам обновит нам структуры данных от узлов
*/
if (manual) запускаем поток ThreadRead;

/*
просто читаем структуру данных
*/
 data = readReadyData (111,12,1);
}