TThread - Sleep

[xZise]

Moin,
wie startest du den Thread?

MfG
Fabian

[JoltinJoe]

Zitat von ChrisE:

Hallo,

aber der Thread legt sich schon selber schlafen?

Also innerhalb seiner Execute-Methode merkt er irgendwann selber, dass er sich schlafen legen kann und ruft selber Sleep auf.

Delphi-Quellcode:

procedure TMeinThread.Exececute;
begin
  while not Terminated do
  begin
    // mach ganz viel
  
    if SchlafbedingungErfuellt then 
      Sleep(1000);
  end;
//....
end;

Greez, Chris

Ja, genauso habe ich es !

Zitat von xZise:

Moin,
wie startest du den Thread?

MfG
Fabian

Habe jetzt keinen SourceCode zur Hand aber ich glaube es war "MyThread.Resume" .. werde heute Nachmittag das Problem nochmal genauer analysieren und ggf. eine neue Beschreibung posten

bYe

[JoltinJoe]

Delphi-Quellcode:

//High Condition
procedure TSendThread.HighCondition;
begin
  FetchedCount:=FetchedCount+1;
end;

//Reset Condition
procedure TSendThread.ResetCondition;
begin
  FetchedCount:=0;
end;

procedure TSendThread.Execute;
begin
  while not Terminated do
  begin
    Synchronize(HighCondition);
    if FetchedCount>ConditionLimit then
      begin
        Sleep(Delay);
        Synchronize(ResetCondition);
      end;
      ....
      MEINE_ANDEREN_PROCEDUREN
      ....
  end;
end;

FetchedCount und ConditionLimit sind globale Variablen. FetchedCount wird nur im Synchronize beschrieben, ConditionLimit wird nur gelesen!

Grundlage: Ich habe immer 100 Threads. Wenn ich das Limit auf 50 setze dann sollen 50 Threads MEINE_ANDEREN_PROCEDUREN ausführen und 50 sollen erstmal schlafen und dann MEINE_ANDEREN_PROCEDUREN ausführen !

[xZise]

Wann wird denn CheckCondition aufgerufen? Eventuell ist dort synchronisiert.

Und was macht der Mainthread, nachdem du es laufen lässt?

MfG
Fabian

[JoltinJoe]

Das hat sich ein Fehler beim kopieren eingeschlichen... "CheckCondition" kann außer Acht gelassen werden, habe es auch im Vor-Thread entfernt...

Nach dem Start der Threads schläft das ganze Programm sofort und danach führen alle Threads "MEINE_ANDEREN_PROCEDUREN" aus.



Edit:

Wenn ich die 100 Aufgaben anstatt auf 100 Threads nur auf 1 Thread lege dann klappt es. 50 werden ausgeführt, dann wird geschlafen und dann kommen die anderen 50.

Wenn ich die 100 Aufgaben auf 100 Threads lege dann wird erst geschlafen und dann werden alle 100 Threads mit einem mal abgearbeitet.

[JoltinJoe]

Delphi-Quellcode:

procedure TMyOwnThread.HighCondition;
begin
  FetchedCount:=FetchedCount+1;
end;

procedure TMyOwnThread.ResetCondition;
begin
  FetchedCount:=0;
end;

procedure TMyOwnThread.WriteResults;
begin
  Form1.Memo1.Lines.Add('blaa');
end;

procedure TMyOwnThread.Execute;
begin
  while not Terminated do
  begin
    Synchronize(HighCondition);
    if FetchedCount>50 then
    begin
      Sleep(10000);
      Synchronize(ResetCondition);
    end;
    Synchronize(WriteResults);
  end;
end;

procedure TForm1.Button1Click(Sender: TObject);
var
  Thread: TMyOwnThread;
  ThreadCount: Integer;
begin
  ThreadCount:=100;
  for i:=0 to ThreadCount-1 do
    begin
      Thread:=TMyOwnThread.Create(True);
      Thread.FreeOnTerminate := True;
      Thread.Resume;
    end;
end;

Habe hier nochmal den kompletten Code zur Veranschaulichung gekürzt ..

[xZise]

Moin,
Und so funktioniert er nicht? Weil ich kann da keine Probleme erkennen. Wobei natürlich 100 Threads via Sync schon heftig ist.

Wäre da nicht eventuell eine TCriticalSection was?

MfG
Fabian