Интерфейс LongStream

Последовательность примитивных элементов со значениями типа long, поддерживающая последовательные и параллельные агрегирующие операции. Это примитивное специализированное представление Stream.

Следующий пример демонстрирует агрегирующую операцию с использованием Stream и LongStream, вычисляя сумму весов красных виджетов:

long sum = widgets.stream()
                       .filter(w -> w.getColor() == RED)
                       .mapToLong(w -> w.getWeight())
                       .sum();

Методы

filter

LongStream filter(LongPredicate predicate)

Параметры:

predicate - предикат невмешивающийся и бессостоятельный, применяемый к каждому элементу для определения, должен ли он быть включён

Возвращает:

новый поток

map

LongStream map(LongUnaryOperator mapper)

Параметры:

mapper - невмешивающаяся и бессостоятельная функция, применяемая к каждому элементу

Возвращает:

новый поток

mapToObj

<U> Stream<U> mapToObj(LongFunction<? extends U> mapper)

Параметры типа:

U - тип элемента нового потока

Параметры:

mapper - не вмешивающаяся, бессостоятельная функция, применяемая к каждому элементу

Возвращает:

новый поток

mapToInt

IntStream mapToInt(LongToIntFunction mapper)

Параметры:

mapper - не вмешивающаяся, бессостоятельная функция, применяемая к каждому элементу

Возвращает:

новый поток

mapToDouble

DoubleStream mapToDouble(LongToDoubleFunction mapper)

Параметры:

mapper - не вмешивающаяся, бессостоятельная функция, применяемая к каждому элементу

Возвращает:

новый поток

flatMap

LongStream flatMap(LongFunction<? extends LongStream> mapper)

Параметры:

mapper - не вмешивающаяся, бессостоятельная функция, применяемая к каждому элементу, которая создаёт LongStream новых значений

Возвращает:

новый поток

См. также:

Stream.flatMap(Function)

distinct

LongStream distinct()

Возвращает:

новый поток

sorted

LongStream sorted()

Возвращает:

новый поток

peek

LongStream peek(LongConsumer action)

Примечание API:

Этот метод существует в основном для отладки, где вы хотите увидеть элементы, поскольку они проходят определённую точку в конвейере:

LongStream.of(1, 2, 3, 4)
         .filter(e -> e > 2)
         .peek(e -> System.out.println("Filtered value: " + e))
         .map(e -> e * e)
         .peek(e -> System.out.println("Mapped value: " + e))
         .sum();

Параметры:

action - не вмешивающееся действие, выполняемое над элементами по мере их потребления из потока

Возвращает:

новый поток

limit

LongStream limit(long maxSize)

Примечание API:

Хотя limit() обычно является недорогой операцией в последовательных потоковых конвейерах, она может быть довольно дорогой в упорядоченных параллельных конвейерах, особенно для больших значений maxSize, так как limit(n) ограничен возвращением не просто любых n элементов, а первых n элементов в порядке их появления. Использование неупорядоченного источника потока (например, generate(LongSupplier)) или удаление ограничения на порядок с помощью BaseStream.unordered() может привести к значительному ускорению limit() в параллельных конвейерах, если семантика вашей ситуации это допускает. Если требуется согласованность с порядком появления, и вы сталкиваетесь с плохой производительностью или использованием памяти с limit() в параллельных конвейерах, переключение на последовательное выполнение с помощью sequential() может улучшить производительность.

Параметры:

maxSize - количество элементов, до которого должен быть ограничен поток

Возвращает:

новый поток

Исключение:

IllegalArgumentException - если maxSize отрицательно

skip

LongStream skip(long n)

Примечание API:

Хотя skip() обычно является недорогой операцией в последовательных потоковых конвейерах, она может быть довольно дорогой в упорядоченных параллельных конвейерах, особенно для больших значений n, так как skip(n) ограничен пропусканием не просто любых n элементов, а первых n элементов в порядке их появления. Использование неупорядоченного источника потока (например, generate(LongSupplier)) или удаление ограничения на порядок с помощью BaseStream.unordered() может привести к значительному ускорению skip() в параллельных конвейерах, если семантика вашей ситуации это допускает. Если требуется согласованность с порядком появления, и вы сталкиваетесь с плохой производительностью или использованием памяти с skip() в параллельных конвейерах, переключение на последовательное выполнение с помощью sequential() может улучшить производительность.

Параметры:

n - количество ведущих элементов для пропуска

Возвращает:

новый поток

Исключение:

IllegalArgumentException - если n отрицательно

forEach

void forEach(LongConsumer action)

Параметры:

action - не вмешивающееся действие, выполняемое над элементами

