Stream.iterator: примеры (JAVA)

Короткие примеры использования iterator()

Пример 1: базовая итерация по списку

import java.util.*;
import java.util.stream.*;

public class Main {
    public static void main(String[] args) {
        List<String> list = Arrays.asList("a", "b", "c");
        Iterator<String> it = list.stream().iterator();
        while (it.hasNext()) {
            System.out.print(it.next() + " ");
        }
    }
}

Результат:
a b c 

Пример 2: итератор для примитивного потока

import java.util.*;
import java.util.stream.*;

public class Main {
    public static void main(String[] args) {
        PrimitiveIterator.OfInt it = IntStream.range(1, 4).iterator();
        while (it.hasNext()) {
            System.out.print(it.nextInt() + " ");
        }
    }
}

Результат:
1 2 3 

Пример 3: безопасное закрытие ресурсоемкого потока

import java.nio.file.*;
import java.util.*;
import java.util.stream.*;

public class Main {
    public static void main(String[] args) throws Exception {
        Path p = Paths.get("/path/to/file.txt");
        try (Stream<String> lines = Files.lines(p)) {
            Iterator<String> it = lines.iterator();
            while (it.hasNext()) {
                System.out.println(it.next());
            }
        }
    }
}

Результат:
(построчный вывод содержимого файла)

Похожие методы Java и сравнение

Сравнение с альтернативами в Java:

• forEach(Consumer) - терминальная операция, выполняет действие для каждого элемента сразу; удобна для простых операций без явного управления итерацией. Предпочтительна, если не требуется объект Iterator или управление ходом итерации.
• forEachOrdered(Consumer) - для параллельных стримов гарантирует порядок обхода при выполнении действий; используется когда важен порядок выполнения эффектов.
• toArray() и collect() - собирают элементы в структуру данных; предпочтительнее, когда нужен случайный доступ или многократное использование результата.
• spliterator() - возвращает Spliterator, позволяющий более гибко контролировать параллелизм и характеристики разделения; удобен для интеграции с StreamSupport и создания новых стримов.

Выбор зависит от цели: нужен ли стандартный Iterator, требуется ли закрытие ресурса, предполагается ли параллельная обработка или нужно собрать элементы в коллекцию.

Эквиваленты в других языках и их отличия

Краткие аналоги метода iterator() в популярных языках и ключевые различия.

JavaScript (ES6) - итераторы и генераторы:

// Итератор из массива
const arr = [1,2,3];
const it = arr[Symbol.iterator]();
console.log(it.next());
console.log(it.next());
console.log(it.next());
console.log(it.next());

Результат:
{ value: 1, done: false }
{ value: 2, done: false }
{ value: 3, done: false }
{ value: undefined, done: true }

Отличие: JavaScript имеет встроенный протокол итераторов и ленивые генераторы; потоковая API в Node.js использует Readable streams с другим семантикой.

Python - функция iter() и генераторы:

lst = [1,2,3]
it = iter(lst)
print(next(it))
print(next(it))
print(next(it))

Результат:
1
2
3

Отличие: iter() возвращает итератор для любого итерируемого объекта; генераторы легко создавать через yield; нет явного разделения на промежуточные и терминальные операции как в Java Stream.

Python (IO) - итерация по строкам файла автоматически закрывает файл через with:

with open('file.txt') as f:
    for line in f:
        print(line.strip())

Результат:
(построчный вывод файла)

C# - IEnumerable.GetEnumerator:

var list = new List<int>{1,2,3};
var enumerator = list.GetEnumerator();
while (enumerator.MoveNext())
    Console.WriteLine(enumerator.Current);

Результат:
1
2
3

Отличие: LINQ предоставляет отложенные последовательности, но IEnumerable и IEnumerator - стандарт для итерации; управление ресурсами через IDisposable.

Kotlin - Sequence.iterator():

val seq = sequence { yieldAll(listOf(1,2,3)) }
val it = seq.iterator()
while (it.hasNext()) println(it.next())

Результат:
1
2
3

Отличие: Kotlin Sequence похож на Java Stream по ленивости, но более интегрирован с языком и коллекциями.

Go - явных итераторов нет, применяются срезы и range или каналы:

slice := []int{1,2,3}
for _, v := range slice {
    fmt.Println(v)
}

Результат:
1
2
3

Отличие: Go использует простые конструкции, нет отдельного интерфейса Iterator в стандартной библиотеке.

