Wie ermitteln Sie, ob untergeordnete Threads abgeschlossen wurden

Question

Ich verwende mehrere Threads in meiner Anwendung mit while (true) Schleife und jetzt möchte ich aus Schleife beenden, wenn alle aktiven Threads ihre Arbeit abschließen.

Answer 1

Sie können Process.GetCurrentProcess(). Threads.Count verwenden.

Answer 2

Es gibt verschiedene Ansätze hier, aber utlimately die meisten von ihnen kommen zu Ihrem Wechsel des ausgeführten Threads etwas zu tun, wann immer sie (Erfolg oder über Ausnahme, die Sie nicht wollen, zu tun sowieso) verlassen. Ein einfacher Ansatz könnte darin bestehen, Interlock.Decrement zu verwenden, um einen Zähler zu reduzieren - und wenn er Null ist (oder -ve, was wahrscheinlich einen Fehler bedeutet), ein ManualResetEvent oder Monitor.Pulse ein Objekt freizugeben; In beiden Fällen würde der Original Thread auf dieses Objekt warten. Eine Anzahl solcher Ansätze sind discussed here.

Natürlich könnte es einfacher sein, die TPL-Bits in 4.0 zu betrachten, die hier eine Menge neuer Optionen bieten (nicht zuletzt Dinge wie Parallel.For in PLINQ).

Wenn Sie eine synchronisierte Arbeitswarteschlange verwenden, ist es möglicherweise auch möglich, diese Warteschlange so einzurichten, dass sie sich selbst schließt und abwartet, bis die Warteschlange leer ist. Die Annahme, hier zu sein, dass Ihre Arbeitsthreads wie etwas tun:

T workItem; 
while(queue.TryDequeue(out workItem)) { // this may block until either something 
    ProcessWorkItem(workItem);   // todo, or the queue is terminated 
} 
// queue has closed - exit the thread 

in diesem Fall, sobald die Warteschlange all leer ist Ihre Worker-Threads bereits im Prozess des Selbstmordes sein sollten.

Answer 3

Angenommen, Sie haben eine Liste der Threads selbst, hier sind zwei Ansätze.

Lösung, um die erste:

Verwenden Thread.Join() mit einem Zeitspanne Parametern mit jedem Thread wiederum synch auf. Der Rückgabewert sagt Ihnen, ob der Thread beendet ist oder nicht.

Lösung der zweite:

prüfen Thread.IsAlive() zu sehen, ob der Faden noch läuft. Stellen Sie in beiden Fällen sicher, dass Ihr Hauptthread Prozessorzeit für die ausgeführten Threads liefert, andernfalls wird Ihre Warteschleife am meisten/die gesamte CPU verbrauchen und Ihre Worker-Threads verhungern.

Answer 4

Sie können Thread.Join() verwenden. Die Join-Methode blockiert den aufrufenden Thread, bis der Thread (derjenige, auf dem die Join-Methode aufgerufen wird) beendet wird.

Wenn Sie also eine Thread-Liste haben, können Sie durchschleifen und Join für jeden Thread aufrufen. Die Schleife wird nur beendet, wenn alle Threads leer sind. So etwas wie das:

for(int i = 0 ;i < childThreadList.Count; i++) 
{ 
    childThreadList[i].Join(); 
} 
///...The following code will execute when all threads in the list have been terminated.../// 

Answer 5

Ich finde, dass die Verwendung der Join() -Methode der sauberste Weg ist. Ich benutze häufig mehrere Threads, und jeder Thread lädt typischerweise Daten aus verschiedenen Datenquellen (Informix, Oracle und SQL zur gleichen Zeit). Eine einfache Schleife, wie oben erwähnt, ruft Join() für jedes Thread-Objekt auf ein einfaches List-Objekt) funktioniert !!!

Carlos Merighe.

Answer 6

Ich ziehe eine HashSet von Themen mit:

// create a HashSet of heavy tasks (threads) to run 
HashSet<Thread> Threadlist = new HashSet<Thread>(); 
Threadlist.Add(new Thread(() => SomeHeavyTask1())); 
Threadlist.Add(new Thread(() => SomeHeavyTask2())); 
Threadlist.Add(new Thread(() => SomeHeavyTask3())); 

// start the threads 
foreach (Thread T in Threadlist) 
    T.Start(); 

// these will execute sequential 
NotSoHeavyTask1(); 
NotSoHeavyTask2(); 
NotSoHeavyTask3(); 

// loop through tasks to see if they are still active, and join them to main thread 
foreach (Thread T in Threadlist) 
    if (T.ThreadState == ThreadState.Running) 
    T.Join(); 

// finally this code will execute 
MoreTasksToDo();