Mehrere Threads auf einmal beenden

[walter_b]

Hallo zusammen

Bei mir im Programm laufen 4 Threads gleichzeitig und ich würde gerne, sobald in einem Thread gewisse Umstände eingetroffen sind, alle 4 Threads auf einmal beenden. Mit "EndThread" wird leider nur der Thread beendet, in welchem ich dies auch reinschreibe, aber Einfluss von diesem aus auf die anderen, kann ich nicht nehmen, bzw. ich weiss nicht, wies geht. Weiss jemand von euch, wie ich aus einem Thread heraus andere Threads (laufen alle als Execute) beenden kann?

vielen Dank.

[rotfc]

Eine globale Variable, die alle kennen, auf true oder false setzen?

[walter_b]

Das wäre die, ich sage mal, unschöne Variante. Das ganze geht ziemlich um Geschwindigkeit und wird auch oft ausgeführt. Wenn dann da plötzlich 20 Millionen Mal ein if überprüft wird, dann ist das nicht besonders gelungen. Gäbe es noch eine andere Möglichkeit, die direkt zu beenden?

[sx2008]

Zunächst mal sollte man die Klasse TThread benützen und sich damit das Leben einfacher machen.
(Also nicht direkt Threadfunktionen aus der Windows API aufrufen)
Dann muss man sich alle Thread-Objekte in einer Liste (TObjectList) merken, denn sonst kann man die Threads nicht beenden.
Um einen Thread zu beenden ruft man einfach threadobject.Terminate auf.
Der Thread muss aber kooperieren, sonst läuft er einfach weiter.
Beispiel:

Delphi-Quellcode:

procedure TMyThread.Execute;
var i:Integer;
begin
  for i := 1 to 1000000 do
  begin
    if Terminated then Exit;  // <==
    BerechneWas(i);
  end;
end;

Wichtig ist die markierte Zeile - der Thread überprüft, ob er beendet wurde und falls ja verlässt er einfach die Excute-Methode.

Ein Thread A kann nicht einfach einen Thread B beenden, denn er hat keinerlei Information über B.
Es ist aber relativ einfach, dass ein Thread alle anderen Threads (einschliesslich sich selber) beendet.
Dazu muss es auf dem Formular eine Methode geben, die für alle Threadobjekte in der Liste die Terminate-Methode aufruft.
Der Aufruf muss "synchronisiert" werden:

Delphi-Quellcode:

  Synchronize(meinForm.TerminateAllThreads);

[walter_b]

Also das mit dem TThread habe ich benutzt. Aber wenn ich da jetzt nochmal ein if reinpacken muss, schlägt sich das schon ziemlich auch die Zeit nieder, wenn es einige Male aufgerufen wird, nicht?

Und wie genau meinst du das mit dem "Terminate"?

Meine Definition:

Delphi-Quellcode:

TMyOwnThread1 = class(TThread)
  protected
    procedure Execute; override;
  end;

  TMyOwnThread2 = class(TThread)
  protected
    procedure Execute; override;
  end;

  TMyOwnThread3 = class(TThread)
  protected
    procedure Execute; override;
  end;

  TMyOwnThread4 = class(TThread)
  protected
    procedure Execute; override;
  end;

Könnte ich dann einfach reinschreiben: "TMyOwnThread4.Terminate"?

Du hast "meinForm" benutzt... was mache ich, wenn ich eine Consolenapplikation benutze?

[rotfc]

@walter_b: Sind das nicht wieder 100.000/20 Millionen if-Abfragen?

Die ABER nur den einen Thread terminieren - wovon die anderen Threads aber nichts mitbekommen?

Frag ja nur...

[walter_b]

Ich weiss nicht genau, was du wissen willst, aber es ist so: Die 4 Threads gehen alle die selbe Berechnung durch, starten jedoch an anderen Punkten. Jeder Thread macht 5 Mio Berechnungen. Sobald einer das richtige Resultat gefunden hat, sollen die 4 Threads beendet werden. Wenn ich jetzt nach jeder Berechnung in allen 4 Threads ein If reinbaue, dann gibt das bei mir nach Adam Riese 20 Mio mal ^^

[sx2008]

Zitat:

Zitat von walter_b

Also das mit dem TThread habe ich benutzt. Aber wenn ich da jetzt nochmal ein if reinpacken muss, schlägt sich das schon ziemlich auch die Zeit nieder, wenn es einige Male aufgerufen wird, nicht?

Nein, wenn man es geschickt anstellt, ist der Zeitverlust fast unmessbar.
Vielleicht hast du mehrere geschachtelte Schleifen (for, while..do, repeat..until);
man muss die Abfrage nicht in die innerste Schleife setzen.
Ausserem in das Property Terminated nur eine Variable und die Abfrage benötigt nur wenige Taktzyklen.

Zitat:

Zitat von walter_b

Und wie genau meinst du das mit dem "Terminate"?

Delphi-Quellcode:

// hier ein Beispiel
var
  th4 : TMyOwnThread4;
  retcode : Integer;

  th4 := TMyOwnThread4.Create(True);  // Threadobjekt erzeugen, aber Thread noch nicht starten
  th4.MaxIterations := 100000;  // bevor der Thread losrennt, setzen wir noch ein eigenes Property
  th4.Resume;  // jetzt rennt der Thread los
  Sleep(10000);   // 10s warten
  th4.Terminate;  // dem Thread sagen, da jetzt "Sense" ist 
  retcode := th4.WaitFor;  // warten, bis der Thread wirklich beendet ist
  th4.Free;   // Threadobjekt freigeben

Zitat:

Zitat von walter_b

Könnte ich dann einfach reinschreiben: "TMyOwnThread4.Terminate"?
Du hast "meinForm" benutzt... was mache ich, wenn ich eine Consolenapplikation benutze?

Man benötigt ein Objekt der Klasse TMyOwnThread4 um die Terminate-Methode aufrufen zu können.
Threads und Konsolenprogramme sind in gewisser Weise ein Widerspruch und nicht zu empfehlen.
Was macht ein Konsolenprogramm?
Es nimmt Inputparameter entgegen, führt eine bestimmte Ausgabe aus und liefert einen Output.
Man benötigt keine Threads um die Aufgabe auszuführen.
Man kann Threads in Konsolenprogrammen benützen, sollte dann aber gut überlegen,
ob es nicht besser wäre ein "normales" Programm daraus zu machen.