Stream 和 parallelStream

• Stream：串行流，单线程，线程安全，适合阻塞任务、重量级任务；

• parallelStream：并行流，多线程，线程不安全，其底层使用Fork/Join框架实现，适合较单纯的数据处理任务；

操作元素

（1）中间操作：流中间操作在应用到流上，返回一个新的流；

map：通过一个 Function 把一个元素类型为 T的流转换成元素类型为 R的流。

flatMap：扁平化流，通过一个 Function 把一个元素类型为 T 的流中的每个元素转换成一个元素类型为 R 的流，再把这些转换之后的流合并。

filter：过滤流中的元素，只保留满足由 Predicate 所指定的条件的元素。

distinct：筛选，通过流所生成元素的hashCode（）和equals去除重复元素

limit：截断流使其最多只包含指定数量的元素。

skip：跳过元素，返回一个扔掉了前n个元素的流，若流中元素不足n个，则返回一个空流，与limit（n）互补

sorted：对流进行排序。

peek：返回的流与原始流相同。当原始流中的元素被消费时，会首先调用 peek 方法中指定的 Consumer 实现对元素进行处理。

dropWhile：从原始流起始位置开始删除满足指定 Predicate 的元素，直到遇到第一个不满足 Predicate 的元素。

takeWhile：从原始流起始位置开始保留满足指定 Predicate 的元素，直到遇到第一个不满足 Predicate 的元素。

……

（2）终结操作：终结操作产生最终的结果；

forEach：遍历，自定义操作

allMatch：检查是否匹配所有元素

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

noneMatch：检查是否没有匹配所有元素

findFirst：返回第一个元素

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

count：返回流中元素的总个数

max：返回流中最大值

min：返回流中最小值

reduce：归约，递归操作，将流的每个元素反复结合形成得到新值

collect：收集，汇总操作（返回新集合、分组），接收一个Collector接口实现

……

java流操作：Stream操作与详解