Я пытаюсь реализовать ConcurrentDictionary, заключая его в BlockingCollection, но, похоже, безуспешно.
Я понимаю, что с BlockingCollection работают объявления одной переменной, такие как ConcurrentBag
, ConcurrentQueue
и т. д.
Итак, чтобы создать ConcurrentBag, завернутый в BlockingCollection Я бы объявил и создал экземпляр следующим образом:
BlockingCollection<int> bag = new BlockingCollection<int>(new ConcurrentBag<int>());
, но как это сделать для ConcurrentDictionary? Мне нужна функция блокировки BlockingCollection как на стороне производителя, так и на стороне потребителя.