tpl-dataflow
Просто нужна помощь в создании пользовательского splitblock с помощью библиотеки потоков данных, которая является частью TPL in. Net. Все, чего я хочу добиться, - это простой пользовательский блок, который принимает входные данные и разбивает их на несколько блоков преобразования. Это необходимо для фильтра...
Я хочу ограничить количество элементов, размещенных в конвейере потока данных. Количество элементов зависит от производственной среды. Эти объекты потребляют большое количество памяти (изображений), поэтому я хотел бы опубликовать их, когда последний блок конвейера выполнит свою работу. Я попытался использов...
У меня есть постоянный поток определенных элементов, которые мне нужно обрабатывать параллельно, поэтому я использую TPL Dataflow. Загвоздка в том, что элементы, имеющие один и тот же ключ (подобно словарю), должны обрабатываться в порядке FIFO и не быть параллельными друг другу (они могут быть параллельны др...
С библиотекой потоков данных TPL я хотел бы сделать что-то вроде этого: myActionBlock.Post(newValue, cancelAllPreviousPosts: true); Похоже, что маркер отмены на ActionBlock отменяет все это; мне придется создать новый блок действий, если я его установлю. Можно ли сделать частичную отмену с помощью ActionB...
Этот вопрос касается лучших практик при использовании ContinueWith() для обработки завершения блока данных TPL. ITargetBlock<TInput>.Completion() метод позволяет асинхронно обрабатывать завершение блока данных с помощью ContinueWith(). Рассмотрим следующий код консольного приложения, который демонстри...
У меня есть TransformManyBlock со следующей конструкцией: ввод: путь к файлу вывод: IEnumerable содержимого файла, по одной строке за раз Я запускаю этот блок на огромном файле (61 ГБ), который слишком велик, чтобы поместиться в оперативной памяти. Чтобы избежать неограниченного роста памяти, я установи...
тизер: ребята, это вопрос не о том, как реализовать политику повтора. Речь идет о правильном завершении блока потока данных TPL. этот вопрос является продолжением моего предыдущего вопроса повторить политику в ITargetBlock. Ответом на этот вопрос было умное решение @svick, которое использует TransformBlock (...