tpl-dataflow

6зной

3ответ

TPL Dataflow - параллельная и асинхронная обработка, сохраняя порядок

Я создал конвейер потока данных TPL, который состоит из 3 TransformBlock и ActionBlock в конце. var loadXml = new TransformBlock<Job, Job>(job => { ... }); // I/O var validateData = new TransformBloc

1зной

2ответ

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

Я новичок в TPL Dataflow и я ищу конструкцию, которая позволит разбить список исходных сообщений для равномерно распределенных параллельной обработки при сохранении порядка сообщений сообщений через о

0зной

1ответ

Повторный поток данных tpl с/без Rx

Я использую .net реактивное расширение с потоком данных TPL. Вот мой трубопровод: Я получаю данные как поток от какого-то внешнего источника, а затем я преобразую точки данных с помощью потока данных

1зной

1ответ

TPL Dataflow - условные циклы

В настоящее время я работаю над потоком данных о трубопроводе, где каждый этап, за исключением этапа 1, является потребителем и производителем async. У меня есть объекты, «текущие» по моему конвейеру,

3зной

1ответ

Преобразование моего кода на основе C# BlockingCollection в поток данных TPL

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

2зной

2ответ

TPL Dataflow труба постоянно работает внутри службы

Например, у меня есть три блока: Buffer -> Transform -> Action Я бегу службы WebAPI приносит данные из запросов в блок буфера. Как создать такой канал, который будет работать вечно без вызова Compl