Java8新特性系列（Stream）

上期咱们分析了Java8中的引用，本期咱们将分析Java8中的另外一个重要的新特性：流Stream。 本文图片转载自并发编程网

Stream是什么？

在Java8源代码中，是这么定义Stream的：

A sequence of elements supporting sequential and parallel aggregate operations.

简单翻译就是流是支持顺序和并行的汇聚操做的一组元素。

从这个定义上来讲，Stream能够说是一个高级版本的Iterator，Iterator只能一个一个遍历元素从而对元素进行操做，可是Stream能够执行很是复杂的查找、过滤和映射数据等操做，而且中间操做能够一直迭代。

Collections是存储元素，Stream是计算。

Stream能够理解为一个管道（Pipeline），数据从管道的一边进入，通过中间各类处理，而后从管道的另外一边出来新的数据。

几个注意点：

• 1. Stream本身不会存储元素。
• 2. Stream不会改变原对象。相反，他们会返回一个持有结果的新Stream。
• 3. Stream操做是延迟执行。这意味着他们会等到须要结果的时候才执行。

Stream的pipeline

• 建立Stream
• 中间操做：一个中间操做链，对数据源数据进行处理，可是是延迟执行的
• 终止操做：执行中间操做链，并产生结果，正如上面注意点3

建立Stream

一、java.util.Collection内置了获取流的方法，分别为串行流与并行流

default Stream<E> stream() {
    return StreamSupport.stream(spliterator(), false);
}

default Stream<E> parallelStream() {
    return StreamSupport.stream(spliterator(), true);
}
复制代码

二、java.util.Arrays内置了获取流的方法

public static <T> Stream<T> stream(T[] array) {
    return stream(array, 0, array.length);
}
复制代码

三、java.util.stream.Stream内置了建立流的方法，分别为经过对象建立流和经过函数建立流

public static<T> Stream<T> of(T t) {
    return StreamSupport.stream(new Streams.StreamBuilderImpl<>(t), false);
}

public static<T> Stream<T> of(T... values) {
    return Arrays.stream(values);
}

public static<T> Stream<T> iterate(final T seed, final UnaryOperator<T> f) {
    Objects.requireNonNull(f);
    final Iterator<T> iterator = new Iterator<T>() {
        @SuppressWarnings("unchecked")
        T t = (T) Streams.NONE;

        @Override
        public boolean hasNext() {
            return true;
        }

        @Override
        public T next() {
            return t = (t == Streams.NONE) ? seed : f.apply(t);
        }
    };
    return StreamSupport.stream(Spliterators.spliteratorUnknownSize(
                iterator,
                Spliterator.ORDERED | Spliterator.IMMUTABLE), false);
}

public static<T> Stream<T> generate(Supplier<T> s) {
    Objects.requireNonNull(s);
    return StreamSupport.stream(
                new StreamSpliterators.InfiniteSupplyingSpliterator.OfRef<>(Long.MAX_VALUE, s), false);
}
复制代码

中间操做（java.util.stream.Stream）

一、截断与切片

• filter：过滤

Stream<T> filter(Predicate<? super T> predicate);
复制代码

• distinct：去除重复元素（经过equals和hashCode）

Stream<T> distinct();
复制代码

• limit：限制数量

Stream<T> limit(long maxSize);
复制代码

• skip：跳过

Stream<T> skip(long n);
复制代码

是否是有点相似SQL语句呢？

二、映射

• map

<R> Stream<R> map(Function<? super T, ? extends R> mapper);
复制代码

• mapToInt

• mapToLong

• mapToDouble

• flatMap

<R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper);
复制代码

• flatMapToInt
• flatMapToLong
• flatMapToDouble

三、排序

• sorted

Stream<T> sorted();
Stream<T> sorted(Comparator<? super T> comparator);
复制代码

四、包装

• peek

Stream<T> peek(Consumer<? super T> action);
复制代码

终止操做

查找与匹配

• allMatch：检查是否匹配全部元素

boolean allMatch(Predicate<? super T> predicate);
复制代码

• anyMatch：检查是否至少匹配一个元素

boolean anyMatch(Predicate<? super T> predicate);
复制代码

• noneMatch：检查是否没有匹配全部元素

boolean noneMatch(Predicate<? super T> predicate);
复制代码

• findFirst：返回第一个元素

Optional<T> findFirst();
复制代码

• findAny：返回当前流中的任意元素

Optional<T> findAny();
复制代码

• count：返回流中元素总数

long count();
复制代码

• max：返回流中最大值

Optional<T> max(Comparator<? super T> comparator);
复制代码

• min：返回流中最小值

Optional<T> min(Comparator<? super T> comparator);
复制代码

• forEach：内部迭代

void forEach(Consumer<? super T> action);
复制代码

规约

• reduce

T reduce(T identity, BinaryOperator<T> accumulator);

Optional<T> reduce(BinaryOperator<T> accumulator);

<U> U reduce(U identity, BiFunction<U, ? super T, U> accumulator, BinaryOperator<U> combiner);
复制代码

收集

• collect

<R, A> R collect(Collector<? super T, A, R> collector);

<R> R collect(Supplier<R> supplier, BiConsumer<R, ? super T> accumulator, BiConsumer<R, R> combiner);
复制代码

• Collectors静态方法

List<T> toList() Set<T> toSet() Collection<T> toCollection Long counting Integer summingInt Double averagingInt IntSummaryStatistics summarizingInt String joining Optional<T> maxBy Optional<T> minBy ... 复制代码

Stream是否是很方便呢？ 下期咱们将测试下Stream中串行流与并行流的性能

微信公众号： 码上论剑 请关注个人我的技术微信公众号，订阅更多内容