Утилизация данных потока данных TPL

Question

Я работаю над инструментом обработки звука, который я хотел бы построить с использованием потока данных TPL. Сам поток данных будет состоять из звуковых образцов, передаваемых между блоками обработки звука. Эти образцы обычно будут иметь размер в несколько К (float[]/byte[] с элементами от 1 до 4 тыс.). Поток данных, таким образом, простой трубопровод, который выглядит следующим образом:

SourceBlock<byte[]> 
    -> TransformBlock<byte[], float[]> 
     -> TransformBlock<float[], float[]> 
      -> ... 

Некоторые из блоков может работать чисто «на месте», т.е. мутирует входные данные, в то время как другие должны создать новые образцы. Время обработки каждого блока может варьироваться в зависимости от данных на входе.

Я не хочу постоянно выделять новые массивы и полагаться на сборщик мусора, чтобы заботиться об утилизации объектов. Я хочу использовать параллельное выполнение блоков и, следовательно, не хочу ограничивать цепочку обработкой данных последовательно (в этом случае мне не понадобится TPL в любом случае). Мне не нужны блоки обработки, чтобы запускать параллельную обработку (я в порядке с одним процессом на блок в любой момент времени).

Какая была бы лучшая схема для управления количеством образцов в конвейере в данный момент времени и повторная выборка образцов/массивов больше не использовалась?

Answer 1

Если ваша цель состоит в том, чтобы повторно использовать массивы вместо того, чтобы всегда создавать новые и имеющие GC собирать их нужно использовать ObjectPool:

Узор пула объектов представляют собой программное обеспечение порождающих шаблоны проектирования дизайна, который использует набор инициализированных объектов, готовых к использованию, - «пул» - вместо того, чтобы распределять и уничтожать их по требованию. Клиент пула будет запрашивать объект из пула и выполнять операции с возвращенным объектом. Когда клиент закончил, он возвращает объект в пул, а не уничтожает его; это можно сделать вручную или автоматически.

К сожалению, вам, вероятно, потребуется реализовать это самостоятельно и сделать его потокобезопасным.