Я процесс ETL Я извлекаю много объектов из репозитория данных Spring. Затем я использую параллельный поток для сопоставления объектов с разными. Я могу либо использовать пользователя для хранения этих новых объектов в другом репозитории один за другим, либо собирать их в список и хранить их в одной массовой операции. Первое дорого, в то время как более поздняя версия может превышать доступную память.
Есть ли хороший способ собрать определенное количество элементов в потоке (например, ограничение), использовать этот кусок и продолжать параллельно, пока все элементы не будут обработаны?