forEachOrdered

void forEachOrdered(LongConsumer action)

Параметры:

action - не вмешивающееся действие, выполняемое над элементами

См. также:

forEach(LongConsumer)

toArray

long[] toArray()

Возвращает:

массив, содержащий элементы этого потока

reduce

long reduce(long identity,
            LongBinaryOperator op)

long result = identity;
     for (long element : this stream)
         result = accumulator.applyAsLong(result, element)
     return result;

Примечание API:

Sum, min, max и average — это все частные случаи сокращения. Суммирование потока чисел может быть выражено как:

long sum = integers.reduce(0, (a, b) -> a+b);

или более компактно:

long sum = integers.reduce(0, Long::sum);

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

Параметры:

identity — значение тождества для накапливающей функции

op — ассоциативная, не влияющая на состояние, бессостоятельная функция для объединения двух значений

Возвращаемое значение:

результат сокращения

См. также:

sum(), min(), max(), average()

reduce

OptionalLong reduce(LongBinaryOperator op)

boolean foundAny = false;
     long result = null;
     for (long element : this stream) {
         if (!foundAny) {
             foundAny = true;
             result = element;
         }
         else
             result = accumulator.applyAsLong(result, element);
     }
     return foundAny ? OptionalLong.of(result) : OptionalLong.empty();

Параметры:

op — ассоциативная, не влияющая на состояние, бессостоятельная функция для объединения двух значений

Возвращаемое значение:

результат сокращения

См. также:

reduce(long, LongBinaryOperator)

collect

<R> R collect(Supplier<R> supplier,
              ObjLongConsumer<R> accumulator,
              BiConsumer<R,R> combiner)

R result = supplier.get();
     for (long element : this stream)
         accumulator.accept(result, element);
     return result;

Тип параметров:

R — тип результата

Параметры:

supplier — функция, создающая новый контейнер результата. При параллельном выполнении эта функция может вызываться несколько раз и должна возвращать новое значение каждый раз.

accumulator — ассоциативная, не влияющая на состояние, бессостоятельная функция для включения дополнительного элемента в результат

combiner — ассоциативная, не влияющая на состояние, бессостоятельная функция для объединения двух значений, которая должна быть совместима с функцией накопления

Возвращаемое значение:

результат сокращения

См. также:

Stream.collect(Supplier, BiConsumer, BiConsumer)

sum

long sum()

return reduce(0, Long::sum);

Возвращаемое значение:

сумма элементов в этом потоке

min

OptionalLong min()

return reduce(Long::min);

Возвращаемое значение:

Optional, содержащий минимальный элемент этого потока, или пустой Optional, если поток пустой

max

OptionalLong max()

return reduce(Long::max);

Возвращаемое значение:

Optional, содержащий максимальный элемент этого потока, или пустой Optional, если поток пустой

count

long count()

return map(e -> 1L).sum();

Возвращаемое значение:

количество элементов в этом потоке

average

OptionalDouble average()

Возвращаемое значение:

Optional, содержащий среднее значение элементов этого потока, или пустой Optional, если поток пуст

summaryStatistics

LongSummaryStatistics summaryStatistics()

Возвращаемое значение:

SummaryStatistics, описывающая различные сводные данные об элементах этого потока

anyMatch

boolean anyMatch(LongPredicate predicate)

Примечание API:

Этот метод оценивает экзистенциальное квантификацию предиката над элементами потока (для некоторого x P(x)).

Параметры:

predicate — не влияющий на состояние, бессостоятельный предикат, применяемый к элементам этого потока

Возвращаемое значение:

true, если хотя бы один элемент потока удовлетворяет заданному предикату, в противном случае false

allMatch

boolean allMatch(LongPredicate predicate)

Примечание API:

Этот метод оценивает универсальное квантификацию предиката над элементами потока (для всех x P(x)). Если поток пуст, то квантификация считается пусто выполнимой и всегда возвращает true (независимо от P(x)).

Параметры:

predicate — не влияющий на состояние, бессостоятельный предикат, применяемый к элементам этого потока

Возвращаемое значение:

true, если все элементы потока удовлетворяют заданному предикату или поток пуст, в противном случае false

noneMatch

boolean noneMatch(LongPredicate predicate)

Примечание API:

Этот метод оценивает универсальное квантификацию отрицания предиката над элементами потока (для всех x ~P(x)). Если поток пуст, то квантификация считается пусто выполнимой и всегда возвращает true, независимо от P(x).

Параметры:

predicate — не влияющий на состояние, бессостоятельный предикат, применяемый к элементам этого потока

Возвращаемое значение:

