Stream

A sequence of elements supporting sequential and parallel aggregate operations Stream是一组用来处理数组、集合的API

▪ Java 8之所以费这么大功夫引入函数式编程，原因有二：

– 代码简洁函数式编程写出的代码简洁且意图明确，使用stream接口让你从 此告别for循环。

– 多核友好，Java函数式编程使得编写并行程序从未如此简单，你需要的全部 就是调用一下parallel()方法

Stream 的操作三个步骤
1> 创建 Stream : 一个数据源 (如 : 集合、数组)， 获取一个流
2> 中间操作 : 一个中间操作链，对数据源的数据进行处理
3> 终止操作(终端操作) : 一个终止操作，执行中间操作链，并产生结果

Stream特性

1：不是数据结构，没有内部存储

2：不支持索引访问

3：延迟计算

4：支持并行

5：很容易生成数组或集合（List，Set）

6：支持过滤，查找，转换，汇总，聚合等操作

Stream运行机制

Stream分为 源source，中间操作，终止操作

流的源可以是一个数组、一个集合、一个生成器方法，一个I/O通 道等等。

一个流可以有零个和或者多个中间操作，每一个中间操作都会返回 一个新的流，供下一个操作使用。

一个流只会有一个终止操作 Stream只有遇到终止操作，它的源才开始执行遍历操作

Stream的创建

1、通过数组

2、通过集合来

3、通过Stream.generate方法来创建

4、通过Stream.iterate方法来创建

5、其他API创建

// Java8 中的Collection接口被扩展，提供了两个获取流的方法：
default Stream<E> stream() // 返回一个顺序流
default Stream<E> parallelStream() // 返回一个并行流
 
// -- 由数组创建流
// Java8 中的Arrays 的静态方法stream() 可以获取数组流：
static <T> Stream<T> stream(T[] array) // 返回一个流
 
// 重载形式，能够处理对应基本类型的数组：
public static IntStream stream(int[] array)
public static LongStream stream(long[] array)
public static DoubleStream stream(double[] array)
 
// -- 由值创建流
// 可以使用静态方法Stream.of()，通过显示值创建一个流。它可以接收任意数量的参数。
public static<T> Stream<T> of(T… values) // 返回一个流
 
// -- 由函数创建流：创建无限流
// 可以使用静态方法Stream.iterate() 和Stream.generate(),创建无限流。
// 迭代
Public static<T> Stream<T> iterate(final T seed, final UnaryOperator<T> f)
// 生成
Public static<T> Stream<T> generate(Supplier<T> s)

Stream的生成方式

1）从Collection和数组获得

• Collection.stream()
• Collection.parallelStream()  （并行执行的流.它通过默认的ForkJoinPool,可能提高多线程任务的速度）
• Arrays.stream(T array) or Stream.of()

（2）从BufferedReader获得

• java.io.BufferedReader.lines()

（3）静态工厂

• java.util.stream.IntStream.range()
• java.nio.file.Files.walk()

（4）自己构建

• java.util.Spliterator

（5）其他

• Random.ints()
• BitSet.stream()
• Pattern.splitAsStream(java.lang.CharSequence)
• JarFile.stream()

Stream常用API 中间操作 过滤 filter 去重 distinct 排序 sorted 截取 limit、skip 转换 map/flatMap 其他 peek

Stream常用API 终止操作 循环 forEach 计算 min、max、count、 average 匹配 anyMatch、 allMatch、 noneMatch、 findFirst、 findAny 汇聚 reduce 收集器 toArray collect