20

我正在运行一个多线程循环：

protected ParallelOptions parallelOptions = new ParallelOptions();

parallelOptions.MaxDegreeOfParallelism = 2;
Parallel.ForEach(items, parallelOptions, item =>
{
// Loop code here
});

我想在并行循环执行期间更改 parallelOptions.MaxDegreeOfParallelism 以减少或增加线程数。

parallelOptions.MaxDegreeOfParallelism = 5;

它似乎没有增加线程。有没有人有任何想法？

4

2 回答 2

6

甚至尝试这样做的问题是这是一个难题。首先，您如何可靠地观察 CPU 和磁盘利用率？不频繁地对 CPU 进行采样将无法准确了解实际情况，并且对磁盘利用率进行采样更加困难。其次，您的任务的粒度是多少，以及您多久可以快速实际更改正在运行的数量。第三，随着时间的推移，事情会迅速变化，因此您需要对观察结果进行某种过滤。第四，理想的线程数将取决于代码实际运行的 CPU。第五，如果你分配了太多线程，你将在它们之间颠簸而不是做有用的工作。

有关.NET 中的线程池如何处理决定使用多少线程的复杂任务的讨论，请参见http://msdn.microsoft.com/en-us/magazine/ff960958.aspx 。

您还可以使用反射器并查看 TPL 用于分配线程并避免不必要的上下文切换的代码 - 它很复杂，甚至没有考虑磁盘访问！

相反，您可以尝试在较低优先级的线程上执行任务（创建自己的TaskScheduler运行低于正常优先级的线程实际上很容易）。这至少可以确保您可以在不影响系统其余部分的情况下运行 100% 的 CPU。弄乱线程优先级本身就充满了问题，但如果这是一个纯粹的后台任务，它可能很简单并且可能会有所帮助。

但是，当其他应用程序被一个贪婪的应用程序所困扰时，磁盘利用率通常是真正的罪魁祸首。Windows 可以轻松地在应用程序之间公平地分配 CPU，但是当涉及到相对较慢的磁盘访问时，则完全是另一回事了。与其尝试动态调整运行的线程数，不如简单地限制应用程序，使其不会过于频繁地访问磁盘。您可以在不更改活动线程数的情况下做到这一点。

您还可以将SetPriorityClass其视为一种通知操作系统您的进程不如系统上运行的其他应用程序重要的方法，请参阅如何提高进程的 I/O 优先级？了解更多信息。但这假设您的整个过程不那么重要，而不仅仅是这一部分。

于 2010-09-14T06:05:31.253 回答
3

我不希望在您调用ForEach. 据我了解，ForEach将确定它可以创建多少个线程，创建多少个分区，并创建线程来对这些分区进行操作。没有一点可以说，“哦，等等，他改变了我们的资源分配，让我重新分区数组并重新分配线程。”

于 2010-09-13T23:35:28.837 回答