true, если ни один элемент потока не удовлетворяет заданному предикату или поток пуст, в противном случае false

findFirst

OptionalLong findFirst()

Возвращаемое значение:

Optional, описывающий первый элемент этого потока, или пустой Optional, если поток пуст

findAny

OptionalLong findAny()

Возвращает:

OptionalLong , описывающую какой-то элемент этого потока, или пустой OptionalLong , если поток пуст

См. также:

findFirst()

asDoubleStream

DoubleStream asDoubleStream()

Возвращает:

DoubleStream , состоящий из элементов этого потока, преобразованных в double

boxed

Stream<Long> boxed()

Возвращает:

Stream состоящий из элементов этого потока, каждый из которых упакован в Long

sequential

LongStream sequential()

Описание скопировано из интерфейса: BaseStream

Указано в:

sequential в интерфейсе BaseStream<Long,LongStream>

Возвращает:

последовательный поток

parallel

LongStream parallel()

Описание скопировано из интерфейса: BaseStream

Указано в:

parallel в интерфейсе BaseStream<Long,LongStream>

Возвращает:

параллельный поток

iterator

PrimitiveIterator.OfLong iterator()

Описание скопировано из интерфейса: BaseStream

Указано в:

iterator в интерфейсе BaseStream<Long,LongStream>

Возвращает:

итератор элементов для этого потока

spliterator

Spliterator.OfLong spliterator()

Описание скопировано из интерфейса: BaseStream

Указано в:

spliterator в интерфейсе BaseStream<Long,LongStream>

Возвращает:

разделитель элементов для этого потока

builder

static LongStream.Builder builder()

Возвращает сборщик для LongStream.

Возвращает:

сборщик потока

empty

static LongStream empty()

Возвращает пустой последовательный LongStream.

Возвращает:

пустой последовательный поток

of

static LongStream of(long t)

Возвращает последовательный LongStream , содержащий один элемент.

Параметры:

t - единственный элемент

Возвращает:

последовательный поток-синглтон

of

static LongStream of(long... values)

Возвращает упорядоченный последовательный поток, элементами которого являются указанные значения.

Параметры:

values - элементы нового потока

Возвращает:

новый поток

iterate

static LongStream iterate(long seed,
                          LongUnaryOperator f)

Параметры:

seed - начальный элемент

f - функция, применяемая к предыдущему элементу для получения нового элемента

Возвращает:

новый последовательный LongStream

generate

static LongStream generate(LongSupplier s)

Возвращает бесконечный неупорядоченный последовательный поток, где каждый элемент генерируется предоставленным LongSupplier. Это подходит для генерации постоянных потоков, потоков случайных элементов и т. д.

Параметры:

s - LongSupplier для сгенерированных элементов

Возвращает:

новый бесконечный неупорядоченный последовательный LongStream

range

static LongStream range(long startInclusive,
                        long endExclusive)

Возвращает упорядоченный последовательный LongStream от startInclusive (включительно) до endExclusive (исключительно) с шагом увеличения 1.

Примечание API:

Эквивалентную последовательность возрастающих значений можно получить последовательно с помощью цикла for следующим образом:

for (long i = startInclusive; i < endExclusive ; i++) { ... }

Параметры:

startInclusive - начальное значение (включительно)

endExclusive - верхняя граница (исключительно)

Возвращает:

последовательный LongStream для диапазона long элементов

rangeClosed

static LongStream rangeClosed(long startInclusive,
                              long endInclusive)

Возвращает упорядоченный последовательный LongStream от startInclusive (включительно) до endInclusive (включительно) с шагом увеличения 1.

Примечание API:

Эквивалентную последовательность возрастающих значений можно получить последовательно с помощью цикла for следующим образом:

for (long i = startInclusive; i <= endInclusive ; i++) { ... }

Параметры:

startInclusive - начальное значение (включительно)

endInclusive - верхняя граница (включительно)

Возвращает:

последовательный LongStream для диапазона long элементов

concat

static LongStream concat(LongStream a,
                         LongStream b)

Создает лениво конкатенированный поток, элементами которого являются все элементы первого потока, за которыми следуют все элементы второго потока. Результирующий поток упорядочен, если оба входных потока упорядочены, и параллелен, если любой из входных потоков является параллельным. При закрытии результирующего потока вызываются обработчики закрытия для обоих входных потоков.

Примечание реализации:

Следует проявлять осторожность при конструировании потоков из многократных конкатенаций. Доступ к элементу глубоко конкатенированного потока может привести к глубоким цепочкам вызовов или даже к StackOverflowException.

Параметры:

a - первый поток

b - второй поток

Возвращает:

конкатенация двух входных потоков