Изменения документа ConcurrentDictionary
Редактировал(а) Alexandr Fokin 2023/02/16 01:41
<
>
отредактировано Alexandr Fokin
на 2021/05/15 14:38
на 2021/05/15 14:38
отредактировано Alexandr Fokin
на 2022/10/04 15:56
на 2022/10/04 15:56
Изменить комментарий:
К данной версии нет комментариев
Комментарий
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -1,20 +1,49 @@ 1 +---- 1 1 2 -Пример работы ConcurrentDictionary AddOrUpdate: 3 -В dictionary есть одной значение по ключу key1 - val1. 3 +===== Описание работы метода AddOrUpdate: ===== 4 4 5 -1 Поток th1 запускает Update делегат по ключу key1. (Фиксирует текущее значение th1_v) 6 -2 Поток th2 запускает Update делегат по ключу key1. (Фиксирует текущее значение th2_v) 7 -3 Поток th2 заканчивает выполнение делегата Update. th1 сравнивает val1 = th2_v (Через equils). 8 - Значение равны и th2 сохраняет результат. 9 -4 Поток th1 заканчивает выполнение делегата Update. th2 сравнивает val1 = th1_v (Через equils). 10 - Значение НЕ равны и th2 повторно вызывает Update делегат. 11 - (Если элемент был удален, то запустить делегат Add) 12 - !Повторного вызова делегата не произойдет, в случает если результат работы th2 эквивалентен исходному начальному знаечнию val1. 5 +|(% style="width:72px" %)**Порядок**|(% style="width:53px" %)**Поток**|(% style="width:1352px" %)**Действие** 6 +|(% style="width:72px" %)0)|(% style="width:53px" %) |(% style="width:1352px" %)В dictionary есть одно значение по ключу key1 - val1. 7 +|(% style="width:72px" %)1)|(% style="width:53px" %)th1|(% style="width:1352px" %)Поток th1 запускает UpdateAction делегат по ключу key1. 8 +(Фиксирует текущее значение th1_val1) 9 +|(% style="width:72px" %)2)|(% style="width:53px" %)th2|(% style="width:1352px" %)Поток th2 запускает UpdateAction делегат по ключу key1. 10 +(Фиксирует текущее значение th2_val2) 11 +|(% style="width:72px" %)3)|(% style="width:53px" %)th2|(% style="width:1352px" %)Поток th2 заканчивает выполнение делегата UpdateAction. 12 +th2 сравнивает (текущее значение) val1 = th2_val1 (Через Equals). 13 +Значение равны и th2 сохраняет результат. 14 + 15 +|(% style="width:72px" %)4)|(% style="width:53px" %)th1|(% style="width:1352px" %)((( 16 +Поток th1 заканчивает выполнение делегата UpdateAction. 17 +th1 сравнивает (текущее значение) val1 = th1_val1 (Через Equals). 18 +Значение НЕ равны и th1 повторно вызывает UpdateAction делегат для значения val1. 13 13 14 -Получается, что ни вызов AddOrUpdate, ни вызов конкретного делегата (Add/Update) сам по себе не блокирует значение в коллекции и не препятствует в изменении другим потокам. 20 +Если элемент был удален и на момент проверки ключ отсутствует в коллекции, то, соответственно, будет запущен делегат AddAction. 21 +!Повторного вызова делегата не будет, в случает если результат работы th2 эквивалентен исходному начальному значению val1 (th1_val1). 22 +))) 15 15 16 - По сути мы получаем**оптимистичную блокировку**. В случае неудачи которой, повторно вызывается действие обработки (add/update) в нового значения по указанному ключу. Критерием сравнения блокировки является Equils. В таком случае возможно имеет смысл перегрузка Equils и наличии в сущности некоторого ключевого поля. Нечто вроде Change Version TimeStamp.24 +**Итог:** 17 17 26 +Ни вызов AddOrUpdate, ни начало выполнения конкретного делегата (AddAction/UpdateAction) само по себе не препятствует изменению значения (по ключу) из других потоков (пока происходит исполнение делегата в текущем потоке). Т.е. не происходит пессимистичной блокировки. 18 18 19 -Ссылки: 20 -[[Базы данных/Транзакции и блокировки>>https://wiki.denhome.ru/bin/view/Разработка/Базы%20данных/Транзакции%20и%20блокировки/]] 28 +По сути мы получаем __оптимистичную блокировку__. В случае неудачи которой, повторно вызывается действие обработки (AddAction/UpdateAction) для измененного значения по указанному ключу. 29 +Критерием сравнения блокировки является Equals. В некоторых ситуациях имеет смысл перегрузка Equals на сравнение по: (1 ReferenceEquals / 2 VersionProperty / 3 TimeStampProperty). 30 + 31 +---- 32 + 33 +Для хранения данных TValue, вычисление значений которых занимает много времени, можно хранить Lazy<TValue> или же Task<TValue>. 34 + 35 +---- 36 + 37 +Best Practices for Using ConcurrentDictionary | Лучшие практики использования ConcurrentDictionary 38 +[[https:~~/~~/arbel.net/2013/02/03/best-practices-for-using-concurrentdictionary/>>url:https://arbel.net/2013/02/03/best-practices-for-using-concurrentdictionary/]] 39 + 40 +How to improve performance of ConcurrentDictionary.Count in C# 41 +[[https:~~/~~/stackoverflow.com/questions/41298156/how-to-improve-performance-of-concurrentdictionary-count-in-c-sharp>>url:https://stackoverflow.com/questions/41298156/how-to-improve-performance-of-concurrentdictionary-count-in-c-sharp]] 42 + 43 +//Дополнение: В некоторых случаях может иметь смысл создание собственной обертки над коллекции и ведения в ней собственного счетчика размера. 44 +Контроль интерфейса обертки позволит четко отслеживать события Добавления/Удаления, для управления счетчиком можно использовать Interlocked операции.// 45 + 46 +---- 47 + 48 +DotNext | Антон Нечуговских — Как мы написали свой lock-free dictionary 49 +[[https:~~/~~/www.youtube.com/watch?v=Vs7qp8FNURo>>https://www.youtube.com/watch?v=Vs7qp8FNURo]]