Backpressure — механизм, через который консьюмер говорит продюсеру «притормози». TCP делает это с 70-х. Вопрос не нужен ли он, а какой именно.
System.Threading.Channels
В .NET есть
System.Threading.Channels — асинхронная труба между продюсером и консьюмером. Канал бывает bounded или unbounded. Этот выбор определяет стратегию backpressure.Drop
Данные живут секунды (телеметрия, тикеры). Важно последнее, а не каждое.
Channel.CreateBounded<SensorReading>(
new BoundedChannelOptions(500)
{ FullMode = BoundedChannelFullMode.DropOldest });
Продюсер не блокируется, консьюмер не голодает. Цена — потеря данных. Для аудита неприемлемо, для дашборда — осознанный выбор.
Buffer
Каждый элемент важен, консьюмер не успевает.
Channel.CreateUnbounded<OrderEvent>(
new UnboundedChannelOptions { SingleReader = true });
Unbounded-канал растёт, пока процесс не упрётся в память. Честная версия — «буфер с бюджетом». Внешний брокер (Kafka, RabbitMQ) или мониторинг глубины очереди. Если
reader.Count растёт и не выравнивается — память не поможет.Throttle
Продюсер может замедлиться. ETL-джоб не пострадает от лишних 200 мс.
Channel.CreateBounded<DataRecord>(
new BoundedChannelOptions(1000)
{ FullMode = BoundedChannelFullMode.Wait });
Когда канал полон,
WriteAsync ждёт освобождения слота. Пайплайн работает на скорости самого медленного участника. Цена — latency.Как выбирать
Drop — стабильность ценой полноты данных.
Buffer — полнота ценой памяти. Без мониторинга это бомба.
Throttle — полнота и стабильность ценой latency.
Большинство систем комбинируют. Решите, что произойдёт при заполнении очереди, до того как она заполнится.
📍 Навигация: Вакансии • Задачи • Собесы
🐸 Библиотека шарписта
#il_люминатор