warten bis Thread keine Jobs mehr hat.....

[Thomas83]

Servus,

habe da einen Thread. In einer Stringliste speicher ich die jobs ab.
Wenn ich meine Anwendung beende, möchte ich noch warten bis alle Jobs verarbeitet wurden.
also bis count = 0 ist. Nur irgend wie funzt dat nicht so kanz... (funzt nur mit application.processmessage)

hier mal ein wenig code

Delphi-Quellcode:

  TSqlThread = class(TThread)
  private
    fSQLTimer : TTimer;
    Procedure OnSqlTimer(Sender : TObject);
  public
    Function IsEmpty : Boolean;
  protected
    Procedure Execute; override;
  end;


function TSqlThread.IsEmpty: Boolean;
begin
  result := fSqlList.Count-1 <= 0;
end;

procedure TSqlThread.OnSqlTimer(Sender: TObject);
begin
  if fSqlList.Count-1 >= 0 then
  begin
    fcs.Enter;
    try
      fDB.SQLQuery(fSqlList[0]);
      fSqlList.Delete(0);
    finally
      fcs.Leave;
    end;
    if Assigned(fOnWriteSQL) then
      Synchronize(fOnWriteSQL);
  end;
end;

procedure TSqlThread.Execute;
var
  MSG : TMsg;
begin
  inherited;

  while (  GetMessage(msg, 0, 0, 0) ) do
    DispatchMessage(msg);
end;

// aus meiner main rufe ich bei einem thread diese methode auf. 
begin
  if fsql <> nil then
    while not fsql.IsEmpty do
    begin
      sleep(100);

      //muss ich machen weil sonst OnSqlTimer nicht aufgerufen wird..
      application.ProcessMessages; //was aber nicht sein darf
    end;
end;

Wenn ich es ohne application.ProcessMessages mache friert meine main auch ein.
Bzw. der Timer vom SQLThread wird nicht aufgerufen......

Mache ich was falsch?

[guidok]

Wieso eigentlich Count-1?

Delphi-Quellcode:

function TSqlThread.IsEmpty: Boolean; 
begin 
  result := fSqlList.Count = 0; 
end;

Sonst würde ja eine Liste, die noch ein Element enthält auch schon als leer interpretiert werden.

[sirius]

Wo erstellst du denn den Timer?

[Thomas83]

Zitat:

Zitat von sirius

Wo erstellst du denn den Timer?

im Thread bei Create

Delphi-Quellcode:

constructor TSqlThread.Create(Host,User,Pass,Db : String);
begin
  inherited Create(false);

  fSQLTimer := TTimer.Create(nil);
  fSQLTimer.Interval := 100;     
  fSQLTimer.OnTimer := OnSqlTimer;
  fSQLTimer.Enabled := true;
end;

[sirius]

Damit ist er im MainThread. Du must ihn in execute erstellen.

btw: Wenn Dein Thread außer dem Timer nichts beinhaltet bzw. den Rest synchronisiert, bringt dir der Timer nichts. du musst alles in den Thread nehmen oder du lässt es mit dem Thread.

[Thomas83]

aso wuste nicht wenn ich ein object in der create eines Threads anlege das es dann im mainthread ist.....

thx

[Thomas83]

habe 4 Threadklassen ..... da sehe ich gerade das ich alles in den threads bei create erstelle....
da muss ich das mal ummodeln.....

[sirius]

Jep, der Constructor ist außerhalb des Threads, der Destructor innerhalb

[Thomas83]

hmmm das stellt mich jetzt aber vor einem problem.

In der Create des Threads habe ich meine objekte die ich brauche angelegt. (Timer, weiter Thread objekte, server socket etc)
Anschließend wenn ich den Thread in der main erstellt habe, muss ich auf variabeln zugreifen die in der create erstellt wurden..... da jetzt aber alles in der execute erstellt wird, wie soll ich das dann lösen.....

Delphi-Quellcode:

  //alles wird in TThreadServer.Create erstellt
  fServer := TThreadServer.Create('log.text');
  fServer.OnProcCommand := OnGetDataFromAgent;      //<- wie soll ich das dann machen
  fServer.OnClientConnect := OnClientConnect;
  fServer.OnClientDisconnect := OnClientDisconnect;
  fServer.GoOnline(12345);
  fServer.Resume;

einer eine idee

[Thomas83]

ok habe es jetzt mit einer methode gemacht. Diese wird vom Server aufgerufen wenn alles erstellt wurde.....

hmmm auf einmal läuft alles schneller und ohne fehler.......

vielen dank!!!