需要帮助理解 .net ThreadPool

Question

我试图了解 ThreadPool 的作用，我有这个 .NET 示例：

class Program
{
    static void Main()
    {
        int c = 2;

        // Use AutoResetEvent for thread management

        AutoResetEvent[] arr = new AutoResetEvent[50];

        for (int i = 0; i < arr.Length; ++i)
        {
            arr[i] = new AutoResetEvent(false);
        }

        // Set the number of minimum threads
        ThreadPool.SetMinThreads(c, 4);

        // Enqueue 50 work items that run the code in this delegate function
        for (int i = 0; i < arr.Length; i++)
        {
            ThreadPool.QueueUserWorkItem(delegate(object o)
            {
                Thread.Sleep(100);
                arr[(int)o].Set(); // Signals completion

            }, i);
        }

        // Wait for all tasks to complete
        WaitHandle.WaitAll(arr);
    }
}

这会以 2 个一组 (int c) 的形式运行 50 个“任务”，直到它们全部完成吗？或者我不明白它的真正作用。

Answer 1

如果您有时间，我真的建议您阅读以下内容：

http://www.albahari.com /threading/

这是一本出色的读物，它奠定了从基本线程到并行编程的基础和工作方式。我建议您在尝试修改线程池代码之前先基本掌握前两章！ :)

Answer 2

通过设置最小线程数，您要求 .NET 运行时做的唯一一件事就是为线程池分配至少 2 个线程。您并不是要求它将自身限制为 2 个。

因此，无法保证您的程序将使用多少个线程。这取决于您的系统和许多其他因素。

我做了一个简单的测试（对程序进行了微小的更改，以跟踪进入 sleep 调用的同时线程），一次运行最大为 4 个，另一次运行为 3 个，另一个运行为 7 个，另一个运行为 10 个，等等。

你真的不应该需要更改线程池大小。

你想实现什么目标？

Answer 3

来自 SetMinThreads 的 MSDN 文档：

当需求较低时，实际数量
线程池线程数可能会低于
最小值。

因此，您指定的值并不能保证 2 个工作线程将处理排队的项目。它可能是 1 个工作线程（因为您在循环中对它们进行排队，因此它可能会在下一个工作线程排队之前完成），或者它可以根据系统资源和必须完成的工作量使用更多工作线程。

如果您确实想了解发生了什么，请查看 Process Monitor。您可以监视进程的线程创建并跟踪它们何时创建、销毁等。这将真正帮助您了解应用程序（和底层框架）正在做什么。

希望这有帮助。

Answer 4

背景：.NET 线程池管理线程的常规方法可能很麻烦。它可以很好地限制由资源争用引起的问题，但这样做是以牺牲线程创建速度为代价的。为了提高线程池中工作线程的性能，设计者允许使用一种机制，允许在不经过队列过程的情况下创建一定数量的线程。

SetMinThreads() 指定应简单地“按需”创建的线程数，即简单地启动，而不检查当前线程计数或排队以缓慢节流。

将会发生的情况是，框架将立即创建前两个线程，就像您手动设置它们并使用 Thread.Start 启动它们一样。除此之外，直到当前的MaxThreads计数，框架将开始对工作线程的请求进行排队，并以指定的时间间隔（默认为250ms，我相信这也可以配置）启动它们，以避免资源冲突。这样做的原因是，如果您想象启动一个访问资源的线程，进行一些计算，然后将结果写入其他地方的循环行为，您可以看到 5 个线程几乎同时启动将如何导致尝试获取资源时发生僵局到第一个资源。在 MaxThreads 阈值处，队列停止；在完成之前不会创建新线程。

因此，根据代码的性质，将安排 50 个单独的工作任务，但并非所有 50 个任务都会同时运行；运行时将允许两个立即启动，然后等待 250 毫秒或直到一个结束，然后再开始下一个。由于线程将在 250 毫秒内执行并终止，因此您不太可能看到同时执行 2 个以上的工作线程；创建第三个线程之前的等待永远不会发生，因为“不受限制”的工作线程将首先释放，并且正在等待的线程在其等待时间到期之前被启动，然后时钟将与下一个线程一起重置。