Java8新特性系列(Stream)

題圖:by pixel2013 From pixabay

上期咱們分析了Java8中的引用,本期咱們將分析Java8中的另外一個重要的新特性:流Stream。 本文圖片轉載自併發編程網java

Stream是什麼?

在Java8源代碼中,是這麼定義Stream的:編程

A sequence of elements supporting sequential and parallel aggregate operations.微信

簡單翻譯就是流是支持順序和並行的匯聚操做的一組元素。併發

從這個定義上來講,Stream能夠說是一個高級版本的Iterator,Iterator只能一個一個遍歷元素從而對元素進行操做,可是Stream能夠執行很是複雜的查找、過濾和映射數據等操做,而且中間操做能夠一直迭代。app

Collections是存儲元素,Stream是計算。ide

Stream能夠理解爲一個管道(Pipeline),數據從管道的一邊進入,通過中間各類處理,而後從管道的另外一邊出來新的數據。函數

幾個注意點:性能

    1. Stream本身不會存儲元素。
    1. Stream不會改變原對象。相反,他們會返回一個持有結果的新Stream。
    1. 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);
複製代碼

filter

  • distinct:去除重複元素(經過equals和hashCode)
Stream<T> distinct();
複製代碼

distinct

  • limit:限制數量
Stream<T> limit(long maxSize);
複製代碼

limit

  • skip:跳過
Stream<T> skip(long n);
複製代碼

skip

是否是有點相似SQL語句呢?測試

二、映射

  • map
<R> Stream<R> map(Function<? super T, ? extends R> mapper);
複製代碼

map

  • mapToIntui

  • mapToLong

  • mapToDouble

  • flatMap

<R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper);
複製代碼

flatMap

  • flatMapToInt
  • flatMapToLong
  • flatMapToDouble

三、排序

  • sorted
Stream<T> sorted();
Stream<T> sorted(Comparator<? super T> comparator);
複製代碼

四、包裝

  • peek
Stream<T> peek(Consumer<? super T> action);
複製代碼

peek

終止操做

查找與匹配

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

微信公衆號: 碼上論劍
請關注個人我的技術微信公衆號,訂閱更多內容
相關文章
相關標籤/搜索