过滤 IEnumerable 模式

Question

考虑以下简单的代码模式：

foreach(Item item in itemList)
{
   if(item.Foo)
   {
      DoStuff(item);
   }
}

如果我想使用并行扩展（PE）对其进行并行化，我可以简单地替换 for 循环构造，如下所示：

Parallel.ForEach(itemList, delegate(Item item)
{
   if(item.Foo)
   {
      DoStuff(item);
   }
});

但是，PE 会执行不必​​要的工作，将 Foo 原来是的那些项目的工作分配给线程错误的。因此，我认为中间包装/过滤 IEnumerable 可能是一种合理的方法。你同意？如果是这样，实现这一目标的最简单方法是什么？ （顺便说一句，我目前正在使用 C#2，所以我会很感激至少有一个不使用 lambda 表达式等的示例。）

Answer 1

我不确定 .NET 2 的 PE 分区是如何工作的，所以很难说。如果每个元素都被推入一个单独的工作项（这将是一个相当糟糕的分区策略），那么提前过滤将非常有意义。

然而，如果 item.Foo 碰巧非常昂贵（我不希望这样，因为它是一个属性，但它总是可能的），允许它并行化可能是有利的。

此外，在 .NET 4 中，TPL 使用的分区策略可以很好地处理这个问题。它是专门为处理不同工作级别的情况而设计的。它以“块”的形式进行分区，因此一个项目不会发送到一个线程，而是为一个线程分配一组项目，并对其进行批量处理。根据 item.Foo 为 false 的频率，并行化（使用 TPL）很可能比提前过滤更快。

Answer 2

所有因素都归结为这一行：

Parallel.ForEach(itemList.Where(i => i.Foo), DoStuff);

但是阅读另一篇文章的评论时，我现在看到您还处于 .Net 2.0 中，因此其中一些内容可能有点难以通过编译器。

对于.Net 2.0，我认为你可以这样做（我有点不清楚将方法名称作为委托传递仍然有效，但我认为它会）：

public IEnumerable<T> Where(IEnumerable<T> source, Predicate<T> predicate)
{
   foreach(T item in source)
       if (predicate(item))
          yield return item;
}

public bool HasFoo(Item item) { return item.Foo; }

Parallel.ForEach(Where(itemList, HasFoo), DoStuff);

Answer 3

如果我要实现这个，我只需在调用 foreach 之前过滤列表。

var actionableResults = from x in ItemList WHERE x.Foo select x;

这将过滤列表以获取可以执行操作的项目。

注意：这可能是一个不成熟的优化，并且不会对您的性能产​​生重大影响。