我看过基本类型的并行聚合代码,例如
Parallel.For<int>(0, result.Count, () => 0, (i, loop, subtotal) =>
{
subtotal += result[i];
return subtotal;
},
(x) => Interlocked.Add(ref sum, x)
);
我想知道是否有列表/其他集合的等价物,例如:
List<Result> AllResults;
Parallel.ForEach(allIDs, (currentID) =>
{
subList.add(GetResultFor(currentID));
return subList;
},
(x) =>
{
lock(AllResults)
AllResults.AddRange(subList);
};
我猜没有什么比这更漂亮和整洁的了,但我想不出另一种方法,当然不是通过标准的 parralel.ForEach 因为我想不出你会怎么说“这个核心有这个范围,这个核心这个范围”......
最佳答案
我认为在这两个例子中,PLINQ可以更好地为您服务,并且在使用非线程安全集合时无需手动锁定。
您的求和计算可以转换为:
var sum = result.AsParallel().Sum();
第二个例子是 List<T>
可以转换为:
List<Result> results = allIDs.AsParallel()
.Select(id => GetResultFor(id))
.ToList();
注意并行性仅与测试所说的一样好。并行并不总是会加速您的代码,有时它甚至可能会降低顺序循环的性能。
关于c# - 并行聚合集合,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33613163/