Asegúrese de que todas las discusiones salieron

Question

En una aplicación de forma triunfo, tengo una serie de roscas que se inicia así:

bool stop = false; 
Thread[] threads = new Thread[10]; 

for (int i = 0; i < threads.Length; i++) 
    threads[i] = new Thread(new ThreadStart(Job)); 

// How to make sure all threads have exited, when the boolean = false 

void Job() 
{ 
    while (!stop) 
     // Do something 
} 

Ahora bien, si el usuario pulsa STOP, el valor booleano para stop se define como true, por lo los hilos salen del método Job uno tras otro. ¿Cómo puedo asegurarme de que se salgan todos los hilos?

NOTA: Necesito el enhebrado tradicional para mi caso y TaskLibrary no encaja en mi situación.

Answer 1

¿Ha pensado en el uso de BackgroundWorkers en su lugar? Usted dijo "hilos tradicionales" ... No estoy muy seguro de lo que quiere decir, así que no sé si esta es una propuesta válida o no, pero aquí está de todos modos en caso de que Join() no resuelva su problema

BackgroundWorker[] workers = new BackgroundWorker[10]; 
bool allThreadsDone = false; 

// initialize BackgroundWorkers 
for (int i = 0; i < 10; i++) 
{ 
     workers[i] = new BackgroundWorker(); 
     workers[i].WorkerSupportsCancellation = true; 
     workers[i].RunWorkerCompleted += 
      new RunWorkerCompletedEventHandler(worker_RunWorkerCompleted); 
     workers[i].DoWork += new DoWorkEventHandler(AlgorithmsUI_DoWork); 
     workers[i].RunWorkerAsync(); 
} 

// thread entry point..DoWork is fired when RunWorkerAsync is called 
void AlgorithmsUI_DoWork(object sender, DoWorkEventArgs e) 
{ 
     while (!stop) 
      // do something   
} 

// this event is fired when the BGW finishes execution 
private void worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
{ 
    bool threadsStillRunning = false; 
    foreach (BackgroundWorker worker in workers) 
    { 
     if (worker.IsBusy) 
     { 
      threadsStillRunning = true; 
      break; 
     } 
    } 
    if (!threadsStillRunning) 
     allThreadsDone = true; 
} 

protected override OnFormClosing(FormClosingEventArgs e) 
{ 
     if (!allThreadsDone) 
     { 
       e.Cancel = true; 
       MessageaBox.Show("Threads still running!"); 
     } 
} 

Esto debería evitar que su formulario se cierre si todavía hay subprocesos en ejecución.

Answer 2

Utilice el método Join para comprobar si se han detenido todos los hilos.

foreach (var t in threads) 
{ 
    t.Join(); 
} 

Answer 3

no estoy seguro si esto es lo que está buscando, pero aquí es una solución simple he utilizado de nuevo en .NET 3.0 para asegurarse de que un gran número de determinista, pero las discusiones se había completado antes de continuar:

Global:

AutoResetEvent threadPoolComplete = new AutoResetEvent(false); 
static int numThreadsToRun; 

Como activar los hilos:

numThreadsToRun = [number of threads]; 
[start your threads]; 
threadPoolComplete.WaitOne(); 

al final del código de cada hilo:

if (Interlocked.Decrement(ref numThreadsToRun) == 0) 
{ 
    threadPoolComplete.Set(); 
}