如何在并行循环中从IQueryable中获取元素

Question

我在这里获得了我的记录。

IQueryable<EmployeeItem> dtEmployee = GetAll(); 

之后，那个循环dtEmployee。

这是我正常的循环工作正常。

for (int i = 0; i < dtEmployee.Count(); i++) 
{ 
    var drEmployee = dtEmployee.AsEnumerable().ElementAt(i); 
} 

这是我想尝试的并联循环。

System.Threading.Tasks.Parallel.For(0, dtEmployee.Count(), i => { 
    var drEmployee = dtEmployee.AsEnumerable().ElementAt(i); 
}); 

我没有任何编译错误，但是当我在Visual Studio中运行它，我得到这个错误：

Answer 1

This is my normal loop which is working fine.

我不会说很好，这是令人难以置信的低效率。由于dtEmployee代表查询和AsEnumerable()意味着它不再是数据库查询，只是一个懒惰序列，每个ElementAt()（以及Count()）都会导致单独的数据库查询，这可能会检索所有员工。

为了解决这个问题，使用foreach：

foreach (var drEmployee in dtEmployee) 
{ 
} 

This is the parallel loop that I want to try.

由于dtEmployee不是线程安全的，从多个线程在同一时间，你不能访问它。这里的修正实际上是相当多的与上面相同：使用Parallel.ForEach()：

Parallel.ForEach(dtEmployee, drEmployee => { 
});