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

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

Задача Поток данных, можно ли изменить блок данных из состояния завершения?

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

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

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

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

Асинхронное ведение журнала, генерирующее исключение NullReferenceException

Я пытаюсь асинхронно записывать некоторую информацию в SQL Server внутри действия контроллера MVC 4, нацеленного на .NET 4.0, используя AsyncTargetingPack. Я...

Задача Поток данных, можно ли изменить блок данных из состояния завершения?

Я хотел бы знать, возможно ли изменить состояние завершения блоков данных? Например, я отметилvar block = new BufferBlock<int>(); блок данных в комплекте сblock.Complete(), Блок связан с другими блоками данных. Я хотел бы знать, могу ли я ...

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

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

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

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

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

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

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