c# – Parallel.ForEach停止与最后几个项目并行

发布时间：2020-12-15 22:16:27 所属栏目：百科来源：网络整理

导读：我有一个外部单线程程序,需要使用不同的参数运行数百次.为了加快速度,我希望同时为每个核心运行一次.为此,我使用在具有不同参数的列表上运行的Parallel.ForEach传递给外部程序： var parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = Envi

我有一个外部单线程程序,需要使用不同的参数运行数百次.为了加快速度,我希望同时为每个核心运行一次.为此,我使用在具有不同参数的列表上运行的Parallel.ForEach传递给外部程序：

var parallelOptions = new ParallelOptions {
    MaxDegreeOfParallelism = Environment.ProcessorCount // 8 for me
};

Parallel.ForEach(ListWithAllTheParams,parallelOptions,DoTheStuff);

...

private void DoTheStuff(ParamType parameter,ParallelLoopState parallelLoopState,long index)
{
    // prepare process parameters etc.
    theProcess.Start();
    theProcess.WaitForExit();
}

非常简单,工作得很好……直到最后~10项 – 它们由于某种原因没有得到并行化,只是一个接一个地运行.我通过查看任务管理器中的cpu使用情况和正在运行的程序来确认这一点.

当我使用少量(例如10个)项目填充参数列表时,不会发生这种情况.

有人可以向我解释这种行为吗？任何提示或技巧赞赏！

解决方法

在上面的评论中,Scott的提示将其更改为以下代码,使其按照我的意愿行事：

OrderablePartitioner<ParamType> partitioner =
    Partitioner.Create(ListWithAllTheParams,EnumerablePartitionerOptions.NoBuffering);

var parallelOptions = new ParallelOptions {
    MaxDegreeOfParallelism = Environment.ProcessorCount // 8 for me
};

Parallel.ForEach(partitioner,DoTheStuff);

非常感谢！

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!