Parallel.ForEach 在处理极大的数据集时抛出异常

Question

我的问题集中在一些 Parallel.ForEach 代码上，这些代码过去可以正常工作，现在我们的数据库已经增长到原来的 5 倍，它几乎经常崩溃。

Parallel.ForEach<Stock_ListAllResult>( lbStockList.SelectedItems.Cast<Stock_ListAllResult>(), SelectedStock =>
{
    ComputeTipDown( SelectedStock.Symbol );
} );

ComputeTipDown() 方法获取该交易品种的所有每日股票波动数据，并迭代每一天，获取昨天的数据并进行一些计算，然后将它们插入每天的数据库中。

当公式更改时，我们很少使用它来重新计算静态数据值。

例外是这样的：

我们正在访问的数据库有 16 GB 内存，是双四核，没有人当我重新计算时正在使用该系统。运行应用程序以重新生成代码的机器是一台笔记本电脑，具有 12 GB 内存和超线程八进制核心。所以不存在明显的资源争夺。

这是我尝试使用 .NET 4 和并行处理，所以我想知道我是否遗漏了一些东西。任何想法都会受到欢迎。

Answer 1

看起来您收到了 AggregateException，这就是 Parallel。如果任何循环体方法引发异常，ForEach 都会引发异常。

如果您对此进行调试，您应该能够查看 InnerExceptions< /a> 查看实际抛出的异常。看起来 ComputeTipDown 在一次或多次迭代中引发了异常，从而导致了这种情况的发生。