c#并行循环错误

Question

有人可以帮忙吗？当我编写此代码并运行时。程序向我显示错误，指出“已经有一个与此命令关联的打开的 DataReader，必须先将其关闭”。

这是我的代码。

Parallel.For(0, MthRange, i => {
    PSUpfrontFeeForMonth[i] = CommissionSummary
        .Where(s => s.TransDate == oReportCommonFilter.fromDate.AddMonths(i))
        .Sum(s => s.PSUpfrontFee);

    if (!PSUpfrontFeeForMonth[i].HasValue)
    {
        PSUpfrontFeeForMonth[i] = 0;
    }
});

谢谢。

问候，简

Answer 1

并行化数据库查询是完全错误的，原因如下:

1. 针对来自的 sql 发出查询每个处理器都有多个数据读者将被打开 -> '错误'
2. 实际上，没有实现任何性能提升程序变慢是因为每个处理器都试图连接到数据库并没有并行处理实际上已经完成，因为所有查询处理是在sql中完成的!所以正常的串行查询速度更快这种情况。