Что такое Stream API в Java?

Stream API в Java

Stream API — это принципиально новый способ работы с наборами данных, представленный в Java 8 как часть проекта Lambda. Это не структура данных, а абстракция для выполнения операций над последовательностями элементов (коллекциями, массивами, генераторами) в декларативном и часто функциональном стиле, с поддержкой цепочек операций и внутренней итерации.

Ключевые характеристики Stream API

• Не хранит данные: Сам Stream не является структурой данных. Он получает элементы из источника (коллекция, массив, I/O канал), обрабатывает их и передаёт результат.
• Функциональность без побочных эффектов (идеально): Операции (особенно промежуточные) должны быть stateless (не зависеть от внешнего состояния) и по возможности non-interfering (не модифицировать источник).
• Ленивые вычисления (lazy evaluation): Промежуточные операции (например, filter, map) не выполняются сразу, а формируют новый Stream. Вычисления начинаются только при вызове терминальной операции (например, collect, forEach).
• Одноразовость: После вызова терминальной операции Stream считается потреблённым и его нельзя использовать повторно. Для новой цепочки операций нужно создать новый Stream.
• Возможность параллельного выполнения: С помощью метода .parallel() (или создания параллельного стрима) цепочка операций может быть автоматически распределена по ядрам процессора, что потенциально ускоряет обработку больших объёмов данных.

Основные компоненты Stream API

1. Источник (Source): Коллекция (list.stream()), массив (Arrays.stream(array)), примитивные стримы (IntStream.range()), файлы (Files.lines()), генераторы (Stream.iterate()).
2. Промежуточные операции (Intermediate Operations): Возвращают новый Stream, позволяя строить конвейер.

    *   **`filter(Predicate<T>)`** – отфильтровать элементы по условию.
    *   **`map(Function<T, R>)`** – преобразовать каждый элемент.
    *   **`sorted()` / `sorted(Comparator)`** – сортировка.
    *   **`distinct()`** – убрать дубликаты.
    *   **`limit(long n)`** – ограничить количество элементов.
    *   **`skip(long n)`** – пропустить первые n элементов.
    *   **`peek(Consumer<T>)`** – выполнить действие для каждого элемента (часто для отладки).

1. Терминальные операции (Terminal Operations): Запускают выполнение конвейера и производят результат или побочный эффект. После их вызова Stream закрывается.

    *   **`forEach(Consumer<T>)`** – выполнить действие для каждого элемента.
    *   **`collect(Collector)`** – собрать элементы в коллекцию или другую структуру.
    *   **`toList()`** (с Java 16) – собрать элементы в неизменяемый список.
    *   **`reduce(...)`** – свернуть элементы в одно значение (например, сумму).
    *   **`min()` / `max()` / `count()`** – найти минимум, максимум, количество.
    *   **`anyMatch()` / `allMatch()` / `noneMatch()`** – проверка условий.

Пример использования

Рассмотрим задачу: из списка сотрудников выбрать имена трёх самых старших (по возрасту), приведя их к верхнему регистру.

import java.util.List;
import java.util.Comparator;

public class StreamExample {
    record Employee(String name, int age) {}

    public static void main(String[] args) {
        List<Employee> employees = List.of(
            new Employee("Иван", 25),
            new Employee("Мария", 30),
            new Employee("Пётр", 45),
            new Employee("Анна", 28),
            new Employee("Сергей", 50)
        );

        List<String> result = employees.stream()           // 1. Создать Stream из списка
                .sorted(Comparator.comparing(Employee::age).reversed()) // 2. Сортировать по возрасту по убыванию
                .limit(3)                                  // 3. Взять первые 3 элемента
                .map(emp -> emp.name().toUpperCase())      // 4. Преобразовать Employee в Имя в верхнем регистре
                .toList();                                 // 5. Собрать результаты в List (терминальная операция!)

        System.out.println(result); // Вывод: [СЕРГЕЙ, ПЁТР, МАРИЯ]
    }
}

Параллельные стримы

Одно из главных преимуществ — простое распараллеливание. Заменив .stream() на .parallelStream(), мы можем ускорить обработку на многопроцессорных системах, но с важными оговорками:

• Потокобезопасность: Источник данных должен быть потокобезопасным или effectively immutable.
• Издержки: Для маленьких коллекций накладные расходы на создание потоков могут перевесить выгоду.
• Порядок: Операции findFirst или порядок в forEach могут быть недетерминированными.

long count = largeList.parallelStream()
                     .filter(s -> s.length() > 10)
                     .count(); // Подсчёт выполняется параллельно

Важные отличия от коллекций (Collection)

Итог: Stream API — это мощный инструмент для написания более чистого, читаемого и часто более производительного кода для обработки данных. Он позволяет перейти от императивного стиля «как делать» к декларативному «что нужно сделать», фокусируясь на логике преобразований, а не на механике итераций. Его правильное использование — обязательный навык для современного Java-разработчика.