#java #java_8 #java_stream #функциональное_программирование
Предположим, у меня есть такой список:
[1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
Можно ли использовать Java Stream API для переноса каждого второго элемента из этого
списка, чтобы получить такой список?
[1, 3, 5, 7, 9]
Или, может быть, каждый третий элемент?
[1, 4, 7, 10]
По сути, я ищу такую функцию, чтобы взять каждый n-ый элемент из потока:
List list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
List list2 = list.stream().takenth(3).collect(Collectors.toList());
System.out.println(list2);
// => [1, 4, 7, 10]
Ответы
Ответ 1
Одним из главных мотивов для введения потоков Java было разрешение параллельных операций.
Это привело к требованию, чтобы операции Java Streams, такие как map и filter, не зависели
от положения элемента в потоке или элементов вокруг него. У этого есть преимущество,
оно позволяет легко разделять потоки для параллельной обработки. Недостатком является
сложность некоторых операций.
Таким образом, нет простого способа сделать что-то такое, например, взять каждый
n-ый предмет или сопоставить каждый предмет сумме всех предыдущих предметов.
Самый простой способ выполнить ваше требование - использовать индекс списка:
List list = ...;
return IntStream.range(0, list.size())
.filter(n -> n % 3 == 0) //3 - каждый 3-ий элемент
.mapToObj(list::get)
.collect(Collectors.toList());
Примечание от Sergey Gornostaev:
Решение рабочее, но должен заметить, подобное применение стримов - это
антипаттерн. Не желательно работать с данными за пределами стрима. Как
только появляется идея об обращении к переменной, стоит насторожиться
и подумать "Я использую стримы неправильно или стримы тут вообще не
подходят?"
Используя Stream.iterate
List list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
int skip = 3;
int size = list.size();
// Limit to carefully avoid IndexOutOfBoundsException
int limit = size / skip + Math.min(size % skip, 1);
List result = Stream.iterate(0, i -> i + skip)
.limit(limit)
.map(list::get)
.collect(Collectors.toList());
System.out.println(result); // [1, 4, 7, 10]
Используя библиотеку Guava(GitHub):
Streams
.mapWithIndex(stream, SimpleImmutableEntry::new)
.filter(entry -> entry.getValue() % 3 == 0)
.map(Entry::getKey)
.collect(Collectors.toList());
Используя библиотеку AbacusUtil:
Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
.filter(MutableInt.of(0), (e, idx) -> idx.getAndDecrement() % 3 == 0)
.println();
Используя библиотеку jOOλ и ее метод zipWithIndex():
System.out.println(
Seq.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
.zipWithIndex() // This produces a Tuple2(yourvalue, index)
.filter(t -> t.v2 % 3 == 0) // Filter by the index
.map(t -> t.v1) // Remove the index again
.toList()
);
