小伙伴们好呀，我是 4ye，今天来分享下 Java8 Stream 的源码

核心回顾

整体概览

这里列出一些重要的类，是看源码过程中必须了解的。

(资料图片仅供参考)

源码中涉及到 N 多的内部类，这个是删减后的版本

比如 ：

demo代码

这里沿用上文的例子

Student aStud = new Student(1, "a");        Student bStud = new Student(2, "b");        Student cStud = new Student(3, null);//         集合的创建 一        List<Student> collect1 = Stream.of(aStud, bStud, cStud).collect(Collectors.toList());        collect1.forEach(System.out::println);        List<String> studNameList = studentList.stream()                .map(Student::getName)                .filter(Objects::nonNull)                .map(String::toUpperCase)                .sorted()                .map(e -> e + "c")                .collect(Collectors.toList());

步骤解析

都在这里了

这里步骤太多了，就不一一放出来了 ，列下核心

wrapSink()

开始套娃，从 ReducingSink 往前套

opWarpSink 方法调用的是每一步 中间操作中的方法

通过 单链表的形式将他们联系在一起

Sink 链创建结果

copyInto()

这里判断是不是 短路操作，然后就去执行 Sink 的 begin，accept，end 方法。

通过 forEachRemaining进行内部迭代，这个是 Spliterator的方法。

map 链节点，直接调用传进来的方法，

filter 链节点，多一步判断

sorted 节点，添加到 list 中。

不过别担心， sorted 链节点中它重写了这个 end，并开启对新数据的新一轮遍历！

最后呢，是来到终止操作 TerminalOp中的 accept，这里执行的是 list 的 add 方法（我们调用 Collectors.toList()中构建的），至此，数据添加到 state 中

获取数据，ReducingSink 继承了 Box 这个抽象类，最后 get 方法得到结果。

总结

代码对应的执行流程

那么，这个 stream 的原理机制就出来了：

此外，源码的 链式调用API 写法，设计模式 的使用以及 泛型 ，四大函数式接口组合构建的高度抽象，封装写法，对我们的编码能力，源码阅读能力也有很大的帮助！

比如 这个 Consumer+Function 接口的组合，配合泛型上下限的使用

源码中 访问者模式，工厂模式等设计模式的影子

工厂模式

对 stream 的特点更加熟悉

比如：

最后