OmniThreadLibrary: Was ist für meine Anforderung der richtige Weg? Welchen Container?

[GPRSNerd]

Hallo Codehunter,

ich habe interessiert mitgelesen, da ich ein ähnliches Problem mit dem Einlesen von Dateieigenschaften mit Parallelisierung lösen und beschleunigen möchte.
Ich habe deinen Code jetzt pro Forma mal in ein Testprogramm eingebaut und irgendwas stimmt mit der Parametrisierung des synchonize()-Aufrufs noch nicht:

[dcc32 Fehler] uMain.pas(247): E2250 Es gibt keine überladene Version von 'Synchronize', die man mit diesen Argumenten aufrufen kann

in der Codezeile:
    Synchronize(FOnComplete(Self, FFileName));

Hast du ne Idee? (dafür reicht mein Thread-Wissen nicht aus)

[TiGü]

Zitat von GPRSNerd:

[dcc32 Fehler] uMain.pas(247): E2250 Es gibt keine überladene Version von 'Synchronize', die man mit diesen Argumenten aufrufen kann

in der Codezeile:
    Synchronize(FOnComplete(Self, FFileName)); Hast du ne Idee? (dafür reicht mein Thread-Wissen nicht aus)

Wenn es in den Mainthread soll:
    Synchronize(nil, FOnComplete(Self, FFileName));

Wie machst du es sonst, wenn der Compiler nach dem Code eintippen meldet das in der Parameterliste ein Argument zuviel oder zuwenig ist?

[GPRSNerd]

Zitat von TiGü:

Wie machst du es sonst, wenn der Compiler nach dem Code eintippen meldet das in der Parameterliste ein Argument zuviel oder zuwenig ist?

Genau so vor meiner Anfrage gemacht und folgenden einzigen Parameter angezeigt bekommen:
AMethod
Nach dem Hinzufügen eines weiteren Parameters (zb nil) kommt immer noch die gleiche Fehlermeldung.
Es muss also eher an dem Parameter FOnComplete() liegen...

Synchronize(nil, FOnComplete(Self, FFileName));

[TiGü]

Zitat von GPRSNerd:

Zitat von TiGü:

Wie machst du es sonst, wenn der Compiler nach dem Code eintippen meldet das in der Parameterliste ein Argument zuviel oder zuwenig ist?

Genau so vor meiner Anfrage gemacht und folgenden einzigen Parameter angezeigt bekommen:
AMethod
Nach dem Hinzufügen eines weiteren Parameters (zb nil) kommt immer noch die gleiche Fehlermeldung.
Es muss also eher an dem Parameter FOnComplete() liegen...

Synchronize(nil, FOnComplete(Self, FFileName));

Abgesehen davon das der Cursor hinter der öffnen Klammer und Ctrl+Shift+Space vier Überladungen für Synchronize zeigt hast du natürlich recht.

Du musst den Code so anpassen:

Delphi-Quellcode:

procedure TMp3ReaderThread.DoComplete;
begin
  if Assigned(FOnComplete) then
  begin
    Synchronize(nil,
      procedure
      begin
        FOnComplete(Self, FFileName)
      end);
  end;
end;

Erklärung:
Es wird einer dieser Typen erwartet:

Delphi-Quellcode:

  TThreadMethod = procedure of object;
  TThreadProcedure = reference to procedure;

FOnComplete ist aber vom Typ TMp3ReaderComplete = procedure (Thread: TMp3ReaderThread; FileName: string) of object; , darum muss man da noch was drumstricken.

[GPRSNerd]

Zitat von TiGü:

Du musst den Code so anpassen:

Delphi-Quellcode:

procedure TMp3ReaderThread.DoComplete;
begin
  if Assigned(FOnComplete) then
  begin
    Synchronize(
      procedure
      begin
        FOnComplete(Self, FFileName)
      end);
  end;
end;

Compiled das bei dir? Ich sehe immer noch die gleiche Fehlermeldung.

[TiGü]

Zitat von GPRSNerd:

Zitat von TiGü:

Du musst den Code so anpassen:

Delphi-Quellcode:

procedure TMp3ReaderThread.DoComplete;
begin
  if Assigned(FOnComplete) then
  begin
    Synchronize(nil,
      procedure
      begin
        FOnComplete(Self, FFileName)
      end);
  end;
end;

Compiled das bei dir? Ich sehe immer noch die gleiche Fehlermeldung.

Ja.
Schreib mal TThread.Synchronize(nil,...

[freimatz]

Zitat von HolgerX:

Ist doch auch im Beispiel von Codehunter vorhanden:

je File ein Tmp3Data, gespeichert in DL: Tmp3DataList; als Liste...

Ja das ist in dem Beispiel vorhanden. Ich sah das nur als ein Beispiel an um die Parallelierierung zu zeigen. Die konkreten Typen halte ich für diskussionswürdig und ich meinte darum ging es dem Threadersteller.

Nun konkret: Vorgeschlagen wurde in Record "Tmp3Data "für einen Eintrag. Das finde ich schon mal nicht schlecht.
Dann aber schreibst du "als Liste". Im Vorschlag steht aber "Tmp3DataList = TDictionary<string, Tmp3Data>;". Das ist keine Liste. TDictionary verwende ich selber häufig, juergen könnte dann Probleme haben alle Einträge da rauszuholen. Es kommt drauf an wie da zugriffen werden soll.
Später gibt es dann noch doch eine Liste "Tmp3ThreadList = TList<Tmp3ReaderThread>".
Ich möchte hier nicht dem Codehunter an den "Karren fahren", es sollte ja ein Denkanstoss sein und scheint auch geholfen zu haben.

[GPRSNerd]

Zitat von TiGü:

Ja.
Schreib mal TThread.Synchronize(nil,...

Nö, immer noch gleiche Fehlermeldung.

[HolgerX]

Hmm..

Stell mal (bezogen auf das Beispiel) so um:

Delphi-Quellcode:

procedure Tmp3ReaderThread.Execute;
begin
  Lese_die_Datei_aus(FFileName, FData); // Speicher von FData liegt im Thread!
  
  Synchronize(DoComplete);
end;

procedure Tmp3ReaderThread.DoComplete;
begin
  if Assigned(FOnComplete) then
    FOnComplete(Self, FFileName);
end;

[GPRSNerd]

Jau, so compiled es jetzt!
Danke HolgerX.

Edit: Kleinere Korrekturen wären noch:
1. Der Konstruktor für die ThreadListe ist parameterlos: TL := Tmp3ThreadList.Create;
2. Das Auswählen des Records der DateiListe geht nicht mit Pointer, sondern (vermutlich) mit der Dereferenzierung: if DL.TryGetValue(Filename, Data^) then