多线程工作线程状态

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

如果你有多个线程比你想在同一时间运行，把它们放入一个队列，并剥离掉相应的旧的线程结束（使用回调）。