У меня есть TransformManyBlock<Tin, Tout> , и во время выполнения я добавляю потребителей (ActionBlocks) через LinkTo(...) . Является ли TransformManyBlock правильным блоком потока данных для потребления элементов, их преобразования и...

Мне было интересно, есть ли преимущества, связанные с использованием BufferBlock, связанного с одним или несколькими ActionBlock, кроме регулирования (с использованием BoundedCapacity), вместо того, чтобы просто публиковать непосредственно в...

Я реализую рабочую роль в Azure, которой необходимо удалять большие двоичные объекты из хранилища Azure. Предположим, что мой список больших двоичных объектов содержит около 10 000 элементов. Вероятно, самым простым синхронным подходом будет:...

Я использую поток данных TPL в приложении WPF по шаблону MVVM. У меня есть TransformBlock<object,object> и ActionBlock<object> , и я связываю их так: transformBlock.LinkTo(notificationBlock); ActionBlock<object> должен...

В документации .Complete() говорится следующее: Сигналы IDataflowBlock о том, что он не должен больше ни принимать, ни создавать сообщения, ни потреблять какие-либо отложенные сообщения. Итак, скажем, у меня есть BatchedJoinBlock ,...

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

У меня есть конвейер потока данных, состоящий из нескольких блоков. Когда элементы проходят через мой конвейер обработки, я хочу сгруппировать их по полю A . Для этого у меня есть BatchBlock с высоким BoundedCapacity . В нем я храню свои...

Я новичок в Dataflow и следую этому пошаговому руководству Как отменить блокировку потока данных . Я сначала нажимаю кнопку "Добавить", а затем нажимаю "Отмена", но получаю исключение " Задание было отменено Исключение " после нажатия кнопки отмены....

Когда TransformBlock имеет MaxDegreeOfParallelism > 1 и BoundedCapacity , которые не являются неограниченными, почему он откладывает получение дальнейших сообщений, в то время как есть одна длительная задача, несмотря на то, что во входной...

Я начал изучать поток данных TPL как решение для рабочего процесса обработки. Суть рабочего процесса обработки заключается в считывании входных сообщений из нескольких таблиц, создании из них четырех отражающих объектов и сохранении их в четырех...

Мне нужно прочитать 1 млн строк из IDataReader и одновременно записать n текстовых файлов. Каждый из этих файлов будет другим подмножеством доступных столбцов; все n текстовые файлы будут состоять из 1 миллиона строк. Текущий план — один...

Я использую TPL Dataflow для загрузки видео (я использую библиотеку Emgu.CV для загрузки) с пути и через TPL Dataflow сначала рисую его в приложении Windows Form (после этого будет этап обмена данными между доской). У меня было еще одно сообщение,...