Java for Beginner

Раздел 8. Stream API и функциональный стиль в Java

Глава 5: Контракты. Почему equals, hashCode и иммутабельность — закон

Иммутабельность данных в потоке — не прихоть, а необходимость

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

Когда мы говорим "поток обрабатывает данные, а не изменяет их", мы противопоставляем два ментальных модуса: трансформацию как порождение нового и мутацию как изменение существующего. Императивный код часто смешивает их: цикл читает элемент, модифицирует его поля, кладёт в результат. Потоковый код разделяет: исходные данные остаются неизменными, каждая операция порождает новое представление.

Контракт неизменности источника

Исходная коллекция, породившая поток, не должна модифицироваться во время обхода. Это правило кажется очевидным, но нарушается из-за недопонимания ленивости:

List<Book> library = new ArrayList<>(fetchBooks());
Stream<Book> stream = library.stream();  // Поток создан, но не активирован

// Позже, до терминальной операции:
library.add(new Book("New", "Author", 2024));  // Модификация источника!

// Теперь терминальная операция:
List<Book> result = stream.collect(toList());  // ConcurrentModificationException?

Поведение неопределённо. Если поток использует Iterator (коллекция не SIZED), модификация после создания потока, но до начала обхода выбросит ConcurrentModificationException при проверке modCount. Если поток использует Spliterator с характеристикой SIZED (например, ArrayList), и терминальная операция предвыделяет размер, добавление элемента приведёт к ArrayIndexOutOfBoundsException или пропуску элементов.

Ещё опаснее модификация внутри потоковой операции:

// Катастрофа: модификация источника изнутри потока
library.stream()
    .filter(b -> b.year() < 1950)
    .forEach(library::remove);  // ConcurrentModificationException гарантирован

Удаление элементов из коллекции во время её обхода — классическая ошибка, приводящая к исключению или пропуску элементов из-за сдвига индексов.

Правильный подход — создание новой коллекции вместо модификации существующей:

// Правильно: фильтрация через collect, не removeIf в потоке
List<Book> modernBooks = library.stream()
    .filter(b -> b.year() >= 1950)
    .collect(toList());

// Или без потока, если модификация исходной нужна:
library.removeIf(b -> b.year() < 1950);  // Метод коллекции, не Stream API

Иммутабельность промежуточных результатов

Не только источник, но и объекты в потоке должны быть неизменяемыми для корректности.

Рассмотрим изменяемый объект в map:

public class MutableBook {
    private String title;
    private int readCount;  // Мутабельное поле!
    
    public void incrementRead() { readCount++; }
}

// Антипаттерн: мутация внутри потока
List<MutableBook> books = fetchBooks();
books.stream()
    .filter(b -> b.getTitle().startsWith("A"))
    .forEach(MutableBook::incrementRead);  //Модифицируем исходные объекты!

// Теперь исходный список books изменён — побочный эффект

forEach здесь используется не для агрегации, а для побочного эффекта — инкремента счётчика. Исходные объекты модифицированы, что делает код сложным для отладки и тестирования. Если позже тот же список обрабатывается другим потоком, результаты зависят от порядка выполнения.

Рефакторинг к иммутабельности:

public record Book(String title, int readCount) {
    public Book withIncrementedRead() {
        return new Book(title, readCount + 1);  //Новый экземпляр
    }
}

// Правильно: создание новых объектов
List<Book> updatedBooks = books.stream()
    .filter(b -> b.title().startsWith("A"))
    .map(Book::withIncrementedRead)
    .collect(toList());

// Исходный список books неизменён

Здесь "обновление" — порождение новой версии объекта, а не модификация существующего. Старые данные сохраняются, новые создаются, история не разрушается.

#Java #для_новичков #beginner #stream_api

👍6

110 views08:59