与 Threadpool C# 相关的问题。未能完成一个线程的执行

Question

我在下面有这个功能，我想了解这一点。另外，如果您有任何文件指向我。我从 msdn 阅读了有关 ManualResetEvent 和 ThreadPool 的信息

public void GetParametersThreadPool()
{
    var toProcess = 50;
    ManualResetEvent[] threadsActive = new ManualResetEvent[50];
    for (int handleIndex = 0; handleIndex < 50; ++handleIndex)
    {
        threadsActive[handleIndex] = new ManualResetEvent(false);

        ThreadPool.QueueUserWorkItem(new WaitCallback(delegate(object state)
            {
                string reportUrl = TeamFoundationTestConfig.TeamFoundationReportPath("TaskGroupStatus");
                ReportUri reportUri = ReportUri.Create(reportUrl);
                Log.Message(TraceEventType.Information, "ReportUri = {0}".InvariantFormat(reportUri.UriString));
                IList<Parameter> parameters = this.RemoteReportingServiceFactory.CreateReportParameterProvider().GetParameters(reportUri, SessionContext);
                Assert.IsNotNull(parameters, "Assertion failed: Parameters cannot be null. GetParameters failed");
                Assert.IsTrue(parameters.Count > 0, "Assertion failed: No parameters available on the report page. GetParameters failed. Count = {0}".InvariantFormat(parameters.Count));
                if (Interlocked.Decrement(ref toProcess) == 0)
                {
                    threadsActive[handleIndex].Set();
                }
            }), null);

        //// Wait for all the threads to complete before starting the next set of requests.
        threadsActive[handleIndex].WaitOne(); 
    }   
}

当我更新这行代码时：ManualResetEvent[] threadsActive = new ManualResetEvent[100];它给出了一个例外，说小于 64。

目前，当我运行此压力测试时，它挂在我进行日志记录的行上并且没有完成运行。我究竟做错了什么？

如果有更好的方法来做到这一点？也只是为了提供信息，我引用了 stackoverflow 中的另一个问题来自己创建这个函数

C# Execute Method (with Parameters) with ThreadPool

Answer 1

根据您的 .NET 版本，您可能希望使用 Task 和 Task.WaitAll(..)，它随 .NET 4 一起提供。您的工具包中还有 CountdownEvent。

使用任务通常很简单

var t = Task.Factory.StartNew(() => { your code });
t.Wait();

如果出于任何原因无法选择任务并行库，您可能需要考虑使用Semaphores（.NET 4 中的SemaphoreSlim）。

至于 64 位限制，这是操作系统强制执行的限制；可悲的是没有办法解决它。

Answer 2

按照建议，如果可以，您应该使用 Tasks。在它们可用之前，只需两个 WaitHandles 就可以做你想做的事。不是每个线程使用一个 WaitHandle，而是为所有线程使用一个 WaitHandle。等待线程计算 WaitHandle 发出信号的次数，并仅在收到所有信号后才继续。

Answer 3

WaitOne 阻塞当前线程，直到当前 WaitHandle 接收到信号，你正在编写多线程代码但这个方法实际上是同步方法

创建一个跟踪正在运行的任务数量的变量：

var toProcess = 50;

创建一个信号而不是数组

   ManualResetEvent signal = new ManualResetEvent(false);

for (int handleIndex = 0; handleIndex < 50; ++handleIndex)
    {


        ThreadPool.QueueUserWorkItem(new WaitCallback(delegate(object state)
            {
                string reportUrl = TeamFoundationTestConfig.TeamFoundationReportPath("TaskGroupStatus");
                ReportUri reportUri = ReportUri.Create(reportUrl);
                Log.Message(TraceEventType.Information, "ReportUri = {0}".InvariantFormat(reportUri.UriString));
                IList<Parameter> parameters = this.RemoteReportingServiceFactory.CreateReportParameterProvider().GetParameters(reportUri, SessionContext);
                Assert.IsNotNull(parameters, "Assertion failed: Parameters cannot be null. GetParameters failed");
                Assert.IsTrue(parameters.Count > 0, "Assertion failed: No parameters available on the report page. GetParameters failed. Count = {0}".InvariantFormat(parameters.Count));
                if (Interlocked.Decrement(ref toProcess) == 0)
                {
                    signal.Set();
                }
            }), null);


    }   

    signal.WaitOne();

不要将 signal.WaitOne() 放在 for 循环中，这会阻塞线程。

最后，如果您正在使用 .net 3.5 或更高版本，请考虑使用 Task