我正在尝试使用新的任务,但是发生了一些我不了解的事情。
首先是代码,这很简单。我传入了一些图像文件的路径列表,并尝试添加一个任务来处理每个图像文件:
public Boolean AddPictures(IList<string> paths) { Boolean result = (paths.Count > 0); List<Task> tasks = new List<Task>(paths.Count); foreach (string path in paths) { var task = Task.Factory.StartNew(() => { Boolean taskResult = ProcessPicture(path); return taskResult; }); task.ContinueWith(t => result &= t.Result); tasks.Add(task); } Task.WaitAll(tasks.ToArray()); return result; }
我发现,如果让它与单元测试中的3条路径列表一起运行,那么所有这3个任务都将使用所提供列表中的最后一条路径。如果我单步执行(并减慢了循环的处理速度),则会使用循环中的每个路径。
有人可以解释发生了什么,为什么?可能的解决方法?
您正在关闭循环变量。不要那样做 取一份副本:
foreach (string path in paths) { string pathCopy = path; var task = Task.Factory.StartNew(() => { Boolean taskResult = ProcessPicture(pathCopy); return taskResult; }); // See note at end of post task.ContinueWith(t => result &= t.Result); tasks.Add(task); }
您当前的代码正在捕获path- 创建任务时不是它的 值 ,而是变量本身。每次循环时,该变量都会更改值-因此可以在调用委托时轻松更改它。
path
通过获取变量的副本,您在每次循环时都会引入一个 新 变量-当捕获 该 变量时,在下一次循环中将不会更改 该 变量。
埃里克·利珀特(Eric Lippert)有两篇博客文章,其中更详细地介绍了这一点:第1部分;第2部分。
别难过-这几乎使所有人都陷入困境:(
关于这一行的注意事项:
task.ContinueWith(t => result &= t.Result);
正如评论中指出的那样,这不是线程安全的。多个线程可以同时执行它,从而可能在彼此的结果上加盖印记。我没有添加锁定或类似的东西,因为它会分散问题关注的主要问题,即变量捕获。但是,值得注意的是。