![]() |
TObjectList-Einträge auf meherere Threads aufteilen
Ich habe eine TObjectList die eine Dateiliste repräsentiert.
Ich möchte basierend auf dieser Liste gerne Threads erstellen. Beispielzahlen: 1000 Dateien, 8 Threads. Jeder Thread verarbeitet 125 Dateien. Wie stellt man das am besten an? Ich meine nicht rechnerisch sondern das Erstellen der Threads, ohne temporäre Zwischenlisten. Edit: es besteht schon eine Prozedur, der ich einfach nur eine Liste übergeben kann und diese Prozedur erzeugt dann daraus einen Thread. Es geht hier nur darum, wie ich das mit der Aufteilung am besten anstelle. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
..anderer Ansatz.
- eine WorkerPool mit 8 Threads - jeder Thread nimmt sich ein Object aus der ObjectListe - wenn der Thread fertig ist, nimmt er sich das nächste Object. Die Liste müsste dann für den Entnahmevorgang gesperrt werden. Grüße Klaus |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Mach mit Zwischenlisten und Datenübergabe beim Erstellen der Threads, alles andere macht nur unnötig Aufwand und Heckmeck.
Wobei Threads und "Dateiliste" schon wieder so ne Sache für sich ist. Schreib- und Lesezugriffe sind ja am Ende durch die Hardware limitiert. Da muss man ein paar Messungen machen, wo da der Tradeoff ist. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
Zitat:
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
Naja, man wird ja noch TObjectList.Count durch 8 teilen können und dann diese Anzahl Entries auf die 8 anderen Lists verteilen können...
Blöd nur, das das ganze nicht so funktionieren wird, wie du dir das vorstellst. Nicht jeder Thread hat gleich große Files, somit sind nicht alle gleichzeitig fertig - im Gegenteil. Außerdem sind File-I/O-Operationen ohnehin sequentiell, eine Festplatte ist bereits mit 2 zeitgleichen Zugriffen völlig am Ende, bei SSD dauert das nur ein wenig länger. Ergo: Anderes Konzept. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
TParallel.For hat eine Überladung mit einem Stride Parameter. Damit ließe sich das im genannten Beispiel so lösen:
Delphi-Quellcode:
Das Stride = 125 sorgt bewirkt, dass ein WorkerThread 125 Indizes hintereinander abarbeitet. Damit wird die For-Schleife auf bis zu acht Threads aufgeteilt.
TParallel.For(125, 1, 1000,
procedure(Index: Integer) begin { Bearbeite Listeneintrag[Index] } end ); |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Für die Verteilung auf die Threads hat Uwe ja schon eine Lösung genannt. Da reicht es die Indizes irgendwie zu verteilen, egal ob auf dem Weg oder anders, da die Liste bei reinen Lesezugriffen threadsicher ist.
Zitat:
Denn wenn du einfach nur auf 8 Threads verteilst, wird das ganze eher noch langsamer als vorher, wenn die Verarbeitung einer Datei nicht gerade ein Vielfaches der Lesezeit von der Festplatte benötigt. Bei SSDs könnte man auch beim Lesen der Dateien parallele Zugriffe versuchen, aber auch nicht unbeschränkt viele, da kommt es auf die Größe der Dateien an wo hier Optimierungspotential ist. Man könnte auch mit MMFs arbeiten um Windows so eine Optimierung der Zugriffe zu ermöglichen, wenn es sich um große Dateien handelt. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
Ich kann euch ja mal meinen absolut scheuslichen Code zeigen. Dann versteht ihr, warum ich hier nachfrage. An der Sache mit den Threads kann ich nichts ändern. Es geht nur um die Aufteilung / Zuweisung in die Threads/Erstellung der Threads
Delphi-Quellcode:
MaxThreadCount := 8;
FilesPerThread := MainProcessFileList_ObjectList.Count div MaxThreadCount; SetLength(TmpFileLists_ObjectList, MaxThreadCount); for i := 0 to MaxThreadCount - 1 do begin try if MainProcessFileList_ObjectList.Count >= FilesPerThread then begin TmpFileLists_ObjectList[i] := TObjectList<TFileEntry_CopyProcess>.Create; TmpFileLists_ObjectList[i].OwnsObjects := False; TmpFileLists_ObjectList[i].Clear; iCnt := FilesPerThread; for j := 0 to iCnt - 1 do begin TmpFileLists_ObjectList[i].Insert(j, MainProcessFileList_ObjectList.Items[j]); end; for j := iCnt - 1 downto 0 do begin MainProcessFileList_ObjectList.Delete(j); end; // Thread erstellen if TmpFileLists_ObjectList[i].Count > 0 then begin createCopyThread(TmpFileLists_ObjectList[i], ..., ...); // ERSTELLUNG DES THREADS MIT DEM REST DER IN TmpFileLists_ObjectList DRIN IST end; end else Break; except // Mache dies und das im Fall des Falles end; end; // for // Wenn noch Dateien "übrig" bleiben (z.B. bei 130 Dateien, 8 Threads bleiben 2 Dateien "übrig") if (MainProcessFileList_ObjectList.Count > 0) then begin // Thread erstellen createCopyThread(TmpFileLists_ObjectList[i], ..., ...); // ERSTELLUNG DES THREADS MIT DEM REST DER IN TmpFileLists_ObjectList DRIN IST for i := MainProcessFileList_ObjectList.Count - 1 downto 0 do begin MainProcessFileList_ObjectList.Items[i].Free; MainProcessFileList_ObjectList.Delete(i); end; end; Zitat:
Low = einfach 1 und High = Anzahl der Dateien? In meinem Fall also?
Delphi-Quellcode:
Dieses Parallel.For verstehe ich noch nicht so richtig. Wie packe ich die Listeneinträge jetzt in einen Thread? Also bei 125 Dateien 16 Dateien pro Thread?
TParallel.For(MainProcessFileList_ObjectList.Count div MaxThreadCount, 1, MainProcessFileList_ObjectList.Count,
procedure(Index: Integer) begin // Bearbeite Listeneintrag[Index] end); createCopyThread() darf ich in diesem Fall nur 8x aufrufen. createCopyThread erwartet als letzten Parameter "IsLastThreads: Boolean". Ich muss also auch irgendwie rausfinden, welcher der letzte Thread ist. Wie mache ich das alles mit TParallel.For? Kann man meinen Code ansonsten irgendwie verbessern: |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zeig uns doch mal das Execute von diesen "CopyThread".
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
Wofür ist das Execute wichtig? Das ist doch egal. Es geht -nur- um die Aufteilung der ObjectList in mehrere ObjectListen, damit ich daraus Threads befüllen kann.
TFor.Parallel ist gut, aber da fehlen mir ein paar Dinge. Ich muss da drin u.a. eine Zählervariable haben. Das Execute ist egal und tut nichts zur Sache. Den Code davon ändere ich ohnehin nicht. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
Zitat:
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
Ich habe das TFor.Parallel noch immer nicht richtig verstanden.
Wenn ich 20 Dateien habe und 2 Threads daraus machen möchte, wie genau zählt Schleife 1 und wie Schleife 2? Fängt Schleife 1 an zu zählen bei Index 0 an bis 9 und Schleife bei 10 von 19 ? Weil ich brauche in irgendeiner Art und Weise eine Schleifenvariable die ich in jeder dieser For-Dinger nutzen kann. Ich muss wissen wann "0" ist. Bei 0 erstelle ich eine temporäre ObjectList. Bei Index = MaxForFürDiesenDurchgang erzeuge ich den Thread. Eine andere Idee. Jetzt gerade ist es so, dass Unit A die ObjectList in mehrere aufteilt und daraus Daten für Unit B (ein Thread) baut. 1000 Dateien, 8 Threads sollen gebaut werden, jeder Thread 125 Dateien. Wenn ich das mit der neuen Herangehensweise mache, gäbe es nur noch EINEN Thread, der intern TParallel.For nutzt. Die Aufteilung und Verwaltung macht dann also TParallel.For. Hat das irgendwelche Vorteile? |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
Das TParallel.For behandelt alle Listeneinträge von 0 bis Count - 1 (Danke Sebastian), wobei die Arbeit an einem Eintrag innerhalb der anonymen Methode erfolgt. Stell dir das erstmal wie bei einer ganz normalen Schleife vor:
Delphi-Quellcode:
Willst du das parallel mit 8 Threads erledigen, schreibst du das so:
for I := 0 to MainProcessFileList_ObjectList.Count - 1 do
begin { Tue was mit MainProcessFileList_ObjectList[I] } end;
Delphi-Quellcode:
Das
MaxThreadCount := 8;
FilesPerThread := MainProcessFileList_ObjectList.Count div MaxThreadCount; TParallel.For(FilesPerThread, 0, MainProcessFileList_ObjectList.Count - 1, procedure(Index: Integer) begin { Tue was mit MainProcessFileList_ObjectList[Index] } end);
Delphi-Quellcode:
versteckt sich aktuell noch irgendwo in der Execute Methode deines Threads. Insofern ist das eben nicht egal. Vielleicht passiert innerhalb dieser Methode ja auch etwas, dass diesen Ansatz unmöglich macht oder eine Änderung dessen erfordert, aber das wissen wir nicht.
{ Tue was mit MainProcessFileList_ObjectList[I] }
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
Im Execute meines Threads passiert davor und danach eine ganze Menge. Vor- und Nachbereitungen von Daten. I/O-mäßig passiert da sonst nix mehr.
Kann ich das TParallel.For auch IN den Thread verlagern? Weil mit dem TParallel.For im Hauptthread wird die GUI sonst geblockt. Dafür wären nur wenige Änderungen notwendig und diesen Code der in temporäre Listen auslagert könnte ich komplett löschen. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
Die Idee mit, das TParallel.For ins Execute auszulagern kam, weil TiGü nach dem Execute gefragt hat.
Ich habe das zum Testen mal ausgelagert. 11 Dateien ergibt Zitat:
Delphi-Quellcode:
TParallel.For(FFileList.Count div 4, 1, FFileList.Count - 1,
10 Dateien werden verarbeitet, die 11. leider nicht. Gibt es hier einen Trick, dass TParallel.For im letzten Durchgang den "Rest" mitnimmt, der bei der Rechnung nicht aufgeht? Ist egal ich bin dumm! Die Zählung muss natürlich bei 0 beginnen, nicht bei 1. Danke an alle. Ich habe jetzt eine Mischung aus allen Vorschlägen. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
Du machst dir schon vorher Gedanken über die Lastverteilung. Wenn du die Aufgaben (Dateien) in eine Blocking Collection packst, dann können die Threads sich selbst bedienen, je nachdem ob einer mal schneller oder langsamer ist. Du kannst auch Threads abhängig von der CPU erstellen (lassen) - also nicht gleich auf x festlegen. ___ von 0 auf 100 - Omni Thread Lib (OTL) - Multithreading einfach in Delphi ![]() |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
Zitat:
Erst dann erzeuge ich einen Thread, der mit der ObjectList (lesend) arbeitet. |
AW: TObjectList-Einträge auf meherere Threads aufteilen
Zitat:
|
AW: TObjectList-Einträge auf meherere Threads aufteilen
![]() Das ist keine Liste von Threads (TObjectList ist ja eine Liste von Objekten), sondern es ist eine TList mit eingebauter Threadabsicherung. (also eigentlich eine TThreadsaveList) Wieso Manuell aufteilen? Lass die Einträge sich doch einfach dynamisch vereilen. (wer Zeit hat, der macht es) * alle Aufgaben/Dateien in eine TThreadList * dann X Threads starten (so viele, wie gewünscht) * jeder Thread holt sich via ThreadList.Pop einwas raus * * verarbeitet das * * und wiederholt dann seine Schleife so oft, bis nichts mehr in der ThreadList drin ist * dann kann er sich beenden (oder wartet, bis wieder was rein kommt, und arbeitet weiter) Vorteile * die ThreadList ist schon thread-sicher (hat die CriticalSection/Monitor bereits einbebaut) * und wenn nicht alle Aufgaben gleich lange dauern, dann geht es auch schneller |
Alle Zeitangaben in WEZ +1. Es ist jetzt 00:16 Uhr. |
Powered by vBulletin® Copyright ©2000 - 2025, Jelsoft Enterprises Ltd.
LinkBacks Enabled by vBSEO © 2011, Crawlability, Inc.
Delphi-PRAXiS (c) 2002 - 2023 by Daniel R. Wolf, 2024 by Thomas Breitkreuz