Hi,

ich habe eine Klasse die bei Bedarf einen Thread zur Bearbeitung erstellt.
Falls der Thread sich beendet oder der Destructor der Klasse erreicht wird soll,
der Thread beendet und freigegeben werden.
Allerdings endet das ganze bei mir darin das in Endlos auf das Ende des Threads warte.

Code der Komponente :

zusammenfalten · markieren

Delphi-Quellcode:

constructor TTestComp.Create(AOwner: TComponent);
begin
  inherited;

  // ...

  // Thread-Instanz
  FCon2SvrThd := Nil;
end;

destructor TTestComp.Destroy;
begin
  // cleanup everything
  // ...

  // End Thread if running
  if FCon2SvrThd <> Nil then begin
    FCon2SvrThd.Terminate;
    While FCon2SvrThd <> Nil do begin
      sleep(250);
    end;
  end;
end;

procedure TTestComp.OnConnection2SvrThreadEnded(Sender: TObject);
begin
  FCon2SvrThd := Nil;
end;

procedure TTestComp.StartThread;
begin
  FCon2SvrThd := TTwConnection2SvrThread.Create(self,FTcpCon);
  FCon2SvrThd.OnThreadEnd := OnConnection2SvrThreadEnded;
  FCon2SvrThd.Resume;
end;

Code des Threads :

zusammenfalten · markieren

Delphi-Quellcode:

constructor TTwConnection2SvrThread.Create(ParentComp : TTestComp; TcpCon: TIdTcpClient);
begin
  inherited Create(true);
  FreeOnTerminate := true;
  OnTerminate := CleanUp;
  fParent := ParentComp;
  fTcpCon := TcpCon;
  fSendCS := TCriticalSection.Create;
  FOnThreadEnd := Nil;
end;

procedure TTwConnection2SvrThread.Cleanup(Sender: TObject);
begin
  Disconnect;
  FreeAndNil(fSendCS);
  if Assigned(FOnThreadEnd) then
    Synchronize(syncOnEnded);
end;

procedure TTwConnection2SvrThread.syncOnEnded;
begin
  FOnThreadEnd(self);
end;

procedure TTwConnection2SvrThread.Execute;
begin
  While (not Terminated) and (fTcpCon.Connected) do begin
    // do some work ...
  end;
end;

function TTwConnection2SvrThread.Disconnect: Boolean;
begin
  if fTcpCon.Connected then begin
    try
      // Send Logout Command
      fTcpCon.WriteLn('QUIT');
      fTcpCon.Disconnect;
    except {} end;
  end;
  result := not fTcpCon.Connected;
end;

Wo liegt der Hund begraben ? Jemand ne Idee ?

Danke und Gruß Data

Hallo Data,

wenn du den Thread terminierst, dann wird dadurch die Instanz nicht automatisch NIL. Du kannst mit der Methode WaitFor auf die Beendigung der Execute-Methode des Threads warten. Danach musst du den Thread selber freigeben (soweit ich weiß).

Schönen Tag von Dale

Bei meiner HID-Komponente setze ich FreeOnTerminate auf False und stoppe den Thread so:

markieren

Delphi-Quellcode:

procedure TJvHidDevice.StopThread;
begin
  if Assigned(FDataThread) then
  begin
    FDataThread.Terminate;
    FDataThread.WaitFor;
    FDataThread.Free;
    FDataThread := nil;
  end;
end;

@Dale:

Wenn alles sauber läuft, dann sollte beim Beenden des Threads(OnTerminate) die procedure Cleanup aufrufen.
In dieser werden die Objekte freigeben und das Event OnThreadEnded wird ausgelöst.
In diesem Event(oben unter OnConnection2SvrThreadEnded zu sehen) wird die Variable auf Nil gesetzt.
Diese Vorgehensweise klappt sonst bei meinen Threads einwandfrei.


@Robert :

