題圖：by pixel2013 From pixabay
上期我們分析了Java8中的引用，本期我們將分析Java8中的另一個(gè)重要的新特性：流Stream粗仓。
本文圖片轉(zhuǎn)載自并發(fā)編程網(wǎng)
Stream是什么嫁怀？
在Java8源代碼中，是這么定義Stream的：
A sequence of elements supporting sequential and parallel aggregate operations.
簡(jiǎn)單翻譯就是流是支持順序和并行的匯聚操作的一組元素借浊。
從這個(gè)定義上來(lái)說(shuō)塘淑，Stream可以說(shuō)是一個(gè)高級(jí)版本的Iterator，Iterator只能一個(gè)一個(gè)遍歷元素從而對(duì)元素進(jìn)行操作蚂斤，但是Stream可以執(zhí)行非常復(fù)雜的查找存捺、過(guò)濾和映射數(shù)據(jù)等操作，并且中間操作可以一直迭代曙蒸。
Collections是存儲(chǔ)元素捌治，Stream是計(jì)算。
Stream可以理解為一個(gè)管道（Pipeline）纽窟，數(shù)據(jù)從管道的一邊進(jìn)入肖油，經(jīng)過(guò)中間各種處理，然后從管道的另一邊出來(lái)新的數(shù)據(jù)臂港。
幾個(gè)注意點(diǎn)：
- Stream自己不會(huì)存儲(chǔ)元素森枪。
- Stream不會(huì)改變?cè)瓕?duì)象。相反审孽，他們會(huì)返回一個(gè)持有結(jié)果的新Stream县袱。
- Stream操作是延遲執(zhí)行。這意味著他們會(huì)等到需要結(jié)果的時(shí)候才執(zhí)行佑力。
Stream的pipeline
- 創(chuàng)建Stream
- 中間操作：一個(gè)中間操作鏈显拳，對(duì)數(shù)據(jù)源數(shù)據(jù)進(jìn)行處理，但是是延遲執(zhí)行的
- 終止操作：執(zhí)行中間操作鏈搓萧，并產(chǎn)生結(jié)果杂数，正如上面注意點(diǎn)3
創(chuàng)建Stream
1宛畦、java.util.Collection內(nèi)置了獲取流的方法，分別為串行流與并行流
default Stream<E> stream() {
return StreamSupport.stream(spliterator(), false);
}
default Stream<E> parallelStream() {
return StreamSupport.stream(spliterator(), true);
}
2揍移、java.util.Arrays內(nèi)置了獲取流的方法
public static <T> Stream<T> stream(T[] array) {
return stream(array, 0, array.length);
}
3次和、java.util.stream.Stream內(nèi)置了創(chuàng)建流的方法，分別為通過(guò)對(duì)象創(chuàng)建流和通過(guò)函數(shù)創(chuàng)建流
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）
1那伐、截?cái)嗯c切片
- filter：過(guò)濾
Stream<T> filter(Predicate<? super T> predicate);
filter
- distinct：去除重復(fù)元素（通過(guò)equals和hashCode）
Stream<T> distinct();
distinct
- limit：限制數(shù)量
Stream<T> limit(long maxSize);
limit
- skip：跳過(guò)
Stream<T> skip(long n);
skip
是不是有點(diǎn)類似SQL語(yǔ)句呢踏施？
2、映射
- map
<R> Stream<R> map(Function<? super T, ? extends R> mapper);
map
mapToInt
mapToLong
mapToDouble
flatMap
<R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper);
flatMap
- flatMapToInt
- flatMapToLong
- flatMapToDouble
3罕邀、排序
- sorted
Stream<T> sorted();
Stream<T> sorted(Comparator<? super T> comparator);
4畅形、包裝
- peek
Stream<T> peek(Consumer<? super T> action);
peek
終止操作
查找與匹配
- allMatch：檢查是否匹配所有元素
boolean allMatch(Predicate<? super T> predicate);
- anyMatch：檢查是否至少匹配一個(gè)元素
boolean anyMatch(Predicate<? super T> predicate);
- noneMatch：檢查是否沒(méi)有匹配所有元素
boolean noneMatch(Predicate<? super T> predicate);
- findFirst：返回第一個(gè)元素
Optional<T> findFirst();
- findAny：返回當(dāng)前流中的任意元素
Optional<T> findAny();
- count：返回流中元素總數(shù)
long count();
- max：返回流中最大值
Optional<T> max(Comparator<? super T> comparator);
- min：返回流中最小值
Optional<T> min(Comparator<? super T> comparator);
- forEach：內(nèi)部迭代
void forEach(Consumer<? super T> action);
規(guī)約
- 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靜態(tài)方法
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是不是很方便呢？
下期我們將測(cè)試下Stream中串行流與并行流的性能
