Есть ли реализация BufferBlock от Filo?
Я засовываю сообщения в BufferBlock
, который я затем хочу направить в один из двух BufferBlocks. Основной блок (P) будет получать все сообщения до тех пор, пока в буфере не будет определенное количество сообщений. Как только буфер P заполнен, я хочу засунуть сообщения в FILO BufferBlock
(S). Затем я хочу использовать из этих буферов через ActionBlock
где приоритет на S, если у него есть сообщения.
Я думаю, что я могу понять, как все правильно собрать, но я попытался посмотреть на реализацию BufferBlock
в corefx, и я не думаю, что у меня есть то, что нужно, чтобы сделать это FILO.
TLDR: уже есть реализация BufferBlock
это FILO или есть простой (относительный) способ сделать BufferBlock
FILO, изменив его источник из corefx?
1 ответ
Есть ли уже реализация
BufferBlock
это FILO или есть простой (относительный) способ сделатьBufferBlock
FILO, изменив его источник изcorefx
?
Не в стандартной библиотеке. Если вы хотите создать новый блок, вы должны реализовать базовые интерфейсы (например, IPropagatorBlock
) или используйте статический метод DataflowBlock.Encapsulate
, не изменять код стандартного блока.
Вы можете найти дополнительную информацию о MSDN или в официальном введении в поток данных TPL.