Большое спасибо за этот ответ, он подробный и понятный, и вы даже сослались на все варианты, которые я упомянул, включая ForEachAsync! +100 :)

я есть требование сделать масштабируемый процесс. Процесс имеет в основном операции ввода-вывода с некоторыми незначительными операциями с процессором (в основном десериализацией строк). Процесс запрашивает у базы данных список URL-адресов, затем ...

, Я добавлю простой пример.

ужно импортировать данные о клиентах из устаревшей БД и выполнить несколько преобразований в процессе. Это означает, что одна запись должна выполнять дополнительные «события» (синхронизировать продукты, создавать счета и т. Д.). Моим ...

Почему блоки работают в таком порядке?

BatchBlock создает пакет с элементами, отправленными после TriggerBatch ()

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

EventSourceException: нет свободных буферов, доступных из операционной системы

Поток данных с разделением работы на небольшие задания и последующей группировкой

Блокировка блокировки буфера с помощью OutputAvailableAsync после TryReceiveAll

Работая надответ вэтот вопросЯ написал этот фрагмент:

Параллельная очистка в .NET

Повторите политику в ITargetBlock <TInput>

Мне нужно ввести политику повторных попыток для рабочего процесса. Допустим, есть 3 блока, которые связаны таким образом: var executionOptions = new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 3 }; var buffer = new ...

Повторите политику в ITargetBlock <TInput>

Мне нужно ввести политику повторных попыток для рабочего процесса. Позволять&#39;скажем, есть 3 блока, которые связаны таким образом: