Wie kann man wissen, ob der gesamte Thread-Pool-Thread bereits mit seinen Aufgaben erledigt ist?

Question

Ich habe diese Anwendung, die alle Ordner in einem bestimmten Verzeichnis recurse und nach PDF suchen. Wenn eine PDF-Datei gefunden wird, zählt die Anwendung ihre Seiten mit ITextSharp. Ich tat dies, indem ich einen Thread benutzte, um alle Ordner für pdf rekursiv zu scannen, und wenn dann PDF gefunden wird, wird es in den Thread-Pool eingereiht. Der Code sieht wie folgt aus:

//spawn a thread to handle the processing of pdf on each folder. 
       var th = new Thread(() => 
       { 
        pdfDirectories = Directory.GetDirectories(pdfPath); 
        processDir(pdfDirectories); 
       }); 
       th.Start(); 



private void processDir(string[] dirs) 
     { 
      foreach (var dir in dirs) 
      { 
       pdfFiles = Directory.GetFiles(dir, "*.pdf"); 
       processFiles(pdfFiles); 

       string[] newdir = Directory.GetDirectories(dir); 
       processDir(newdir); 
      } 
     } 



private void processFiles(string[] files) 
     { 
      foreach (var pdf in files) 
      { 
       ThreadPoolHelper.QueueUserWorkItem(
        new { path = pdf }, 
        (data) => { processPDF(data.path); } 
        ); 
      } 
     } 

Mein Problem ist, wie kann ich wissen, dass der Thread des Thread-Pool hat alle Warteschlange Elemente beendet die Verarbeitung, so dass ich den Benutzer sagen kann, dass die Anwendung mit ihrer beabsichtigten Aufgabe erledigt ist?

Answer 1

Im Allgemeinen würde ich so etwas tun, indem ich eine Zählervariable habe. Fügen Sie für jedes Arbeitselement, das Sie in die Warteschlange einreihen, einen Wert ThreadPool zur Zählervariable hinzu. Dann, wenn es verarbeitet wird, würden Sie die Zählervariable verringern.

Stellen Sie sicher, dass Sie das Inkrementieren und Dekrementieren über die Methoden der Klasse Interlocked durchführen, da dies sicherstellt, dass Dinge auf thread-sichere Weise ausgeführt werden.

Sobald die Zähler Hits Null Sie Flag könnte, dass die Aufgaben abgeschlossen sind eine ManualResetEvent

Verwendung Wenn Sie Zugriff auf .NET 4 haben, dann können Sie die neue CountdownEvent Klasse verwenden, um eine ähnliche Sache zu tun.

Answer 2

1) Wie kann man wissen, ob alle Threads beendet sind?

Sie werden die Themen zu tun, ihre eigene Check-in/Check-out lassen müssen, indem Sie den Code zwischen Bracketing:

Interlocked.Increment(ref jobCounter); 
// your code 
Interlocked.Decrement(ref jobCounter); 

Wenn dies zu Ihren anonym Delegierten vermasselt viel verwenden Sie dann nur Wrapper-Methoden. Wahrscheinlich müssen Sie auch die Ausnahmebehandlung hinzufügen.

Der verzahnte Ansatz trotzt immer noch dem Problem, auf 0 zu warten, eine Schleife mit Sleep() ist eine schwache, aber in diesem Fall praktikable Lösung.

2) Sie starten Threads in einem rekursiven Tree Walker. Sei vorsichtig, du schaffst wahrscheinlich zu viel von ihnen und das wird die Leistung beeinträchtigen.