TList mit Record füllen und an weitere TList übergeben

[dGeek]

Ihr werdet mich für den Code HASSEN (poste ich gleich aber erst eine Frage).

Ich habe mittlerweile herausgefunden, dass wenn ich nach der Procedur die den Thread erstellt eine Showmessage mache, alles korrekt abläuft. Scheint also ein sehr suspektes Zeitproblem zu sein.

geht deine Vermutung in diese Richtung?

[Aviator]

Zitat von dGeek:

geht deine Vermutung in diese Richtung?

Nein eher nicht. Es kann natürlich sein, das ich mit meiner Vermutung total falsch liege.

Zitat von dGeek:

Ihr werdet mich für den Code HASSEN

Jeder hat doch mal klein angefangen. Als ich das erste Mal mit ObjectLists gearbeitet hatte, ging auch nicht alles direkt. Heute will ich sie nicht mehr missen. Da hakte es auch an der ein oder anderen Stelle. Und die Formatierung des SourceCodes kannst du ja schnell durch die IDE machen lassen falls du das meinst.

[dGeek]

Ich habe alles Unwichtige rausgenommen und ein bisschen Pseudo-Kommentiert, damit man es HALBWEGS nachvollziehen kann
Threads sind nicht das Problem. Denn als ich das alles ohne ObjectList hatte, lief es einwandfrei.

Delphi-Quellcode:

// aProcessFileList_ObjectList enthält "10" Instanzen von TFileEntry
// aProcessFileList_ObjectList.OwnsObjects ist "False"
// aGlobalVars.iMaxCopyThreadCount ist "2"
// iFilesPerThread ist "5"

// Der ganze StringList-Kram ist nur zum TEST da

{*
 Dateien z.B.:
 
 - Datei0.txt
 - Datei1.txt
 - Datei2.txt
 - Datei3.txt
 - Datei4.txt
 - Datei5.txt
 - Datei6.txt
 - Datei7.txt
 - Datei8.txt
 - Datei9.txt
*}
 
aTmpFileList_ObjectList := TObjectList.Create;
aTmpFileList_ObjectList.OwnsObjects := False;
 
try
 for i := 0 to aGlobalVars.iMaxCopyThreadCount - 1 do
  begin
   Application.ProcessMessages;

   try
    if aProcessFileList_ObjectList.Count >= iFilesPerThread then
     begin
      // Liste wird geleert, damit nicht die alten Daten drin sind / SEIN SOLLTEN
      aTmpFileList_ObjectList.Clear;

      iCnt := iFilesPerThread;

      if aProcessFileList_ObjectList.Count - iCnt = 1 then
       Inc(iCnt);

      {*
        Erster  Durchgang: aTmpFileList_ObjectList bekommt "Datei0" bis "Datei4"
        Zweiter Durchgang: aTmpFileList_ObjectList bekommt "Datei5" bis "Datei9"
      *}
      for j := 0 to iCnt - 1 do
       aTmpFileList_ObjectList.Insert(j, aProcessFileList_ObjectList.Items[j]);

      sl := TStringList.Create;
      try
       {*
         Erster  Durchgang: aus aProcessFileList_ObjectList wird "Datei4" bis "Datei0" gelöscht
         Zweiter Durchgang: aus aProcessFileList_ObjectList wird "Datei9" bis "Datei5" gelöscht
       *}
       for j := iCnt - 1 downto 0 do
        begin
         aProcessFileList_ObjectList.Delete(j);
         sl.Add(TFileEntry(aTmpFileList_ObjectList.Items[j]).sSourceDirItem);
        end;

       // StringList-TEST - was ist in der Liste? In eine Datei abspeichern!
       sl.SaveToFile(ExtractFilePath(ParamStr(0)) + '__DELETE' + IntToStr(i) + '.txt');
      finally
       sl.Free;
      end;

      
      sl := TStringList.Create;
      try
       for j := 0 to aTmpFileList_ObjectList.Count - 1 do
        begin
         sl.Add(TFileEntry(aTmpFileList_ObjectList.Items[j]).sSourceDirItem);
        end;
        
       // StringList-TEST - was ist in der Liste? In eine Datei abspeichern!
       sl.SaveToFile(ExtractFilePath(ParamStr(0)) + '__' + IntToStr(i) + '.txt');
      finally
       sl.Free;
      end;

      if aTmpFileList_ObjectList.Count > 0 then
       begin
        {*
          Erster  Durchgang: Thread1 arbeitet "Datei0" bis "Datei4" ab
          Zweiter Durchgang: Thread2 arbeitet "Datei5" bis "Datei9" ab
        *}
        createCopyThread(aTmpFileList_ObjectList);
       end;
     end
    else
     break;
   except
    // ...
   end;
  end;

  // Wenn noch RESTE in der originalen ObjectList sind, dann erstelle damit einen seperaten Thread
  // Das ist z.B. der Fall, wenn 11 Dateien verarbeitet werden müssten. Die letzte (elfte) Datei würde hier in einen Thread gepackt werden
  if aProcessFileList_ObjectList.Count > 0 then
   begin
    createCopyThread(aProcessFileList_ObjectList);
   end;
  end;
