我想测试并行添加和删除到并行字典。 我有下面的代码在我的测试类:从并行字典中删除元素的并行任务执行的不同行为
[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),它也可以工作(每个任务获得不同的地址)
有人可以解释这种行为吗?
如果将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