PHP - Iterator и Generator:

function gen() { yield 1; yield 2; yield 3; }
$it = gen();
foreach ($it as $v) echo $v . "\n";

Результат:
1
2
3

Отличие: генераторы просты в использовании; PHP-итераторы интегрированы с foreach.

SQL - курсоры для построчной обработки результата запроса; семантика и управление ресурсами зависят от СУБД и драйвера.

Типичные ошибки при использовании iterator()

• Повторный вызов методов потока после получения итератора. Пример:

Stream<String> s = Stream.of("a", "b");
Iterator<String> it = s.iterator();
s.forEach(System.out::println); // Ошибка: поток уже использован

Результат:
java.lang.IllegalStateException: stream has already been operated upon or closed

• Игнорирование закрытия ресурсоемкого потока. Пример:

// Files.lines() без закрытия
Stream<String> lines = Files.lines(Paths.get("file.txt"));
Iterator<String> it = lines.iterator();
// если пропустить close(), файл останется открыт

Результат:
(возможная блокировка файла или утечка дескриптора в зависимости от ОС)

• Параллельный доступ к итератору из нескольких потоков. Итератор не потокобезопасен, возможны состояния гонки и некорректные результаты.
• Ожидание порядка элементов у неупорядоченного источника при параллельной обработке - результат может отличаться.
• Приведение типов при работе с примитивными и объектными итераторами (например, ожидание Iterator<Integer> при использовании IntStream).

Изменения и эволюция метода

Метод iterator() доступен с ранних версий Stream API (Java 8) и с тех пор принципиально не менял сигнатуру и поведение. В новом коде появляются дополнительные утилиты вокруг Spliterator и StreamSupport, но сам метод остался простым мостом от Stream к Iterator. Непрерывные улучшения платформы не влияют на контракт этого метода.

Расширенные варианты и нетипичные примеры

Пример 1: обёртка Iterator в Spliterator и обратная конверсия в Stream

import java.util.*;
import java.util.stream.*;

public class Main {
    public static void main(String[] args) {
        Iterator<String> it = Arrays.asList("x","y","z").iterator();
        Spliterator<String> sp = Spliterators.spliteratorUnknownSize(it, 0);
        Stream<String> s = StreamSupport.stream(sp, false);
        s.map(String::toUpperCase).forEach(System.out::println);
    }
}

Результат:
X
Y
Z

Пояснение: иногда требуется преобразовать готовый итератор обратно в Stream для применения операций конвейера.

Пример 2: комбинирование нескольких итераторов в одном стриме

import java.util.*;
import java.util.stream.*;

public class Main {
    public static void main(String[] args) {
        Iterator<Integer> a = Arrays.asList(1,2).stream().iterator();
        Iterator<Integer> b = Arrays.asList(3,4).stream().iterator();
        // объединение через StreamSupport
        Stream<Integer> combined = Stream.concat(
            StreamSupport.stream(Spliterators.spliteratorUnknownSize(a, 0), false),
            StreamSupport.stream(Spliterators.spliteratorUnknownSize(b, 0), false)
        );
        combined.forEach(System.out::print);
    }
}

Результат:
1234

Пояснение: полезно при интеграции с API, возвращающим итераторы из разных источников.

Пример 3: ленивое преобразование и прерывание обхода

import java.util.*;
import java.util.stream.*;

public class Main {
    public static void main(String[] args) {
        Stream<Integer> s = IntStream.iterate(1, n -> n + 1).boxed();
        Iterator<Integer> it = s.iterator();
        for (int i = 0; i < 5 && it.hasNext(); i++) {
            System.out.println(it.next());
        }
        // итерация остановлена после 5 элементов; сам источник потенциально бесконечен
    }
}

Результат:
1
2
3
4
5

Пояснение: получение итератора для бесконечного стрима позволяет брать ограниченное количество элементов вручную; важна осторожность с ресурсами и логикой остановки.

Пример 4: использование итератора внутри реактивной интеграции (примерный код)

// концептуальный пример: адаптация Iterator в поток событий
Iterator<String> it = Arrays.asList("a","b","c").stream().iterator();
while (it.hasNext()) {
    String item = it.next();
    // отправка в асинхронный обработчик
    asyncSend(item);
}

Результат:
(элементы отправляются асинхронно в обработчик)

Пояснение: итератор позволяет интегрировать Stream API с существующими системами обработки событий, но требуется внимание к потокобезопасности и задержкам.