BlockingCollection слишком долго просыпается

У меня проблема, когда BlockingCollection<MyItem> слишком долго просыпается от .Take() звонка.

Сценарий таков: у меня есть поток, который очень быстро отправляет данные в BlockingCollection (на самом деле в XUnit я выполнил цикл for. У меня есть 3 Task, которые просто сидят в .Take() вызове и ждут добавления элементов. Из вывода я могу видеть что почти 200 элементов (до 1 секунды или более) были добавлены в коллекцию перед первым Task пробуждением и фактическим сбором данных из BlockingCollection.

У меня есть несколько "буферов" на основе BlockingCollection, организованных конвейерным способом, и все они страдают от слишком длительного пробуждения при выполнении .Take() действия.

Я пробовал .TryTake() и .GetConsumingEnumerable() с теми же результатами.

Идея о том, что в конце этого конвейера у меня есть однопоточная медленная функция, которая обрабатывает элементы один за другим, и для обработки одного элемента может потребоваться неизвестное время. Мне просто нужно убедиться, что "элемент" перешел из "буфера" в "буфер" очень быстро (как только он будет вставлен в первый "буфер")

Мне просто нужно убедиться, что время запуска (в .Take() или .TryTake() и т. Д.) Будет близко к тому времени, когда элемент добавлен в коллекцию