Вопросы по теме 'tpl-dataflow'
Очевидная гонка/ошибка BufferBlock.Post/Receive/ReceiveAsync
отправлено на http://social.msdn.microsoft.com/Forums/en-US/tpldataflow/thread/89b3f71d-3777-4fad-9c11-50d8dc81a4a9
Я знаю... На самом деле я не использую TplDataflow по максимуму. ATM Я просто использую BufferBlock как безопасную очередь...
1835 просмотров
schedule
15.09.2022
Задачи против TPL Dataflow против Async / Await, что использовать, когда?
Я прочитал довольно много технических документов от некоторых из команды Microsoft или других авторов, подробно описывающих функциональность новой библиотеки TPL Dataflow, фреймворков async / await для параллелизма и TPL. Тем не менее, я не встречал...
4107 просмотров
schedule
25.09.2022
Свяжите результат конвейера потока данных TPL с начальным сообщением
Я работаю над созданием конвейера потока данных, который отвечает за асинхронную обработку запросов HttpRequest, отправленных в HttpListener . Чтобы ответить на запрос, мне, возможно, придется выполнить некоторые трудоемкие операции, такие как...
334 просмотров
schedule
23.08.2022
Использование Orderby для BatchedJoinBlock (из T1, T2) — поток данных (библиотека параллельных задач)
Я просто хочу иметь возможность сортировать результаты BatchedJoinBlock ( http://msdn.microsoft.com/en-us/library/hh194683.aspx ), чтобы разные результаты разных целей оставались вместе. Я объясню! Пример в некотором псевдокоде:
Dim batchedJoin...
109 просмотров
schedule
23.10.2023
Должны ли элементы, передаваемые в сети потока данных TPL, быть DTO или POCO?
(Теперь, когда я привлек ваше внимание к аббревиатурам...)
Может быть, лучше задать вопрос так: Когда следует использовать DTO и когда POCO в сети потока данных TPL ? (Потому что лучший выбор может зависеть от обстоятельств).
Я сделал это...
157 просмотров
schedule
24.04.2023
Поток данных TPL - контроль того, какие элементы находятся в потоке в любой момент
Мне нужно обработать файлы, которые нам присылают продавцы. Каждое имя файла будет содержать идентификатор продавца. Например. Товары - 118763.csv, где число - идентификатор продавца.
Я хочу настроить поток данных для обработки этих файлов....
225 просмотров
schedule
09.04.2023
Включает ли BoundedCapacity элементы, которые в настоящее время обрабатываются в потоке данных TPL?
Включает ли лимит BoundedCapacity только элементы во входной очереди, ожидающие обработки, или он также учитывает элементы, обрабатываемые в данный момент?
Возьмем, к примеру, это ActionBlock :
var block = new ActionBlock<int>(
i...
2152 просмотров
schedule
11.06.2022
Есть ли такой блок потока данных, как TransformBlock ‹TIn, TOut›, который позволяет передавать элементы вне последовательности?
Я относительно новичок в асинхронной обработке и экспериментирую с TPL Dataflow. Мой сценарий: у меня есть блок, который постоянно получает входные данные, асинхронно выполняет функцию на входе и возвращает результаты. (Результаты затем передаются в...
167 просмотров
schedule
02.09.2022
Подождите, пока предыдущие блоки закончат обработку, прежде чем продолжить
У меня есть процесс, который выглядит так.
Получить набор файлов CSV из папки
Прочитайте файлы CSV и сохраните содержимое в базе данных.
Прочитайте данные из базы данных и выполните дополнительную обработку.
Причина разделения шагов 2 и...
351 просмотров
schedule
15.09.2022
Поток данных TPL, BroadcastBlock в BatchBlocks
У меня проблема с подключением BroadcastBlock(s) к BatchBlocks . Сценарий таков, что источники BroadcastBlocks , а получатели BatchBlocks .
В приведенном ниже упрощенном коде выполняется только один из дополнительных блоков действий. Я даже...
920 просмотров
schedule
01.07.2022
Блок потока данных TPL потребляет всю доступную память
У меня есть TransformManyBlock со следующим дизайном:
Ввод: путь к файлу
Вывод: IEnumerable содержимого файла, по одной строке за раз
Я запускаю этот блок в огромном файле (61 ГБ), который слишком велик, чтобы поместиться в ОЗУ. Чтобы...
3096 просмотров
schedule
15.09.2022
Типы сообщений с блоками DataFlow
Я занимаюсь самообучением TPL-Dataflow , и я читал, что использование неизменяемых объектов для сообщений - это путь.
Чтобы соответствовать этому, я разработал специальные классы для каждого входа и выхода блока.
К сожалению, когда я связываю...
132 просмотров
schedule
06.12.2022
OperationCanceledException, созданное в блоке потока данных tpl, проглатывается
По какой-то причине, когда OperationCanceledException выбрасывается внутри IDataflowBlock , блок не распространяет это исключение на свою задачу IDataflowBlock.Completion . Выполнение приведенного ниже примера кода возвращает неожиданную ошибку...
256 просмотров
schedule
08.08.2023
ActionBlock‹T› против Task.WhenAll
Я хотел бы знать, каков рекомендуемый способ параллельного выполнения нескольких асинхронных методов?
в System.Threading.Tasks.Dataflow мы можем указать максимальную степень параллелизма, но unbounded, вероятно, используется по умолчанию и для...
2231 просмотров
schedule
07.07.2023
Проводка TransformBlock для вывода
Мой сценарий заключается в том, что у меня есть BufferBlock<Stream> , получающий Stream из внешнего источника, скажем, из файловой системы или какого-то FTP-сервера. Эти файлы Stream перейдут в другой блок и будут обработаны....
321 просмотров
schedule
01.06.2022
Как маршрутизировать, группировать или иным образом разделять сообщения на согласованные наборы с помощью потока данных TPL
Я новичок в потоке данных TPL и ищу конструкцию, которая позволит разделить список исходных сообщений для равномерно распределенной параллельной обработки при сохранении порядка сообщения сообщений через отдельные конвейеры. Есть ли в API DataFlow...
486 просмотров
schedule
28.06.2022
Преобразование моего кода на основе C# BlockingCollection в поток данных TPL
У меня есть конкретная проблема, которую, я уверен, можно решить с помощью потока данных TPL. Я просто новичок в этом, поэтому мне нужна ваша помощь, чтобы ускорить мое понимание. Мой код сейчас такой:
где Процесс1, Процесс2, Процесс3 —...
355 просмотров
schedule
27.12.2022
извлечение zip-архивов, синтаксический анализ файлов и преобразование в CSV
Я пытаюсь добиться максимальной производительности от следующей задачи:
Перечислить каталог с zip-файлами
Извлечение zip-архивов в памяти в поисках .json файлов (обработка вложенных zip-архивов)
Разберите json файлы
Записать свойства из...
248 просмотров
schedule
29.04.2023
Использование AsObservable для наблюдения за блоками потока данных TPL без использования сообщений
У меня есть цепочка блоков потока данных TPL, и я хотел бы наблюдать за прогрессом где-то внутри системы.
Я знаю, что могу просто вставить TransformBlock в меш, где я хочу наблюдать, заставить его опубликовать в каком-нибудь средстве обновления...
1485 просмотров
schedule
29.03.2023
Задача SendAsync потока данных TPL никогда не завершается, когда блок связан
Я надеялся на чистое решение для регулирования определенного типа производителя, пока потребитель занят обработкой, без написания собственного настраиваемого блока. Я надеялся, что приведенный ниже код сделает именно это, но как только SendAsync...
920 просмотров
schedule
28.04.2023
