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中串行流與並行流的性能

微信公衆號： 碼上論劍 請關注個人我的技術微信公衆號，訂閱更多內容