Блог

У меня проблема с добавлением нового элемента в статический словарь при использовании его из нескольких потоков. Есть идеи, где я делаю это неправильно? Инициализация словаря:

 public static class Server
{
    public static volatile Dictionary<int, List<SomeClass>> Values;
}
 

Попытка добавить элемент:

 Server.Values.Add(someInt, new List<SomeClass> { elements});
 

Как объяснил Джон Скит, вы используете объект, который не гарантированно является потокобезопасным

попробуйте использовать ConcurrentDictionary который предназначен для сценария параллелизма со многими потоками

 public static class Server
{
    public static  ConcurrentDictionary<int, List<SomeClass>> Values =
                      new ConcurrentDictionary<int, List<SomeClass>>(); 
}
 

Вот как это использовать

 bool added = Server.Values.TryAdd(someInt, new List<SomeClass> { elements});
 

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

 private object _lock = new object();
 

Затем вы окружаете любой код, который обращается к вашему общему ресурсу, следующим образом:

 lock(_lock)
{
    // perform operations on shared resource here.
}
 

Важно отметить, что у вас должна быть отдельная блокировка для каждого общего ресурса, а не одна блокировка, используемая для всех ресурсов. Если вы используете свой объект блокировки с несколькими ресурсами, ваш код может быть очень неэффективным. Если один поток захватывает блокировку, чтобы он мог использовать ресурс A, тогда другим потокам придется ждать снятия блокировки, даже если они хотят получить доступ к ресурсу B, который не имеет ничего общего с ресурсом A. Поэтому лучше иметь один объект блокировки на ресурс и называть свои объекты блокировки, чтобы вы знали, с какими ресурсами они должны использоваться.

Альтернативой этому (как показывает ответ БРАХИМА Камеля) является использование замены, если таковая имеется, для вашего общего ресурса, в который уже встроена синхронизация потоков, например ConcurrentDictionary . Хотя в вашем случае это может быть невозможно.