Использование LINQ ToDictionary с ConcurrentDictionary

Question

Я использую словарь для сбора событий в многопоточном приложении, используя блокировку, когда добавляю событие и не использую его при поиске. Каждый час или около того я запускаю очистку событий старше определенного времени. Очень простой и он работает.

Я хотел бы перейти к ConcurrentDictionary, чтобы удалить блокировки, и я подумал, что мне просто нужно добавить «Concurrent» и изменить Add to TryAdd. Но тогда я понес в ошибке, что LINQ возвращает только ToDictionary. Я могу obviusly не использовать LINQ, но я был любопытным, знаю, есть ли что-то, что я могу сделать, чтобы сохранить его. И что еще важнее, есть ли что-то, что я еще должен рассмотреть, прежде чем переходить на ConcurrentDictionry?

public class messageResult 
     { 
      public Result result; 
      public DateTime receivedTime; 
     } 


public Dictionary<Guid, messageResult> events = new Dictionary<Guid, messageResult>(); 


lock (events) 
      { 
       events = events.Where(p => p.Value.receivedTime >= t).ToDictionary(p => p.Key, p => p.Value); 
      } 

Благодаря

Answer 1

Это выглядит как ToDictionaryextension method не так сложно, и вы можете создать свою собственную версию.

Но обратите внимание, что ToDictionary возвращает новый объект, пока вы хотели бы иметь один словарь и делиться им между вашими темами.

Вы не должны блокировать изменяемую переменную (и вы также меняете фактическую ссылку на events), создайте приватную переменную readonly и используйте ее для блокировки.

Answer 2

ToDictionary возвращает новый экземпляр ... который отличается от вашего общего экземпляра.

Вы хотите изменить общий экземпляр и должен написать код, который делает это:

foreach(var kvp in events.Where(...).ToList()) 
{ 
    var val = kvp.Value; 
    events.TryRemove(kvp.Key out val); 
}