多線程工作線程狀態

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(); 
    } 

與經緯（= 100，150，255等...），但我不能學多少線程工作。執行時間。

我想要控制所有線程何時完成其工作。並給我一個消息，如「所有線程都死了，作業已完成...」 像backgroundWorker的RunWorkerCompleted事件

Answer 1

爲什麼不能使用臨界區保護單變量來控制多個活動線程？線程函數可以修改這個變量（當然已經進入臨界區）。

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比較各種異步方法，按從最佳（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

添加了代表對搜索器，並從你的主線程傳遞一個回調方法，當它完成每個線程將調用。在啓動每個線程時，將其添加到由線程的ManagedThreadId鍵入的字典中。當每個線程完成時，回調會從Dictionary中刪除該線程，並檢查計數是否爲零。

 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); 
      } 
     } 

如果你有多個線程比你想在同一時間運行，把它們放入一個隊列，並剝離掉相應的舊的線程結束（使用回調）。