tpl-dataflow

4зной

2ответ

Как реализовать непрерывно выполняемые блоки потока данных в TPL?

У меня есть настройка блока потока данных производителя/потребителя с использованием BufferBlock и ActionBlock, и он отлично работает в консольном приложении; После добавления всех предметов в Burffer

3зной

1ответ

Ожидает ActionBlock <T> - TPL DataFlow

Я использую TPL DataFlow и ActionBlock для создания параллелизма. Причина использования TPL DataFlow заключается в том, что он поддерживает асинхронность, за исключением того, что я не могу заставить

0зной

2ответ

Упрощенное решение, чем поток данных TPL для параллельного удаления aync blob

Я реализую рабочую роль на Azure, которая должна удалить капли из хранилища Azure. Предположим, что у моего списка blobs есть около 10K элементов. Самый простой способ синхронизации, вероятно, будет:

1зной

1ответ

TPL Dataflow. Не удается привязать BatchBlock к ActionBlock. Аргумент типа не может быть выведен из использования?

У меня есть этот командный блок как var batchBlock = new BatchBlock<IEnumerable<string>>(10000, new GroupingDataflowBlockOptions { Cancellati

2зной

1ответ

TPL DataFlow: создание пользовательского splitblock

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

0зной

1ответ

Использование Orderby on BatchedJoinBlock (Of T1, T2) - поток данных (параллельная библиотека задач)

Я просто ищу, чтобы иметь возможность сортировать результаты BatchedJoinBlock (http://msdn.microsoft.com/en-us/library/hh194683.aspx), чтобы разные результаты разных целей сохранялись вместе. Я объясн

8зной

1ответ

поток данных tpl: фиксированный размер буфера без отбрасывания элементов

После игры с потоком данных я столкнулся с новой проблемой. Я хотел бы ограничить входной уровень всех блоков. Мой productionblock (ActionBlock) быстро создает 5000 элементов и помещает их в широковещ

1зной

2ответ

C# Dataflow или Tasks, обрабатывающие параллельные запросы

Если я хочу принимать сообщения из внешней очереди, скажем в Redis или аналогично. Является ли это лучше иметь один поток постоянно проверять очереди и отправка сообщений в соответствующей BroadcastBl