Почему цикл Parallel.ForEach завершается с OperationCancelledException при использовании GetConsumableEnumerable ? //outside the function static BlockingCollection<double> _collection = new BlockingCollection<double>();...

Я реализовал шаблон Producer/Consumer, используя BlockingCollection, однако он, похоже, не блокируется, как я ожидаю. У меня есть один поток, получающий кадры с веб-камеры и добавляющий их в BlockingCollection. private void...

У меня есть несколько производителей и несколько потребителей. Мой общий ресурс — BlockingCollection. Однако мой код работает, только если у меня есть один потребитель. Я знаю, что это состояние гонки, так как вывод каждый раз разный, когда я...

У меня есть список, привязанный к коллекции блокировок в моей модели представления. <ListBox Grid.Row="1" ItemsSource="{Binding PlantControllers}" и собственность public BlockingCollection<PLANTCONTROLLER> PlantControllers...

У меня проблема, когда BlockingCollection<MyItem> слишком долго просыпается от .Take() звонка. Сценарий таков: у меня есть поток, который очень быстро отправляет данные в BlockingCollection (на самом деле в XUnit я выполнил цикл for ....

Я написал следующий метод для пакетной обработки огромного CSV-файла. Идея состоит в том, чтобы прочитать часть строк из файла в память, а затем разделить эту часть строк на пакеты фиксированного размера. Как только мы получим разделы, отправьте эти...

Я использую очередь, реализованную классом BlockingCollection, для реализации очереди модели производитель-потребитель. У меня есть несколько потоков, добавляющих элементы в указанном порядке (только для каждого из потоков), и один поток,...

У меня есть простая установка производителя-потребителя, использующая блокирующую коллекцию. Потребитель сидит в цикле в течение всего времени работы нашего приложения, ожидая, пока потребитель поместит элементы в коллекцию, затем извлекает элемент и...

Я работаю над простым регистратором файлов, у меня были проблемы с потокобезопасностью, и я смотрел, как это делают другие. Я столкнулся с подходом к использованию BlockingCollection в качестве очереди и цикла foreach для обработки этой очереди:...

Насколько я знаю, добавление в BlockingCollection не блокирует, o AddToAny, о котором я могу думать, это если некоторые из них вызывают CompleteAdding(). Это единственное использование AddToAny? И как только все они вызовут CompleteAdding, AddToAny...