在 Parallel.Foreach 中调用方法并将结果保存到线程安全列表中

Question

我有这段代码在单线程中运行良好

foreach (var meetingRoom in meetingRooms)
{
            try
            {
                var res = calendarService.GetEvents(meetingRoom.Email, startUtc, endUtc, lightweight, limit);
                result.AddRange(res);
            }
            catch (Exception ex)
            {
                Log.Error(ex);
            }
}

但问题是 meetingRooms 列表包含超过 40 000 个条目。我正在尝试接近 Parallel.Foreach - 这是我到目前为止所得到的：

Parallel.ForEach(meetingRooms, () => 0,(meetingRoom) =>
        {
            var res = calendarService.GetEvents(meetingRoom.Email, startUtc, endUtc, lightweight, limit);

        }
        ,
        finalResult =>
        {
            lock (result)
            {
                result.Add(finalResult);
            }
        });

我不知道第四个参数 localFinally 是如何工作的。

请注意，result 和 meetingRooms 是具有不同数据类型的列表。

编辑：

正如其中一个答案所示，我已经实施了 PLINQ 解决方案。看起来像它的工作，但 Exchange Web 服务（EWS）库没有实现并行调用其方法之一。获取和错误“不是唯一的键！”这是由 Microsoft 代码抛出的。

Answer 1

您可以使用 Plinq。

result = meetingRooms
  .AsParallel()
  .Select(meetingRoom => calendarService.GetEvents(meetingRoom.Email, startUtc, endUtc, lightweight, limit) )
  .ToList();

当您仍想使用 Parallel.ForEach() 时，localFinally 的重载就不是那么有用了。使用基础：

Parallel.ForEach(meetingRooms, meetingRoom =>
    {
        var res = calendarService.GetEvents(meetingRoom.Email, ...);

        lock (result) // only OK when you don't lock on it anywhere else
        {
            result.Add(res);
        }
    });

Answer 2

您还可以使用ConcurrentBag（或ConcurrentQueue 或ConcurrentDictionary）来存储结果并避免锁定。