Когда вы используете
AsParallel(), PLINQ по умолчанию буферизует результаты перед тем, как отдать их вызывающему коду. Для небольших коллекций это незаметно. На больших объёмах данных стратегия буферизации напрямую влияет на задержку и пропускную способность.
Метод
WithMergeOptions позволяет явно указать, как PLINQ собирает результаты из параллельных потоков.Как использовать:
var results = items
.AsParallel()
.WithMergeOptions(ParallelMergeOptions.NotBuffered)
.Select(ProcessItem)
.ToList();
Три режима работы
•
AutoBuffered — режим по умолчанию. PLINQ сам выбирает размер буфера. Подходит для большинства сценариев, когда вы не думаете о задержке.•
FullyBuffered — все результаты сначала собираются в памяти, потом отдаются целиком. Полезно, когда важен порядок или когда вы всё равно ждёте полного завершения (например, при сортировке). Даёт максимальную пропускную способность, но первый элемент вы получите только после обработки последнего.•
NotBuffered — результаты отдаются по мере готовности, без накопления. Минимальная задержка до первого элемента. Хорош для стриминговых сценариев или когда нужно начать обработку результатов как можно раньше.Когда это пригодится
Если вы обрабатываете тысячи элементов и хотите показывать прогресс в реальном времени,
NotBuffered сократит время до первого результата. Если же вам нужен отсортированный вывод или полная выборка перед следующим шагом, FullyBuffered будет эффективнее.На маленьких коллекциях разница между режимами минимальна. Оптимизация имеет смысл, когда элементов много или обработка каждого занимает ощутимое время.
📍 Навигация: Вакансии • Задачи • Собесы
🐸 Библиотека шарписта
#sharp_view