Мульти нить рабочий статус нить

Question

Я создаю мои темы, как

for (int i = 0; i < threadCount; i++) 
{ 
    Searcher src = new Searcher(i, this); 

    threads[i] = new Thread(new ThreadStart(src.getIpRange)); 
    threads[i].Name = string.Format(i.ToString()); 
    } 

    foreach (Thread t in threads) 
    { 
    t.Start(); 
    } 

с THREADCOUNT (= 100, 150, 255 и т.д ...), но я не могу узнать, сколько потоков работает. во время выполнения.

и я хочу контролировать, когда все потоки завершают работу. и дать мне сообщение типа «Все потоки мертвы, рабочие задания завершены ...» like backgroundWorker's RunWorkerCompleted event

Answer 1

Почему вы не можете использовать критическую секцию, защищенную одиночной переменной, для управления несколькими активными потоками? Функция Thread может модифицировать эту переменную (конечно, войдя в критический раздел).

Answer 2

Определение, когда все потоки закончены, просты.

for (int i = 0; i < threadCount; i++) 
{ 
    threads[i].Join(); 
} 

Console.WriteLine("All threads are done!"); 

Можете ли вы подробнее рассказать о своих других требованиях?

Answer 3

Вы можете проверить свойство ThreadState свойства Нити.

Возможно, лучше использовать методы асинхронного использования. Это дает вам объект WaitHandle, и вы можете использовать WaitHandle.WaitAll, чтобы дождаться завершения всех ваших методов асинхронного программирования.

Вот интро асинхронного программирования: http://msdn.microsoft.com/en-us/library/aa719598%28v=VS.71%29.aspx

Answer 4

Во-первых, я должен отметить, что создание 100, 150, 255 и т.д. темы, вероятно, не является хорошей идеей. Возможно, вам лучше использовать класс ThreadPool или Task (при использовании .NET 4.0). Кроме того, существуют два хорошо установленных метода для ожидания завершения всех потоков.

Вступить в цепочку.

Thread.Join блокирует до тех пор, пока целевая нить не закончится.

for (int i = 0; i < threadCount; i++) 
{ 
    Searcher src = new Searcher(i, this); 
    threads[i] = new Thread(new ThreadStart(src.getIpRange)); 
    threads[i].Name = string.Format(i.ToString()); 
} 

foreach (Thread t in threads) 
{ 
    t.Start(); 
} 

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

Использование CountdownEvent.

A CountdownEvent ожидает, пока его внутренний счет не достигнет нуля. Этот метод лучше подходит, если вы хотите использовать ThreadPool. Если вы не используете .NET 4.0, вы можете получить действительно простую реализацию на Joe Albahari's website.

var finished = new CountdownEvent(1); 

for (int i = 0; i < threadCount; i++) 
{ 
    finished.AddCount(); 
    Searcher src = new Searcher(i, this); 
    threads[i] = new Thread(
    () => 
    { 
     try 
     { 
      src.getIpRange(); 
     } 
     finally 
     { 
      finished.Signal(); 
     } 
    } 
    threads[i].Name = string.Format(i.ToString()); 
} 

foreach (Thread t in threads) 
{ 
    t.Start(); 
} 

finished.Signal(); 
finished.WaitOne(); 

Answer 5

Вы определенно хотите использовать Task класс для этого или понятие более высокого уровня, как Parallel.ForEach. С помощью класса Thread прямо очень болезненно.

Я недавно wrote a blog post Сравнение различных асинхронных подходов, перечисленных в списке от best (Task) до худшего (Thread).

Вот пример использования Task, демонстрируя то, что вы хотели сделать:

// Start all tasks 
var threads = new Task[threadCount]; 
for (int i = 0; i < threadCount; i++) 
{ 
    Searcher src = new Searcher(i, this); 
    threads[i] = Task.Factory.StartNew(src.getIpRange); 
} 

// How many are running right now? 
var runningCount = threads.Count(x => x.Status == TaskStatus.Running); 

// Register a callback when they have all completed (this does not block) 
Task.Factory.ContinueWhenAll(threads, MyCallback); 

Answer 6

Добавить делегат Searcher и передать его метод обратного вызова из основного потока, который каждый поток будет звонить, когда он закончится. Когда вы запускаете каждый поток, добавьте его в словарь, связанный с ManagedThreadId потока. Когда каждый поток заканчивается, обратный вызов удаляет поток из Словаря и проверяет, равен ли счет нулю.

 Dictionary<int, Thread> activeThreads = new Dictionary<int, Thread>();    

      for (int i = 0; i < threadCount; i++) 
      { 
       Searcher src = new Searcher(i, this); 
       src.Done = new SearcherDoneDelegate(ThreadDone); 
       threads[i] = new Thread(new ThreadStart(src.getIpRange)); 
       threads[i].Name = string.Format(i.ToString()); 
      } 

      foreach (Thread t in threads) 
      { 
       lock (activeThreads) 
       { 
        activeThreads.Add(t.ManagedThreadId, t); 
       } 
       t.Start(); 
      } 


     } 
     public void ThreadDone(int threadIdArg) 
     { 
      lock (activeThreads) 
      { 
       activeThreads.Remove(threadIdArg); 
       if (activeThreads.Count == 0) 
       { 
        // all done 
       } 
      } 
     } 

     public delegate void SearcherDoneDelegate(int threadIdArg); 
     public static object locker = new object(); 



     public class Searcher 
     { 
      public SearcherDoneDelegate Done { get; set; } 
      public void getIpRange() 
      { 
       Done(Thread.CurrentThread.ManagedThreadId); 
      } 
     } 

Если у вас есть больше потоков, чем вы хотите работать в одно время, поставить их в очередь и очистить их как старые нити закончить (используйте обратный вызов).