c# - Parallel.Foreach() 没有结果
问题描述
我正在尝试使用并行查询 mongo-db,Parallel.Foreach()
但没有得到任何结果。但是当我尝试在常规 foreach 循环中运行相同的东西时,我能够执行预期的任务。
var exceptions = new ConcurrentQueue<Exception>();
var secondaryObjectsDictionaryCollection = new Dictionary<string, List<JObject>>();
// This works
foreach(var info in infos)
{
try
{
name = await commonValidator.ValidateAsync(name);
await commonValidator.ValidateIdAsync(name, id);
var list = await helper.ListRelatedObjectsAsync(name, id, info, false);
secondaryObjectsDictionaryCollection.Add(info.PrimaryId, secondaryObjectsList.ToList());
}
catch (Exception ex)
{
exceptions.Enqueue(ex);
}
}
//This does not
Parallel.ForEach(infos, async info =>
{
try
{
name = await commonValidator.ValidateAsync(name);
await commonValidator.ValidateIdAsync(name, id);
var list = await helper.ListRelatedObjectsAsync(name, id, info, false);
secondaryObjectsDictionaryCollection.Add(info.PrimaryId, secondaryObjectsList.ToList());
}
catch (Exception ex)
{
exceptions.Enqueue(ex);
}
});
我只想并行执行此任务,因为涉及不同的 mongodb 集合,并且还可以减少响应时间。
我无法弄清楚我的并行循环中出了什么问题。并行执行这些任务的任何其他方法也将起作用。
解决方案
让我们看一个更简单的例子来说明同样的问题
你有类似的代码
var results = new Dictionary<int, int>();
Parallel.ForEach(Enumerable.Range(0, 5), async index =>
{
var result = await DoAsyncJob(index);
results.TryAdd(index, result);
});
您的代码无法运行,因为表达式
async index => {...}
返回未等待的任务
像这样
Parallel.ForEach(Enumerable.Range(0, 5), index => new Task());
顺便说一句,当您像示例中那样使用多线程时,当您进行并行更新以避免错误和死锁时,您应该使用ConcurrentDictionary而不是 Dictionary
这里最好的解决方案不要使用并行循环,而是使用Task.WhenAll
var tasks = Enumerable.Range(0, 5).Select(async index =>
{
var result = await DoAsyncJob(index);
results.TryAdd(index, result);
});
await Task.WhenAll(tasks);
推荐阅读
- php - 单击按钮时很难使用 AJAX 发布图片
- sql - 根据 SQL Server 中时间戳的差异过滤掉行
- jquery - 在jsp输入字段中固定某些值
- text-to-speech - HTS 语音未在 Festival 2.5 版上运行
- java - 在 JavaFX MediaPlayer 上强制自定义音量
- performance - Chrome Web 请求卡住 8 秒
- printing - 有没有办法从并行端口将数据保存到 pdf?
- video-streaming - 从 RTSP 捕获 jpeg 图像 - gStreamer
- javascript - 按钮搜索或过滤
- sqlite - SQLITE 导入问题