c# – 更改了Parallel.ForEach行为？

我有一个报表构建类,它使用并行处理来构建一批800个左右的报表.

直到昨天它使用以下代码正常工作：

Parallel.ForEach(reports,report => { this.Build(report); });

注意：出于调试目的,我要从测试项目中编写的测试中排除代码.

昨天,它开始失败了.使用资源监视器进行的一些挖掘表明,与qtagent32.exe(测试运行器)相关的线程数不断增加,最终导致进程失败.看起来突然变得阻塞了.

我能够通过对代码进行一些小改动来解决问题：

Parallel.ForEach(reports,new ParallelOptions { MaxDegreeOfParallelism = 4 },report => { this.Build(report); });

但我仍然想知道改变了什么？

解决方法

只需要1个元素就可以慢一点.如果它确实是“相同的代码”,即相同的报告,它可能是数据库.多一点数据可以使查询变慢.

TPL位于ThreadPool的顶部,ThreadPool将慢慢添加新的Threads.

假设您的一个报告需要超过阈值(500毫秒),那么TP将创建一个额外的线程.如果您的报告竞争某些内容(最可能是磁盘I / O),那么额外的线程将使其他报告更有可能超过阈值.随着雪崩的结果.

新的Fx4 Threadpool比前一个更聪明,但它仍然是一个粗略的启发式.您的MaxDegreeOfParallelism是正确的解决方案.