Одним из главных мотивов для введения потоков Java было разрешение параллельных операций. Это привело к требованию, чтобы операции Java Streams, такие как map
и filter
, не зависели от положения элемента в потоке или элементов вокруг него. У этого есть преимущество, оно позволяет легко разделять потоки для параллельной обработки. Недостатком является сложность некоторых операций.
Таким образом, нет простого способа сделать что-то такое, например, взять каждый n-ый предмет или сопоставить каждый предмет сумме всех предыдущих предметов.
Самый простой способ выполнить ваше требование - использовать индекс списка:
List<String> 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<Integer> 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<Integer> 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()
);