带有异步lambda的并行foreach

Question

我想并行处理一个集合，但我在实现它时遇到了困难，因此我希望得到一些帮助。

var bag = new ConcurrentBag<object>();
Parallel.ForEach(myCollection, async item =>
{
  // some pre stuff
  var response = await GetData(item);
  bag.Add(response);
  // some post stuff
}
var count = bag.Count;

var bag = new ConcurrentBag<object>();
Parallel.ForEach(myCollection, item =>
{
  // some pre stuff
  var responseTask = await GetData(item);
  responseTask.Wait();
  var response = responseTask.Result;
  bag.Add(response);
  // some post stuff
}
var count = bag.Count;

foreach方法的原型采用操作 作为参数，但我希望它等待异步lambda。

Answer 1

如果您只想要简单的并行性，可以这样做：

var bag = new ConcurrentBag<object>();
var tasks = myCollection.Select(async item =>
{
  // some pre stuff
  var response = await GetData(item);
  bag.Add(response);
  // some post stuff
});
await Task.WhenAll(tasks);
var count = bag.Count;

如果需要更复杂的内容，请查看Stephen Toub的ForeachAsync文章。