QThread richtig einsetzen?

[J.Hilk]

Guten Morgen @Galilio ,

zu deinem letzten post:

das Signal QThread::started wird nur dann ausgelöst wenn QThread bereit ist die EventLoop zu starten, also kurz bevor (intern) exec in run gecalled wird.

Das passiert eigendlich nur einmal in der Lebenszeit des Threads.

Ist nen Privates Signal, d.h. nur das QThread Object kann es auslösen, aber man kann sich von außerhalb an das Signal hängen, mit nem connect. Klick hier zum nachlesen

Und das ist auch was im Beispiel passiert. Weil connect(workerThread, &QThread::started, workerObject, &Worker::init);eine Qt::Queuedconnection ist, wird init auf jedenfall erst dann ausgeführt, wenn die QThread eventloop läuft.

Der Connecttyp ist nicht expliciet definiert -> Auto als standart -> Queuedconnection weil Threadübergreifend.

Zu dem post davor,
sieht so aus, als ob die Objecte im Constructor im original Thread erstellst und nicht mit verschiebst. Aber ohne Code ist da schwer was zu sagen, der Stacktrace sollte dir aufschluß darüber geben in welcher Zeile das passiert. Programm mal in Debug starten und gucken :-)

[Galilio]

@J.Hilk

Problem tritt wenn die Application verlassen wird.

Beim Verlassen der application wird der destrctor der CAgilentLan aufgerufen, der so aussieht:

CAgilentLan::~CAgilentLan()
{
	this->Close(GetiTimeOutClose());

	if (this->Execute("DeleteObject", 0, 0, 0) != enRspOK)
	{
		throw(QString("Error AgilentLan.CPP/Destructor TcpSocket Delete memory error"));
	}
}

die close Methode sieht wie folgende aus:

bool CAgilentLan::Close(const int iTimeout_p)
{
	bool boRet_l = true;

	if (this->Execute("CloseConnection", 500, iTimeout_p, 1000) != enRspOK)
	{
		throw(QString("Error AgilentLan.CPP/Close Connection error"));
	}
	
	if (GetboDebug())
	{
		throw(QString("Tcp Socket is closed"));
	}

	return boRet_l;
}

und genau gesagt hier knallt:

	GetTcpSocket()->disconnectFromHost();

Das Object "GetTcpSocket()" ist nicht gleich NULL, sonst hätte ich einen ganze andere Fehlermeldung.

[Galilio]

Guten morgen zusammen
Problem wurde gelöst.
ich habe es immer den falschen Thread benutzt und dazu versuche ich ihm zu löschen.
danke
@J-Hilk

[Galilio]

This post is deleted!

[J.Hilk]

@Galilio
hi,

Warum bestehst du eigentlich auf einer Synchronen TCPSocket Lösung? Wenn möglich sollte man immer die Asynchronen Funktionen nehmen.

Das gesagt, waitForDisconnected hat in der docu den Beisatz

Note: This function may fail randomly on Windows. Consider using the event loop and the disconnected() signal if your software will run on Windows.

Also besondere Vorsicht die man hier walten lassen sollte.

if ((GetTcpSocket()->state() == QAbstractSocket::UnconnectedState) || (GetTcpSocket()->waitForDisconnected(GetTimeOut())))

ist an sich nicht falsch, der erste Parameter wird immer zuerst geprüft, und falls true, wird der Rest des IF-Statements ignoriert.
Ist aber trotzdem eine blockierende Funktion und wird deinen Thread für bis zu 3 Sekunden, der default timeout, freezen.

Ich würde es etwas anders lösen, und zwar über das Signal stateChanged vom TcpSocket

connect(tcpSocket, &QTcpSocket::stateChanged, this, [=](QAbstractSocket::SocketState socketState{
    if(socketState == ConnectedState)
       emit SocketConnected();
    if(socketState == UnconnectedState)
       emit SocketDisconnected();
});

einen Timeout kannst du dir ganz leicht selbst machen mit einem QTimer

void disconnectMySocket(){
   tcpSocket->disconnectFromHost();
   QTimer::singleShot(3000, this, &mySocketClass::checkDisconnected);
}

void checkDisconnected(){
   if(tcpSocket->state != UnconnectedState){
   //Error Handling
   }
}

[Galilio]

@J.Hilk
vielen dank
Dein tipps sind super

[Galilio]

@J.Hilk
Hi,

Das

void disconnectMySocket(){
   tcpSocket->disconnectFromHost();
   QTimer::singleShot(3000, this, &mySocketClass::checkDisconnected);
}

void checkDisconnected(){
// Diese Funktion wird aber ne aufgerufen
   if(tcpSocket->state != UnconnectedState){
   //Error Handling
   }
}

wird aber ne erreicht.

[J.Hilk]

@Galilio
mit ziehmlicher sicherheit wird das aufgerufen x), Fehlermeldungen falls vorhanden immer mit posten.

Ich hab das so vereinfacht geschrieben wie möglich, das muss an dein Programm angepasst werden.

wenn die den Slot vermeiden möchtest kann man das auch in ein Lamda stecken.
Das wird auf jeden Fall aufgerufen, oder zumindest wird der compiler abbrechen mit einer Fehlermeldung:

void disconnectMySocket(){
   tcpSocket->disconnectFromHost();
   QTimer::singleShot(3000, this, [=]{
       if(tcpSocket->state != UnconnectedState){
           //Error Handling
       }
   });
}

[Galilio]

@J.Hilk
aber wenn ich so schreibe :

void disconnectMySocket(){
   tcpSocket->disconnectFromHost();
   QTimer::singleShot(3000, this, [=]{
qDebug() << "checkDisonnected";
       if(tcpSocket->state() != UnconnectedState){
           //Error Handling
       }
   });
}

dann muss er rein aber der tut es nicht.

Hier wird der SocketConnect bzw. SocketDisconnected emitted und das entsprechende Slot aufgerufen

	connect(GetTcpSocket(), &QTcpSocket::stateChanged, this, [=](QAbstractSocket::SocketState socketState) {
		if (socketState == QAbstractSocket::ConnectedState)
		{
			qDebug() << "Connected";
			emit SocketConnected();
		}
		if (socketState == QAbstractSocket::UnconnectedState)
		{
			qDebug() << "Disconnected";
			emit SocketDisconnected();
		}
	});

[J.Hilk]

@Galilio said in QThread richtig einsetzen?:

disconnectMySocket()

setze mal einen Breakpoint oder eine qDebug() line um zu schaun, ob disconnectMySocket() überhaupt aufgerufen wird.

[Galilio]

Das habe ich gemacht.

disconnectMySocket()

Dieses wird schon aufgerufen, aber

checkDisconnected()

wird ne aufgerufen.

[J.Hilk]

@Galilio mmh
#include <QTimer> ist gemacht? Clean Build durchgeführt? Eventuell ShadowBuild-Ordner löschen.

[Galilio]

@J.Hilk

@J.Hilk said in QThread richtig einsetzen?:

@Galilio mmh
#include <QTimer> ist gemacht? Clean Build durchgeführt? Eventuell ShadowBuild-Ordner löschen.
habe ich gemacht