应该等待Parallel.Foreach吗？

Question

这里发生了一件奇怪的事情.我以为Parallel.Foreach会等到所有任务完成后再继续.但是,我有类似的东西:

List<string> foo(List<A> list){
    Dictionary<string, bool> dictionary = new Dictionary<string, bool>();
    Parallel.Foreach(list, element =>
    {
        dictionary[element.Id] = true;
        if (element.SomeMethod()){
            dictionary[element.Id] = false;
        }
    });

    List<string> selectedIds = (from element in list where !dictionary[element.Id] select element.Id).ToList();
    return selectedIds;
}

然后我在选择行中得到System.Collections.Generic.KeyNotFoundException(有时,并不总是).正如您所看到的,我正在为每个可能的键(列表元素的ID)初始化字典,然后获得此异常,这使我认为在执行Parallel.Foreach完成之前可能会到达此行...是对的吗？如果是这样,我怎么能等到这个Parallel.Foreach的所有分支完成？

Answer 1

Parallel.Foreach不需要等待,因为它不返回a Task并且不是异步的.当对该方法的调用完成时,迭代已经完成.

但是,Parallel.Foreach并发使用多个线程并且Dictionary不是线程安全的.

您可能手上有竞争条件,而您应该使用线程安全ConcurrentDictionary.

通过使用PLinq可以更简单的方式解决这个特定情况AsParallel:

list.AsParallel().Where(element => !element.SomeMethod());