Prüfen wann alle Threads beendet wurden

[endeffects]

Hallo,

ich habe leider ein kleines problem mit threads
die ich in einer schleife im hauptprogramm erzeuge,
jeder thread berechnet bestimmte werte und gibt diese
an das hauptprogramm zurück wo sie dann in einer
stringliste gespeichert werden, das funktioniert
auch alles wunderbar, nur leider weiß ich nun nicht genau
wie ich prüfen kann ob alle aktionen die in den x threads
y mal neu berechnet wurden beendet sind und ich somit
die stringliste lokal speichern kann

mein ansatz war nun folgender:

Delphi-Quellcode:

//schleife im hauptprogramm die x threads
//immer wieder mit y neuen daten versorgt

while {????????????????} do
  Application.ProcessMessages;

hat jemand dazu vielleicht eine idee?

[Meflin]

nimmst du den vcl thread oder den api thread?
du kannst bei letzterer methode die handles der threads abspeichern und überprüfen, ob es noch existiert oder nicht!

[endeffects]

das ist eine gute frage, auf die ich leider so gar keine
antwort habe, ich halte mich dabei immer an die beispiele von luckie

die threads erzeuge ich wie folgt:

Delphi-Quellcode:

    Setlength(ThreadArray, StrToInt(edtThreads.Text));
    while Mylist.Count-1 > 0 do
    begin
      for i := 0 to length(ThreadArray) - 1 do
      begin
        ThreadArray[i] := TMyThreads.Create(true);
        ThreadArray[i].FIndex := i;
        ThreadArray[i].FValue := Mylist[0];
        ThreadArray[i].Priority := tpIdle;
        ThreadArray[i].FreeOnTerminate := True;
        ThreadArray[i].Resume;
        Mylist.Delete(0);
      end;
    end;

welche der beiden methoden das nun darstellt weiß ich
eigentlich gar nicht :(

[Luckie]

waitformultipleobjects sollte die Lösung sein.

[endeffects]

hmm, kann ich leider nichts mit anfangen,
das forum bringt dazu leider auch kaum hilfreiche informationen

[Luckie]

Dann kuck in mein Threading Tutorial, da hab eich was dazu geschrieben und ein Demo gemacht.

[endeffects]

also erstmal danke euch beiden für eure hilfe :)

luckie ich hab mir gerade nocheinmal deine pdf dazu angeschaut
und da steht nun was von "->Demo: WaitForMultipleObjects",
bezieht sich das jetzt auf den nachfolgenden Beitrag in der pdf
oder gibt es da einen Source zum Download der bei mir nicht aktiv ist?

[endeffects]

naja ich geh mal nun davon aus das es dort keinen source gibt,
leider sind die angaben in deinem tutorial zu hoch für mich,
damit kann ich als nicht informatiker und einsteiger nicht viel anfangen,
auch bei google und in den bekannten delphi foren sind dazu nur brüchstücke
zu finden, aber keine beispiele :(

[Luckie]

Zitat:

Zitat von endeffects

luckie ich hab mir gerade nocheinmal deine pdf dazu angeschaut
und da steht nun was von "->Demo: WaitForMultipleObjects",

das steht immer am ende eines Kapitels, wenn es dazu Demos mit Source gibt im Archiv.

Zitat:

oder gibt es da einen Source zum Download der bei mir nicht aktiv ist?

Hm, wenn ich mir diese Seite http://tutorials.luckie-online.de so amgucke und speziell diese Zeile:

Zitat:

Klassen_in_Delphi.zip 10-Apr-2004 06:07 206k Klassen Tutorial für Delphi. Version 1.0 [PDF und Demos]

Dann erübrigt sich eigentlich jede Frage. :roll:

[Sprint]

Zitat:

Zitat von endeffects

nur leider weiß ich nun nicht genau
wie ich prüfen kann ob alle aktionen die in den x threads
y mal neu berechnet wurden beendet sind und ich somit
die stringliste lokal speichern kann

Speicher jeden erstellten Thread in eine TList Klasse. TThread hat ein Ereignis OnTerminate. Wenn's aufgerufen wird, lösche den Thread wieder aus der TList. Jetzt weißt du auch wenn keine Thread's mehr laufen.

[endeffects]

hallo,

ich hab das ganze nun mal mit WaitForMultipleObjects probiert,
allerdings scheint hier nicht wirklich gewartet zu werden =(

mein code ist folgender:

Delphi-Quellcode:

procedure TMainForm.LunchThreadds;
var i: integer; Mylist: TStringlist;
    hndlArray : Array of THandle;
begin
  ...
  //erstmal wird Mylist eingelesen und geschaut ob noch threads laufen
  ...
  Setlength(MyThreadArray, StrToInt(edtThreads.Text));
  Setlength(hndlArray, StrToInt(edtThreads.Text));

    while Mylist.Count-1 > 0 do
    begin
      for i := 0 to length(MyThreadArray) - 1 do
      begin
        MyThreadArray[i] := TMyThreads.Create(true);
        MyThreadArray[i].FIndex := i;
        MyThreadArray[i].FValue := Myylist[0];
        MyThreadArray[i].Priority := tpIdle;
        MyThreadArray[i].FreeOnTerminate := True;
        hndlArray[i] := MyThreadArray[i].Handle;
        MyThreadArray[i].Resume;
        Mylist.Delete(0);
      end;
      //die ersten threads durchlaufen und warten bis diese beendet sind
      //um dann die nächsten threads zu initialisieren
      WaitForMultipleObjects(StrToInt(edtThreads.Text), @hndlArray, True, 60000);
    end;
    Myylist.Free;

end;

jemand eine idee wo nun der denkfehler ist?

[endeffects]

ich hab folgendes tutorial genutzt:
http://www.delphicorner.f9.co.uk/articles/op1.htm

dort steht unter anderem:

Zitat:

Those couple of Windows API functions are called WaitForSingleObject and WaitForMultipleObjects. These two functions are used to wait for objects to enter a signaled state before they return. Okay, what's signaled mean anyway? ... Essentially, when an object is created in Windows, it is given a system assigned state property of sorts. While it is active or in use, it is said to be non-signaled. When it is available, it is said to be signaled.

ich hab das nun so verstanden das solange der thread arbeitet kein "signal" für diesen
thread gesetzt ist, das wäre dann also erst der fall wenn er abgearbeitet wurde
und genau darauf soll ja nun WaitForMultipleObjects warten :gruebel:

[endeffects]

also das problem, wie ich mir sagen lassen habe, lag am dynamischen
array das an die api funktion übergeben wird, folgender
code funktionier nun anscheinend:

Delphi-Quellcode:

procedure TMainForm.LunchThreads;
var 
i, hndlArraylength: integer; 
Mylist: TStringlist;
hndlArray : Array[0..63] of THandle;
begin
...
//prüfen ob threads laufen und stringliste laden
...
    Setlength(ThreadArray, 64));
    while Mylist.Count > 1 do
    begin
      for i := 0 to length(ThreadArray) - 1 do
      begin
        ThreadArray[i] := TMyThreads.Create(true);
        hndlArray[i] := ThreadArray[i].Handle;
        ThreadArray[i].FIndex := i;
        ThreadArray[i].FValue := Mylist[0];
        ThreadArray[i].Priority := tpIdle;
        ThreadArray[i].FreeOnTerminate := True;
        ThreadArray[i].Resume;
        if Mylist.Count > 1 then
          Mylist.Delete(0)
        else
          break;
      end;
      WaitForMultipleObjects(64, @hndlArray, True, 20000);
    end;
    Mylist.Free;