Введение в Stream API: зачем нужны потоки

1. Проблема императивного подхода

Давайте начнём с классической задачи. Пусть у нас есть список пользователей:

List<User> users = ...; // уже заполнен

Допустим, нам нужно получить список имён всех совершеннолетних пользователей (от 18 лет). Как мы это делали раньше?

List<String> names = new ArrayList<>();
for (User user : users) {
    if (user.getAge() >= 18) {
        names.add(user.getName());
    }
}

На первый взгляд всё просто, но обратите внимание на «технические» шаги: объявить новый список для результата, пройтись по всем элементам, проверить условие, добавить результат.

Если задача усложняется — например, нужно получить отсортированный по алфавиту список уникальных e-mail всех пользователей, чьи имена начинаются с буквы «А» — то код быстро разрастается: фильтрация, извлечение полей, удаление дубликатов, сортировка, возможно преобразования формата e‑mail и т.д. В результате вместо короткой понятной логики вы получаете гору бойлерплейта, который трудно читать и поддерживать.

Минусы такого подхода в двух словах: много повторяющегося кода, высокая вероятность допустить ошибку (забыть про сортировку или неправильно обработать дубликаты), и сложность комбинирования операций. Это и называется императивный стиль: вы шаг за шагом описываете компьютеру, как выполнять задачу, а не что вы хотите получить.

2. Stream API — декларативный стиль

С выходом Java 8 появился Stream API — инструмент, который позволяет работать с коллекциями в стиле «что нужно сделать», а не «как именно это сделать». Такой подход и называется декларативным.

А что такое Stream вообще?
Это не отдельная коллекция, а скорее поток данных: последовательность элементов, которые проходят через цепочку операций — фильтрацию, преобразование, сортировку, сбор результата и т.д. Поток ничего не хранит, он просто «протаскивает» данные через конвейер. Операции можно комбинировать почти как кубики LEGO: собрали цепочку и запустили.

Пример:

List<String> names = users.stream()                // создаём поток из списка пользователей
    .filter(u -> u.getAge() >= 18)                 // оставляем только тех, кому уже есть 18 лет
    .map(User::getName)                            // преобразуем User → String (берём имя)
    .collect(Collectors.toList());                 // собираем результат в список

И всё — одной строкой мы описали всю задачу: «возьми пользователей, отфильтруй по возрасту, достань имена, собери в список». Не нужно вручную писать циклы, создавать временные переменные и следить, чтобы ничего не забыть.

Stream API работает как заводской конвейер: вы задаёте этапы обработки, а данные сами проходят через них. Красиво, компактно и читается в разы проще.

3. Преимущества Stream API

• Краткость и читаемость. Сравните два подхода — императивный и декларативный — на одной и той же задаче. Сразу видно, какой из них легче читать и поддерживать.
• Лёгкая композиция операций. Операции легко «складывать» в цепочку: filter, map, sorted, collect — и всё это в одной связной последовательности.
• Меньше ошибок. Stream API избавляет от рутины: не нужно вручную управлять промежуточными коллекциями и циклами — ниже шанс забыть шаг или сделать ошибку индексации.
• Возможность параллелизма. Легко масштабировать обработку на несколько ядер, просто вызвав parallelStream() вместо stream(). Подробности — позже.
• Современный стиль программирования. Идеи функционального программирования (композиция функций, отсутствие явных циклов) повышают выразительность и ценятся на рынке.

Краткая история Stream API

Stream API появился в Java 8 (2014) и стал качественным скачком для языка. До этого любая нетривиальная операция над коллекциями требовала много вспомогательного кода, тогда как другие платформы уже предлагали декларативные подходы (map, filter, reduce и т.п.).

С тех пор Stream API — стандарт де‑факто для обработки коллекций в Java. Если вы хотите писать современный Java‑код — без него никуда.

4. Области применения Stream API

• Фильтрация: выбрать только нужные элементы (например, все пользователи старше 18 лет).
• Преобразование: извлечь поле или создать новый объект (например, список имён пользователей).
• Агрегация: посчитать сумму, среднее, количество, максимум/минимум.
• Сортировка: упорядочить элементы по нужному признаку.
• Группировка: разбить элементы по категориям.
• Сборка результата: собрать в список, множество, карту, строку и т.д.

Примеры задач:

• Получить список e‑mail всех пользователей, чьё имя начинается на «А».
• Посчитать средний возраст пользователей.
• Найти первого пользователя с определённым e‑mail.
• Собрать все уникальные города проживания в одно множество.

5. Полезные нюансы

Как работает поток

[User1] --\
[User2] ---|--> [ filter ] --> [ map ] --> [ collect ] --> List<String>
[User3] --/

1. filter — пропускает только пользователей, удовлетворяющих условию.
2. map — преобразует пользователя в, например, e‑mail.
3. collect — собирает e‑mail в нужную коллекцию.

Синтаксис: как создать поток

• Из коллекции: list.stream() — поток элементов коллекции.
• Из массива: Arrays.stream(array)
• Из отдельных значений: Stream.of("a", "b", "c")

6. Типичные ошибки при переходе на Stream API

Ошибка №1: попытка изменить коллекцию внутри потока. Stream API не предназначен для модификации исходной коллекции (например, не стоит делать list.remove() в теле forEach). Для удалений используйте, к примеру, removeIf на коллекции до или после обработки.

Ошибка №2: путаница между коллекцией и потоком. Поток — это не коллекция! Поток «проходит» по элементам один раз, после чего закрывается. Если нужно снова обработать данные — создайте новый stream().

Ошибка №3: слишком сложные цепочки. Не превращайте выражение в «монстра» из десятка операций. Если цепочка становится длинной — разбейте её на несколько шагов с промежуточными переменными для читаемости и отладки.