Установить размер партии / разбиения параллельной коллекции Scala

Question

Я использую параллельную последовательность, в которой вычисления выполняются для одного элемента, и он недостаточно велик, чтобы оправдать переключение контекста и затраты на его выполнение в отдельном потоке.Вместо этого я хотел бы разделить коллекцию на 16 частей или на партии по 1000 наименований и запустить их параллельно.Является ли это возможным?

Answer 1

Здесь вы можете использовать Параллельные Коллекции. Если вы уже это сделали, вы можете настроить их поведение.

Из документации:

В настоящее время существует несколько реализаций поддержки задач, доступных для параллельных коллекций. В ForkJoinTaskSupport внутренне используется пул разветвления

Смотрите здесь https://docs.scala -lang.org / обзоров / параллельная-коллекция / configuration.html