finally
 aTmpFileList_ObjectList.Free;
end;

////////////////////////////////////////////////////////////////////////////////

procedure createCopyThread(FaFileList: TObjectList);
 var
  aCopyThread: TCopyThread;
 begin
  aCopyThread := TCopyThread.Create;

  aCopyThread.aFileList := FaFileList;
 end;

////////////////////////////////////////////////////////////////////////////////

type
 TCopyThread = class(TThread)
 private
  { Private-Deklarationen }
  FaFileList: TObjectList;
 protected
  procedure Execute; override;
 public
  { Public-Deklarationen }
  constructor Create;
  procedure Finish(Sender: TObject);

  property aFileList: TObjectList read FaFileList write FaFileList;
 end;

[DeddyH]

Zitat von dGeek:

Threads sind nicht das Problem.

Bist Du da ganz sicher? Du musst bedenken, dass der Code, der nach dem Erzeugen der Threads kommt, auch weiter ausgeführt wird, während die Threads noch laufen.

[dGeek]

Zitat von DeddyH:

Zitat von dGeek:

Threads sind nicht das Problem.

Bist Du da ganz sicher? Du musst bedenken, dass der Code, der nach dem Erzeugen der Threads kommt, auch weiter ausgeführt wird, während die Threads noch laufen.

Das weiß ich, keine Sorge. Deswegen benutze ich Threads ja

Aber ich übergebe dem Thread doch die ObjectList. Hat der dann nicht eine vollkommen eigene Kopie davon? Und wenn ich dann das Original (aTmpFileList_ObjectList) ändere, dürfte das die Daten im Thread doch nicht ändern.

[bra]

Zitat von dGeek:

Aber ich übergebe dem Thread doch die ObjectList. Hat der dann nicht eine vollkommen eigene Kopie davon? Und wenn ich dann das Original (aTmpFileList_ObjectList) ändere, dürfte das die Daten im Thread doch nicht ändern.

Klassen werden als Pointer übergeben, d.h. dein Thread arbeite mit derselben Liste, wie im Hauptthread. Wenn du die Liste also im Thread oder im Hauptthread veränderst, wirkt sich das überall aus.
Du könntest den Aufruf beim Thread als const definieren, dann wird eine Kopie deiner Liste erstellt:

Delphi-Quellcode:

procedure createCopyThread(const FaFileList: TObjectList);
...

[DeddyH]

Wieso sollte da eine Kopie erstellt werden?

[Aviator]

Zitat von bra:

Zitat von dGeek:

Aber ich übergebe dem Thread doch die ObjectList. Hat der dann nicht eine vollkommen eigene Kopie davon? Und wenn ich dann das Original (aTmpFileList_ObjectList) ändere, dürfte das die Daten im Thread doch nicht ändern.

Klassen werden als Pointer übergeben, d.h. dein Thread arbeite mit derselben Liste, wie im Hauptthread.

Genau das war auch meine Vermutung @dGeek. Du übergibst dem Thread eine Instanz einer ObjectList und verwendest diese dann weiter. Du müsstest dir pro Durchlauf deiner äußersten Schleife eine neue Instanz der ObjectList erstellen. Die kannst du dann auch bedenkenlos nach Beendigung des Threads im Thread freigeben lassen.

Des Weiteren könntest du auch folgenden machen:

aTmpFileList_ObjectList := TObjectList<TFileEntry>.Create(False); .

Das hat 2 Vorteile:

• Du brauchst nicht mehr zu casten, sondern bekommst beim Auslesen deiner ObjectList direkt ein Object vom Typ TFileEntry zurück
• Der False Parameter bewirkt, dass OwnsObjects beim Erzeugen deiner Liste auf False gesetzt wird (somit entfällt die zweite Zeile)

[stahli]

Dein Problem ist offenbar nicht mehr die TList sondern die Synchronisierung von Threads.

In dem Fall wäre das dann auch ein Thema für einen neuen "Thread".

Hier gab es kürzlich eine nette Zusammenfassung: https://www.youtube.com/watch?v=Jhcpgjs1uPA

[Mavarik]

Zitat von dGeek:

Ihr werdet mich für den Code HASSEN

Hassen - nein - nur viel zu umständlich - aber da Du in Deinem Profil nicht angegeben hast, welche Delphi Version Du nutzt, gehe ich davon aus, diese ist kleine XE6, oder?