Co dodać do części aktualizacji w ConcurrentDictionary AddOrUpdate

Próbuję ponownie napisać kod za pomocą Dictionary, aby użyć ConcurrentDictionary. Przejrzałem kilka przykładów, ale nadal mam problemy z zaimplementowaniem funkcji AddOrUpdate. To jest oryginalny kod:

    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;

Nie wiem, co dodać do aktualizacji:

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

Wszelkie wskazówki będą mile widziane.

Musisz przekazać a, Funcktóry zwraca wartość, która ma być przechowywana w słowniku w przypadku aktualizacji. Myślę, że w twoim przypadku (ponieważ nie rozróżniasz między dodawaniem a aktualizacją) byłoby to:

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

To znaczy, że Funczawsze zwraca sessionId, więc zarówno Add, jak i Update ustawiają tę samą wartość.

BTW: na stronie MSDN znajduje się przykład .

Mam nadzieję, że w Twoim pytaniu niczego mi nie brakowało, ale czemu nie tak po prostu? Jest łatwiejszy, atomowy i bezpieczny dla wątków (patrz poniżej).

userDic[authUser.UserId] = sessionId;

Przechowuj parę klucz / wartość bezwarunkowo w słowniku, nadpisując dowolną wartość dla tego klucza, jeśli klucz już istnieje: użyj metody ustawiającej indeksatora

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

Indeksator też jest atomowy. Jeśli zamiast tego przekażesz funkcję, może to nie być:

Wszystkie te operacje są niepodzielne i są bezpieczne dla wątków w odniesieniu do wszystkich innych operacji w ConcurrentDictionary. Jedynym zastrzeżeniem co do atomowości każdej operacji są te, które akceptują delegata, a mianowicie AddOrUpdate i GetOrAdd. [...] ci delegaci są wywoływani poza śluzami

Zobacz: http://blogs.msdn.com/b/pfxteam/archive/2010/01/08/9945809.aspx

Skończyło się na wdrożeniu metody rozszerzenia:

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);
    }
}

Dla tych, którzy są zainteresowani, wdrażam obecnie przypadek, który jest świetnym przykładem użycia "starej wartości", czyli istniejącej wartości zamiast wymuszania nowej (osobiście nie podoba mi się termin "stara wartość", ponieważ to nie jest tak stary, kiedy został utworzony zaledwie kilka tyknięć procesora temu z równoległego wątku).

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