线程池 - WaitAll 64 句柄限制

Question

我试图绕过 .net 3.5 施加的 wait64 句柄限制

我看到了这个线程： WaitHandle.WaitAll 64 句柄限制的解决方法？

所以我理解总体思路，但我遇到了困难，因为我没有使用委托，而是

基本上正在处理这个示例： http://msdn.microsoft.com/en- us/library/3dasc8as%28VS.80%29.aspx

此链接 http://www.switchonthecode.com/tutorials/csharp-tutorial-using-the-threadpool 类似，但跟踪任务的 int 变量又是一个成员变量。

在上面的示例中，我将在哪里传递 threadCount 整数？ 我是否将其作为对象传递到回调方法中？我认为我在回调方法和通过引用传递方面遇到了问题。

谢谢斯蒂芬，

这个链接对我来说并不完全清楚。

让我发布我的代码来帮助自己澄清：

for (int flows = 0; flows < NumFlows; flows++)
{
ResetEvents[flows] = new ManualResetEvent(false);
ICalculator calculator = new NewtonRaphson(Perturbations);
Calculators[flows] = calculator;
ThreadPool.QueueUserWorkItem(calculator.ThreadPoolCallback, flows);
}
resetEvent.WaitOne();

我将在哪里传递 threadCount 变量。我认为它需要在calculator.ThreadPoolCallback中递减？

Answer 1

您不应使用多个等待句柄来等待ThreadPool 中多个工作项的完成。它不仅不可扩展，您最终还会遇到 WaitHandle.WaitAll 方法施加的 64 个句柄限制（正如您已经完成的那样）。在这种情况下使用的正确模式是计数等待句柄。在 .NET 3.5 的响应式扩展下载中可以通过CountdownEvent 类。

var finished = new CountdownEvent(1);
for (int flows = 0; flows < NumFlows; flows++) 
{ 
  finished.AddCount();
  ICalculator calculator = new NewtonRaphson(Perturbations); 
  Calculators[flows] = calculator; 
  ThreadPool.QueueUserWorkItem(
    (state) =>
    {
      try 
      { 
        calculator.ThreadPoolCallback(state); 
      }
      finally 
      { 
        finished.Signal(); 
      }
    }, flows);
} 
finished.Signal();
finished.Wait();

Answer 2

匿名方法可能是最简单的：

int threadCount = 0;
for (int flows = 0; flows < NumFlows; flows++)
{
    ICalculator calculator = new NewtonRaphson(Perturbations);
    Calculators[flows] = calculator;

    // We're about to queue a new piece of work:
    //    make a note of the fact a new work item is starting
    Interlocked.Increment(ref threadCount);
    ThreadPool.QueueUserWorkItem(
        delegate
        {
            calculator.ThreadPoolCallback(flows);

            // We've finished this piece of work...
            if (Interlocked.Decrement(ref threadCount) == 0)
            {
                // ...and we're the last one.
                // Signal back to the main thread.
                resetEvent.Set();
            }
        }, null);
}
resetEvent.WaitOne();