从并行字典中删除元素的并行任务执行的不同行为

-1

我想测试并行添加和删除到并行字典。我有下面的代码在我的测试类：从并行字典中删除元素的并行任务执行的不同行为

[TestMethod] 
    public void T_Parallel_Removing 
    { 
     var management = new Management(); 

     List<Task> AddTasks = new List<Task>(); 
     List<Task> RemoveTasks = new List<Task>(); 

     var units = new List<Unit>(); 

     for (int i = 0; i < 30; i++) 
     { 
      var unit= = new Unit(); 
      units.Add(unit); 
      AddTasks.Add(Task.Run(() => AddUnit(management, unit))); 
     } 

     Task.WaitAll(AddTasks.ToArray()); 
    }

的添加删除UND方法：

public void AddUnit(Management m, Unit u,) 
    { 
     management .AddPlantUnit(u, "",); 
    } 


    public void RemoveUnit(Management m, Unit u) 
    { 
     m.RemovePlantUnit(u.Adress); 
     Console.WriteLine(u.Adress); 
    }

这工作完全正常。但是，当我开始删除一些奇怪的情况发生（忽略整型领域，我总觉得他们是问题的一部分，但他们都没有）

for (int i = 0; i < 29; i++) 
     { 
      RemoveTasks .Add(Task.Run(() => RemoveUnit(management, units[i]))); 

     }

在这里，我总是得到同一个地址和输出如果每个任务都一样。

但是，如果使用下面的代码：

RemoveTakes.Add(Task.Run(() => RemoveUnit(management, units[0]))); 
     RemoveTasks .Add(Task.Run(() => RemoveUnit(management, units[1]))); 
     RemoveTasks .Add(Task.Run(() => RemoveUnit(management, units[2]))); 
     RemoveTasks .Add(Task.Run(() => RemoveUnit(management, units[3]))); 
     RemoveTasks .Add(Task.Run(() => RemoveUnit(management, units[4]))); 
     RemoveTasks .Add(Task.Run(() => RemoveUnit(management, units[5])));

它的工作原理没有问题。如果我在for循环中添加一些虚拟代码或Thread.Sleep（1），它也可以工作（每个任务获得不同的地址）

有人可以解释这种行为吗？

来源

2017-09-14 Rolfant90

如果将Task.Run（（）=> RemoveUnit（management，units [i]））''改成Task.Run（（）=> Console.WriteLine（i））'写入的内容安慰？这是你的预期吗？ – mjwills

不知道[闭包]（https://stackoverflow.com/q/428617/1997232）几乎任何lambda在循环= [问题]（https://stackoverflow.com/q/16264289/1997232）。 – Sinatr

for (int i = 0; i < 29; i++) 
{ 
    RemoveTakes.Add(Task.Run(() => RemoveUnit(management, units[i]))); 
}

不符合您的想法。

您应将其更改为：

for (int i = 0; i < 29; i++) 
{ 
    var bob = i; 
    RemoveTakes.Add(Task.Run(() => RemoveUnit(management, units[bob]))); 
}

随着你的原代码，由当时的Task跑的i值发生了变化。所以，你需要存储在一个单独的变量（bob - 范围的内循环），从而第一Task得到0，下得1等

你的问题是基本相同this one（尽管它使用foreach原理是一样的）。

请注意，如果您安装了Resharper，它应该有highlighted这个问题给你。

来源

2017-09-14 12:44:53 mjwills

每次运行后都不会被破坏？ – Rolfant90

不，'bob'会一直活着，直到它不再'需要'（这就是封闭如何工作）。实际上，这是'RemoveUnit'完成执行时的情况。 – mjwills

从并行字典中删除元素的并行任务执行的不同行为

回答

相关问题