比 .ToArray() 更好的东西来强制枚举 LINQ 输出

Question

我正在使用 LINQ to 对象并有一个函数，在某些情况下，我需要在调用 Aggregate(...) 之前修改基础集合，然后在函数返回 Aggregate(...) 的结果之前将其返回到其原始状态。我当前的代码如下所示：

bool collectionModified = false;
if(collectionNeedsModification)
{
    modifyCollection();
    collectionModified = true;
}

var aggregationResult = from a in
                            (from b in collection
                             where b.SatisfysCondition)
                             .Aggregate(aggregationFunction)
                        select a.NeededValue;

if(collectionModified)
    modifyCollection();

return aggregationResult;

但是，正如所写，如果我修改集合，我会得到错误的结果，因为我在枚举 aggregationResult 之前将集合恢复到其原始状态，并且对 LINQ 结果进行延迟评估。我目前的解决方案是在我的 LINQ 查询中使用 .ToArray()，如下所示：

var aggregationResult = (from a in
                            (from b in collection
                             where b.SatisfysCondition)
                             .Aggregate(aggregationFunction)
                         select a.NeededValue).ToArray();

结果数组的大小总是很小（

Answer 1

如果你总是使用结果，我认为你的方法没有问题（因为你的结果集不大，它不会消耗太多内存。顺便说一下，如果你这样做并且从不使用结果，它会造成性能损失）。 所以，是的，这是正确的做法。

Answer 2

最好避免像上面的 modifyCollection 这样的副作用函数。

更好的方法是创建一个返回修改后的集合（或查询）的函数，让最初的集合保持原样。

var modifiedCollection = ModifyCollection(collection, collectionNeedsModification);

var aggregationResult = from a in
                        (from b in modifiedCollection
                         where b.SatisfysCondition)
                         .Aggregate(aggregationFunction)
                    select a.NeededValue;

其中 ModifyCollection 是根据 collectionNeedsModification 布尔参数在参数中返回修改后的集合（或查询）的方法。

Answer 3

只是为了检查我理解你的意思 - 你基本上想遍历所有结果，只是为了强制任何副作用发生？

副作用通常是一个坏主意，正是因为这种逻辑更难理解。话虽如此，执行此操作并强制进行全面评估的最简单方法可能就是迭代它：

foreach (var result in aggregationResult)
{
    // Deliberately empty; simply forcing evaluation of the sequence.
}

您也可以使用LastOrDefault() 来避免ToArray() 中涉及的所有复制。只要结果不实现IList<T>（涉及快捷方式），Count() 就可以了。

Answer 4

（注意：在没有编译器的情况下打字，因此代码未经测试）

如果您已经将 Reactive Extensions for .NET 作为依赖项，则可以使用 Run()：

aggregationResult.Run();

但可能不值得为此添加依赖项。

您也可以自己实现 Run 方法作为扩展方法：

public static MyLinqExtensions 
{
     public static void Run<T>(this IEnumerable<T> e)
     {
         foreach (var _ in e);
     }
}