Stream为何而生

Stream 作为 Java 8 的一大亮点，它与 java.io 包里的 InputStream 和 OutputStream 是完全不同的概念。它也不同于 StAX 对 XML 解析的 Stream，也不是 Amazon Kinesis 对大数据实时处理的 Stream。Java 8 中的 Stream 是对集合（Collection）对象功能的增强，它专注于对集合对象进行各种非常便利、高效的聚合操作（aggregate operation），或者大批量数据操作 (bulk data operation)。Stream API 借助于同样新出现的 Lambda 表达式，极大的提高编程效率和程序可读性。同时它提供串行和并行两种模式进行汇聚操作，并发模式能够充分利用多核处理器的优势，使用 fork/join 并行方式来拆分任务和加速处理过程。通常编写并行代码很难而且容易出错, 但使用 Stream API 无需编写一行多线程的代码，就可以很方便地写出高性能的并发程序。所以说，Java 8 中首次出现的 java.util.stream 是一个函数式语言+多核时代综合影响的产物。

源码分析

依赖关系

luogw@luogw-MacBook-Pro stream$ ag 'import java.util' |  awk 'BEGIN{FS=":"} {print $3}' | awk 'BEGIN{FS=" "} {print $2}' | awk 'BEGIN{FS=";"} {print $1}' | sort -ujava.util.AbstractMapjava.util.AbstractSetjava.util.ArrayDequejava.util.ArrayListjava.util.Arraysjava.util.Collectionjava.util.Collectionsjava.util.Comparatorjava.util.Dequejava.util.DoubleSummaryStatisticsjava.util.EnumMapjava.util.EnumSetjava.util.HashMapjava.util.HashSetjava.util.IntSummaryStatisticsjava.util.Iteratorjava.util.LinkedHashSetjava.util.Listjava.util.LongSummaryStatisticsjava.util.Mapjava.util.Objectsjava.util.Optionaljava.util.OptionalDoublejava.util.OptionalIntjava.util.OptionalLongjava.util.PrimitiveIteratorjava.util.Setjava.util.Spliteratorjava.util.Spliteratorsjava.util.StringJoinerjava.util.concurrent.ConcurrentHashMapjava.util.concurrent.ConcurrentMapjava.util.concurrent.CountedCompleterjava.util.concurrent.ForkJoinPooljava.util.concurrent.ForkJoinTaskjava.util.concurrent.atomic.AtomicBooleanjava.util.concurrent.atomic.AtomicLongjava.util.concurrent.atomic.AtomicReferencejava.util.function.BiConsumerjava.util.function.BiFunctionjava.util.function.BinaryOperatorjava.util.function.BooleanSupplierjava.util.function.Consumerjava.util.function.DoubleBinaryOperatorjava.util.function.DoubleConsumerjava.util.function.DoubleFunctionjava.util.function.DoublePredicatejava.util.function.DoubleSupplierjava.util.function.DoubleToIntFunctionjava.util.function.DoubleToLongFunctionjava.util.function.DoubleUnaryOperatorjava.util.function.Functionjava.util.function.IntBinaryOperatorjava.util.function.IntConsumerjava.util.function.IntFunctionjava.util.function.IntPredicatejava.util.function.IntSupplierjava.util.function.IntToDoubleFunctionjava.util.function.IntToLongFunctionjava.util.function.IntUnaryOperatorjava.util.function.LongBinaryOperatorjava.util.function.LongConsumerjava.util.function.LongFunctionjava.util.function.LongPredicatejava.util.function.LongSupplierjava.util.function.LongToDoubleFunctionjava.util.function.LongToIntFunctionjava.util.function.LongUnaryOperatorjava.util.function.ObjDoubleConsumerjava.util.function.ObjIntConsumerjava.util.function.ObjLongConsumerjava.util.function.Predicatejava.util.function.Supplierjava.util.function.ToDoubleFunctionjava.util.function.ToIntFunctionjava.util.function.ToLongFunctionjava.util.function.UnaryOperator

如上所示，Stream包依赖集合框架，并发编程包（java.util.concurrent），函数式接口（java.util.function），即要先搞清楚依赖方的实现先！