Интерфейс DoubleStream

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

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

double sum = widgets.stream()
                         .filter(w -> w.getColor() == RED)
                         .mapToDouble(w -> w.getWeight())
                         .sum();

Методы

filter

DoubleStream filter(DoublePredicate predicate)

Параметры:

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

Возвращает:

новый поток

map

DoubleStream map(DoubleUnaryOperator mapper)

Параметры:

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

Возвращает:

новый поток

mapToObj

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

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

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

Параметры:

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

Возвращает:

новый поток

mapToInt

IntStream mapToInt(DoubleToIntFunction mapper)

Параметры:

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

Возвращает:

новый поток

mapToLong

LongStream mapToLong(DoubleToLongFunction mapper)

Параметры:

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

Возвращает:

новый поток

flatMap

DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Параметры:

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

Возвращает:

новый поток

См. также:

Stream.flatMap(Function)

distinct

DoubleStream distinct()

Возвращает:

результирующий поток

sorted

DoubleStream sorted()

Возвращает:

результирующий поток

peek

DoubleStream peek(DoubleConsumer action)

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

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

DoubleStream.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

DoubleStream limit(long maxSize)

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

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

Параметры:

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

Возвращает:

новый поток

Исключения:

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

skip

DoubleStream skip(long n)

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

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

Параметры:

n - количество ведущих элементов, которые нужно пропустить

Возвращает:

новый поток

Исключения:

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

forEach

void forEach(DoubleConsumer action)

Параметры:

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

forEachOrdered

void forEachOrdered(DoubleConsumer action)

Параметры:

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

См. также:

forEach(DoubleConsumer)

toArray

double[] toArray()

Возвращает:

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

reduce

double reduce(double identity,
              DoubleBinaryOperator op)

double result = identity;
     for (double element : this stream)
         result = accumulator.applyAsDouble(result, element)
     return result;

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

Сумма, минимум, максимум и среднее значение являются частными случаями сведения. Вычисление суммы потока чисел может быть выражено как:

double sum = numbers.reduce(0, (a, b) -> a+b);

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

double sum = numbers.reduce(0, Double::sum);

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

Параметры:

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

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

Возвращает:

результат сведения

См. также:

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

reduce

OptionalDouble reduce(DoubleBinaryOperator op)

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

Параметры:

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

Возвращает:

результат сведения

См. также:

reduce(double, DoubleBinaryOperator)

collect

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

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

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

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

Параметры:

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

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

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

Возвращает:

результат сведения

См. также:

Stream.collect(Supplier, BiConsumer, BiConsumer)

sum

double sum()

return reduce(0, Double::sum);

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

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

Возвращает:

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

min

OptionalDouble min()

return reduce(Double::min);

Возвращает:

OptionalDouble содержащий минимальный элемент этого потока или пустой необязательный объект, если поток пустой

max

OptionalDouble max()

return reduce(Double::max);

Возвращает:

OptionalDouble, содержащий максимальный элемент этого потока, или пустой необязательный объект, если поток пустой

count

long count()

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

Возвращает:

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

average

OptionalDouble average()

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

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

Возвращает:

OptionalDouble содержащий среднее значение элемента этого потока, или пустой необязательный объект, если поток пустой

summaryStatistics

DoubleSummaryStatistics summaryStatistics()

Возвращает:

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

anyMatch

boolean anyMatch(DoublePredicate predicate)

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

Этот метод вычисляет существование квантификации предиката по элементам потока (для некоторого x P(x)).

Параметры:

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

Возвращает:

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

allMatch

boolean allMatch(DoublePredicate predicate)

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

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

Параметры:

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

Возвращает:

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

noneMatch

boolean noneMatch(DoublePredicate predicate)

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

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

Параметры:

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

Возвращает:

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

findFirst

OptionalDouble findFirst()

Возвращает:

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

findAny

OptionalDouble findAny()

Возвращает:

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

См. также:

findFirst()

boxed

Stream<Double> boxed()

Возвращает:

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

sequential

DoubleStream sequential()

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

Определено в:

sequential в интерфейсе BaseStream<Double,DoubleStream>

Возвращает:

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

parallel

DoubleStream parallel()

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

Определено в:

parallel в интерфейсе BaseStream<Double,DoubleStream>

Возвращает:

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

iterator

PrimitiveIterator.OfDouble iterator()

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

Определено в:

iterator в интерфейсе BaseStream<Double,DoubleStream>

Возвращает:

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

spliterator

Spliterator.OfDouble spliterator()

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

Определено в:

spliterator в интерфейсе BaseStream<Double,DoubleStream>

Возвращает:

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

builder

static DoubleStream.Builder builder()

Возвращает билдер для DoubleStream.

Возвращает:

билдер потока

empty

static DoubleStream empty()

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

Возвращает:

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

of

static DoubleStream of(double t)

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

Параметры:

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

Возвращает:

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

of

static DoubleStream of(double... values)

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

Параметры:

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

Возвращает:

новый поток

iterate

static DoubleStream iterate(double seed,
                            DoubleUnaryOperator f)

Параметры:

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

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

Возвращает:

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

generate

static DoubleStream generate(DoubleSupplier s)

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

Параметры:

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

Возвращает:

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

concat

static DoubleStream concat(DoubleStream a,
                           DoubleStream b)

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

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

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

Параметры:

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

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

Возвращает:

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