🌊 JEP 458: Stream Gatherers в Java 22
Java 22 добавила Gatherers — расширение Stream API, которое позволяет собирать элементы не только привычными map/filter/reduce, а своими кастомными способами. Теперь поток можно «собирать» прямо в процессе, без костылей.
📦 Простая идея Gatherer
Stream.of(1, 2, 3, 4, 5)
.gather(Gatherers.windowFixed(2))
.forEach(System.out::println);
➡️ Элементы пакуются по 2 штуки.
Вывод:
[1, 2]
[3, 4]
[5]
🔄 Sliding Window — скользящее окно
Stream.of(1, 2, 3, 4, 5)
.gather(Gatherers.windowSliding(3))
.forEach(System.out::println);
➡️ Формируются окна по 3 элемента с шагом в 1.
Вывод:
[1, 2, 3]
[2, 3, 4]
[3, 4, 5]
🗂 Группировка по условию
Stream.of("a", "b", "x", "y", "c", "d")
.gather(Gatherers.groupUntil(s -> s.equals("x")))
.forEach(System.out::println);
➡️ Группа закрывается, когда встречается "x".
Вывод:
[a, b, x]
[y, c, d]
⚙️ Свой Gatherer
Gatherer sumPairs =
Gatherer.of(
() -> new int[1], // state
(state, e, down) -> {
state[0] += e;
if (state[0] >= 10) {
down.push(state[0]);
state[0] = 0;
}
return true;
},
(state, down) -> {}
);
Stream.of(3, 4, 5, 6, 7)
.gather(sumPairs)
.forEach(System.out::println);
➡️ Числа суммируются, пока не превысят 10, потом сбрасываются.
12
13
📊 Gatherers.fold — промежуточная агрегация
Stream.of(1, 2, 3, 4, 5)
.gather(Gatherers.fold(0, Integer::sum))
.forEach(System.out::println);
➡️ Видим все промежуточные суммы.
Вывод:
1
3
6
10
15
⚖️ Gatherers 🆚 Collectors
Collectors работают в конце стрима (collect(...)).
Gatherers же действуют прямо в процессе, шаг за шагом.
➡️ Это позволяет писать stateful-преобразования, которые раньше выглядели громоздко.
🚀 Реальные применения
1. Буферизация при работе с большими потоками.
2. Batch-загрузки в БД.
3. Скользящие средние и метрики.
4. Stateful-пайплайны без ручного кода.
➡️ Всё это теперь можно писать нативно в Stream API.
🔗 Комбинации
Stream.of(1, 2, 3, 4, 5, 6)
.gather(Gatherers.windowFixed(2))
.map(list -> list.stream().mapToInt(i -> i).sum())
.forEach(System.out::println);
➡️ Сначала разбиваем на пары, потом суммируем каждую.
Вывод:
3
7
11
🗣️ Запомни: Gatherers в Java 22 выводят стримы на новый уровень. Они позволяют обрабатывать данные «на лету» и строить stateful-пайплайны, которые раньше были невозможны без костылей.
0
Показать ещё
