Вопросы по теме 'tpl-dataflow'
Поток данных TPL и вызовы асинхронных методов
Я пытаюсь лучше понять всю концепцию параллельной обработки и настроил тестовые примеры. Поиграв с тестами, я вижу, что использование вызовов методов Async в Dataflow ActionBlock (или TransformBlock ) не влияет положительно на производительность,...
3566 просмотров
schedule
26.09.2021
Исключение потока данных TPL в блоке преобразования с ограниченной емкостью
Мне нужно построить конвейер потока данных TPL, который будет обрабатывать множество сообщений. Поскольку сообщений много, я не могу просто Post их поместить в бесконечную очередь BufferBlock , иначе я столкнусь с проблемами памяти. Поэтому я...
3326 просмотров
schedule
22.09.2021
TPL Dataflow: как дросселировать весь конвейер?
Я хочу ограничить количество элементов, размещаемых в конвейере потока данных. Количество элементов зависит от производственной среды. Эти объекты потребляют большой объем памяти (изображений), поэтому я хотел бы опубликовать их, когда последний...
2631 просмотров
schedule
23.10.2021
Глобальная поблочная обработка ошибок в конвейере потока данных
Я разрабатываю долгосрочный конвейер потока данных, состоящий из нескольких блоков. Элементы подаются во входной блок конвейера, в конечном итоге проходят через него и отображаются в пользовательском интерфейсе в конце (в знак любезности для...
804 просмотров
schedule
04.11.2021
Как создать бесконечную сетку DataFlow с обработкой исключений?
Я создаю процессор задач, который использует TPL DataFlow. Я буду следовать модели производителя и потребителя, в которой производитель производит некоторые товары, которые время от времени обрабатываются, а потребители продолжают ждать прибытия...
533 просмотров
schedule
04.11.2021
TPL Dataflow LinkTo TransformBlock очень медленный
У меня есть два блока TransformBlocks, которые расположены в виде цикла. Они связывают свои данные друг с другом. TransformBlock 1 - это блок ввода-вывода для чтения данных, который ограничен максимум 50 задачами. Он читает данные и некоторые...
743 просмотров
schedule
06.10.2021
TPL Dataflow - блок не обрабатывается должным образом
У меня есть набор простых блоков, которые в основном обрабатываются последовательно, но у меня есть два блока, которые я хочу обрабатывать параллельно (processblock1 и processblock2). Я только начал экспериментировать с блоками данных TPL, так что...
45 просмотров
schedule
26.10.2021
Как обработать полный список входных данных с помощью TPL Dataflow?
Я новичок в TPL Dataflow, и у меня он работает, но я не уверен, правильно ли я его использую. У меня есть список входных данных (строк), и я хочу обработать их (все) с максимальной степенью параллелизма и знать, когда все это будет завершено. Прямо...
157 просмотров
schedule
04.12.2021
TPL Dataflow обрабатывает каждый файл синхронно, но каждую строку в файле асинхронно
Итак, мой вариант использования требует, чтобы я обработал список файлов, где для каждого файла в списке я просматриваю каждую строку и выполняю некоторые вычисления в этой строке. Теперь моя проблема в том, что у меня не может быть нескольких строк...
89 просмотров
schedule
04.03.2022
TPL DataFlow: создание пользовательского разделенного блока
просто нужна помощь в создании собственного разделенного блока с помощью библиотеки потоков данных, которая является частью TPL в .Net.
Все, чего я хочу добиться, — это простой пользовательский блок, который принимает ввод и разбивает его на...
1312 просмотров
schedule
15.03.2022
Поток данных TPL - условные циклы
В настоящее время я работаю над конвейерным потоком данных, где каждый этап, кроме этапа 1, является async запущенным потребителем и производителем. У меня есть объекты, «текущие» по моему конвейеру, которые ссылаются на элементы. На этапе 3 я...
816 просмотров
schedule
25.03.2022
TPL Dataflow - как вызвать несколько элементов элемента действия
Я новичок в TPL Dataflow . У меня есть список номеров проектов, которые мне нужно обработать. В проекте может быть около 8000 элементов, и мне нужно получить данные для каждого элемента в проекте, а затем отправить эти данные на 5 отдельных...
714 просмотров
schedule
25.03.2022
Как синхронно объединить два конвейера TPL DataFlow?
Я хочу написать приложение, которое оценивает данные датчиков с двух датчиков. Оба датчика отправляют свои данные в Package объектах, которые разделены на Frame объекта. Package - это, по сути, Tuple<Timestamp, Data[]> , Frame - это...
521 просмотров
schedule
29.03.2022
Заставить задачу продолжить текущий поток?
Я делаю перенос фреймворка AKKA для .NET (не воспринимайте это слишком серьезно, сейчас это часть актерской части на выходных)
У меня проблемы с поддержкой "Future" в нем. В Java / Scala Akka Futures следует ожидать синхронно с вызовом Await....
2202 просмотров
schedule
11.04.2022
TPL Dataflow Broadcastblock отбрасывает последнее сообщение
У меня довольно простая проблема. Мне нужен способ легко выполнять некоторую обработку сообщений, которая занимает некоторое время. В процессе обработки могут быть введены новые запросы, но все запросы, кроме последнего, могут быть отброшены....
975 просмотров
schedule
17.05.2022
Создание шины сообщений с помощью TPL Dataflow
Я искал легкую, обрабатываемую шину асинхронных сообщений и наткнулся на TPL Dataflow.
Моя текущая реализация приведена ниже (полный пример см. https://gist.github.com/4416655 ).
public class Bus
{
private readonly...
3953 просмотров
schedule
28.05.2022
Применим ли TPL-Dataflow для высокопараллельных приложений?
Я изучаю, способен ли TPL-Dataflow избавить нас от написания шаблонного кода с блокировками и мониторами для наших высококонкурентных приложений.
Итак, я моделирую простой сценарий с одним производителем и несколькими потребителями, каждый из...
70 просмотров
schedule
13.06.2022
Элементы TransformBlock застревают в очереди вывода. Почему и как исправить?
Я прошел через поток данных TPL и столкнулся с очень раздражающей проблемой, возникшей в коде, использующем TrasformBlock , связанный с ActionBlock .
В конце концов я обнаружил, что элементы застряли в выходной очереди TransformBlock , так как...
753 просмотров
schedule
29.06.2022
Использование Polly с потоком данных TPL
Конвейеры обработки данных и обработка временных сбоев, кажется, идут рука об руку, поэтому мне интересно посмотреть, смогу ли я получить 2 лучшие библиотеки для них — TPL Dataflow и Polly , соответственно - для приятной игры вместе.
В качестве...
329 просмотров
schedule
15.09.2022
Проблемы со ссылками на TPL Dataflow и TPL в VS 2012 RC
Я только что обновил бета-версию Visual Studio 11 до новой версии Visual Studio 2012 RC, и у меня возникли проблемы со ссылкой на поток данных TPL.
Во-первых, я попытался сослаться на Dataflow, как и раньше, добавив ссылку из фреймворка. Но когда...
11145 просмотров
schedule
15.03.2023