Die Variante funktioniert das hatte ich auch schon getestet, allerdings kann ich diese Variante bei mir nicht verwenden, weil sich der Thread auch von alleine beenden soll, wenn die Tcp-Verbindung nicht mehr connected ist.
D.H. auch in diesem Fall muss der Thread sich beenden und alle Objekte wieder freigeben und in meiner Klasse soll die Thread Variable dann auf Nil gesetzt werden.


@All:
Die oben genannte Vorgehensweise funktioniert normalerweise.
Das Problem ist das Sleep, normalerweise verwende ich das zusammen mit Application.processMessages.
Da ich mich hier aber innerhalb der Komponente befinde und keinen Zugriff auf Application habe, scheint
das Sleep die restliche Ausführung zu blockieren.

Bin gerade am überlegen ob ich im "cleanup" des Threads einen bestimmen Event auslöse, auf denn ich im Destructor der Komponente warte. Was meint Ihr ?

Gruß Data

Zitat von DataCool:

Wenn alles sauber läuft, dann sollte beim Beenden des Threads(OnTerminate) die procedure Cleanup aufrufen.
In dieser werden die Objekte freigeben und das Event OnThreadEnded wird ausgelöst.
In diesem Event(oben unter OnConnection2SvrThreadEnded zu sehen) wird die Variable auf Nil gesetzt.
Diese Vorgehensweise klappt sonst bei meinen Threads einwandfrei.

In der Prozedur Cleanup kann ich nicht sehen das dein Thread freigegeben wird. Lediglich die Variable FCon2SvrThd wird NIL gesetzt.

Dale

Zitat von DataCool:

Die Variante funktioniert das hatte ich auch schon getestet, allerdings kann ich diese Variante bei mir nicht verwenden, weil sich der Thread auch von alleine beenden soll, wenn die Tcp-Verbindung nicht mehr connected ist.
D.H. auch in diesem Fall muss der Thread sich beenden und alle Objekte wieder freigeben und in meiner Klasse soll die Thread Variable dann auf Nil gesetzt werden.

Na dann faellt das "FDataThread.Free;" einfach weg waehrend FreeOnTerminate halt True bleibt.
Zusatzlich weist du FDataThread.OnTerminate beim Start eine Methode zu und dort machst du "FDataThread := nil;".
Im Destruktor deiner Komponente kann man nun einfach StopThread aufrufen.

@Dale:

Der Thread selber steht auf FreeOnTerminate := true;
Im Cleanup werden nur die im Thread erzeugten Objekte freigegeben.
Der Thread gibt sich nach Ende selber frei.
Das FCon2SvrThd := NIL gesetzt wird, ist nur dazu da, das ich innerhalb der Komponente immer
prüfen kann ob der Thread existiert oder nicht.

Gruß Data

zusammenfalten · markieren

Delphi-Quellcode:

constructor TTwConnection2SvrThread.Create(ParentComp: TTestComp; TcpCon: TIdTcpClient);
begin
  inherited Create(True);
  FreeOnTerminate := True;
  fParent := ParentComp;
  fTcpCon := TcpCon;
end;

procedure TTwConnection2SvrThread.Execute;
begin
  fSendCS := TCriticalSection.Create;

  while (not Terminated) and fTcpCon.Connected do
  begin
    // do some work ...
  end;

  if fTcpCon.Connected then
    try
      // Send Logout Command
      fTcpCon.WriteLn('QUIT');
      fTcpCon.Disconnect;
    except
    end;

  fSendCS.Free;
end;

So sollte es gehen. Der Thread raeumt am Ende des Execute einfach selber auf.
Sollte fSendCS nur im Execute gebraucht werden, so kann es durchaus auch eine lokale Variable von Execute sein.

@Robert:

Habs jetzt mal mit Deinem Vorschlag versucht, hat zur folgende das beim beenden/ Freigeben der Komponente meine IDE im Nirvana hängt

Das OnTerminate Event wurde noch ausgelöst, der von mir überschriebene Destructor des Threads wird aber nie aufgerufen.

Gruß Data

@Robert:

Ist es nicht etwas unelegant im Execute aufzuräumen ?!
Das habe ich bis jetzt immer vermieden.

Gehen würde das auf die Weise schon, denke ich.

Gruß Data