Что добавить для части обновления в ConcurrentDictionary AddOrUpdate

Я пытаюсь переписать код с помощью Dictionary, чтобы использовать ConcurrentDictionary. Я просмотрел несколько примеров, но у меня все еще возникают проблемы с реализацией функции AddOrUpdate. Это исходный код:

    dynamic a = HttpContext;
    Dictionary<int, string> userDic = this.HttpContext.Application["UserSessionList"] as Dictionary<int, String>;

   if (userDic != null)
   {
      if (useDic.ContainsKey(authUser.UserId))
      {
        userDic.Remove(authUser.UserId);
      }
   }
  else
  {
     userDic = new Dictionary<int,string>();
  }
  userDic.Add(authUser.UserId, a.Session.SessionID.ToString());
  this.HttpContext.Application["UserDic"] = userDic;

Я не знаю, что добавить в обновленную часть:

userDic.AddOrUpdate(authUser.UserId,
                    a.Session.SessionID.ToString(),
                    /*** what to add here? ***/);

Любые указатели будут оценены.

Вам нужно передать, Funcкоторый возвращает значение, которое будет сохранено в словаре в случае обновления. Я предполагаю, что в вашем случае (поскольку вы не различаете добавление и обновление) это будет:

var sessionId = a.Session.SessionID.ToString();
userDic.AddOrUpdate(
  authUser.UserId,
  sessionId,
  (key, oldValue) => sessionId);

Т.е. Funcвсегда возвращает sessionId, так что и Add, и Update устанавливают одно и то же значение.

Кстати: на странице MSDN есть образец .

Надеюсь, я ничего не упустил в вашем вопросе, но почему бы просто не так? Это проще, атомарнее и потокобезопасно (см. Ниже).

userDic[authUser.UserId] = sessionId;

Безоговорочно сохраните пару ключ / значение в словаре, перезаписав любое значение для этого ключа, если ключ уже существует: используйте установщик индексатора

(См .: http://blogs.msdn.com/b/pfxteam/archive/2010/01/08/9945809.aspx )

Индексатор тоже атомарный. Если вместо этого вы передадите функцию, ее может не быть:

Все эти операции являются атомарными и потокобезопасными по отношению ко всем другим операциям в ConcurrentDictionary. Единственное предостережение относительно атомарности каждой операции - для тех, которые принимают делегат, а именно AddOrUpdate и GetOrAdd. [...] эти делегаты вызываются вне блокировок

См. Http://blogs.msdn.com/b/pfxteam/archive/2010/01/08/9945809.aspx

В итоге я реализовал метод расширения:

static class ExtensionMethods
{
    // Either Add or overwrite
    public static void AddOrUpdate<K, V>(this ConcurrentDictionary<K, V> dictionary, K key, V value)
    {
        dictionary.AddOrUpdate(key, value, (oldkey, oldvalue) => value);
    }
}

Для тех, кому интересно, я в настоящее время реализую случай, который является отличным примером использования "oldValue", известного как существующее значение, вместо того, чтобы форсировать новое (лично мне не нравится термин "oldValue", поскольку это не старый, когда он был создан всего несколько тактов назад из параллельного потока).

dictionaryCacheQueues.AddOrUpdate(
    uid,
    new ConcurrentQueue<T>(),
    (existingUid, existingValue) => existingValue
);