C＃和线程池

Question

之间有什么区别：

Task[] tasks = new Task[mylist.Count]; 
int i = 0; 

foreach (DataTable dt in mylist) 
{ 
      Task t = Task.Factory.StartNew(() => UpdateProductsData(dt, updateType)); 
      tasks[i] = t; 
      i++; 
} 
Task.WaitAll(tasks); 

和：

tasks[0] = Task.Factory.StartNew(() => UpdateProductsData(mylist[0], updateType)); 
tasks[1] = Task.Factory.StartNew(() => UpdateProductsData(mylist[1], updateType)); 
tasks[2] = Task.Factory.StartNew(() => UpdateProductsData(mylist[2], updateType)); 
tasks[3] = Task.Factory.StartNew(() => UpdateProductsData(mylist[3], updateType)); 
Task.WaitAll(tasks); 

出于某种原因，第一个片段过早终止，虽然第二片段的行为与预期。第一个例子中需要改变什么才能提供动态实现？

Answer 1

这是经典的Captured Variable In Loop问题。您需要将循环体内的循环迭代的值复制到本地变量：

Task[] tasks = new Task[mylist.Count]; 
int i = 0; 
foreach (DataTable dt in mylist) 
{ 
    DataTable dtInner = dt; 
    Task t = Task.Factory.StartNew(() => UpdateProductsData(dtInner, updateType)); 
    tasks[i] = t; 
    i++; 
} 
Task.WaitAll(tasks); 

编辑：

这可能是更简单的表达你的代码使用Parallel.Foreach一个班轮：

Parallel.ForEach(mylist, dt => UpdateProductsData(dt, updateType));