当 Java SE 8（又名核心 Java 8）在 2014 年被推出时，它引入了一些更改，从根本上影响了用它进行的编程。这些更改中有两个紧密相连的部分：流 API 和函数式编程构造。本文使用代码示例，从基础到高级特性，介绍每个部分并说明它们之间的相互作用。
基础特性流 API 是在数据序列中迭代元素的简洁而高级的方法。包 java.util.stream 和 java.util.function 包含了用于流 API 和相关函数式编程构造的新库。当然，代码示例胜过千言万语。
下面的代码段用大约 2,000 个随机整数值填充了一个 List：
Random rand = new Random2();List list = new ArrayList();?????????? // 空 listfor (int i = 0; i < 2048; i++) list.add(rand.nextInt()); // 填充它 另外用一个 for 循环可用于遍历填充列表，以将偶数值收集到另一个列表中。
流 API 提供了一种更简洁的方法来执行此操作：
List evens = list????.stream()??????????????????????// 流化 list????.filter(n -> (n & 0x1) == 0)?? // 过滤出奇数值????.collect(Collectors.toList()); // 收集偶数值 这个例子有三个来自流 API 的函数：
??stream 函数可以将集合转换为流，而流是一个每次可访问一个值的传送带。流化是惰性的（因此也是高效的），因为值是根据需要产生的，而不是一次性产生的。 ?filter 函数确定哪些流的值（如果有的话）通过了处理管道中的下一个阶段，即 collect 阶段。filter 函数是 高阶的(higher-order)，因为它的参数是一个函数 —— 在这个例子中是一个 lambda 表达式，它是一个未命名的函数，并且是 Java 新的函数式编程结构的核心。 ?lambda 语法与传统的 Java 完全不同：
n -> (n & 0x1) == 0 箭头（一个减号后面紧跟着一个大于号）将左边的参数列表与右边的函数体分隔开。参数 n 虽未明确类型，但也可以明确。在任何情况下，编译器都会发现 n 是个 Integer。如果有多个参数，这些参数将被括在括号中，并用逗号分隔。
在本例中，函数体检查一个整数的最低位（最右）是否为零，这用来表示偶数。过滤器应返回一个布尔值。尽管可以，但该函数的主体中没有显式的 return。如果主体没有显式的 return，则主体的最后一个表达式即是返回值。在这个例子中，主体按照 lambda 编程的思想编写，由一个简单的布尔表达式 (n & 0x1) == 0 组成。
??collect 函数将偶数值收集到引用为 evens 的列表中。如下例所示，collect 函数是线程安全的，因此，即使在多个线程之间共享了过滤操作，该函数也可以正常工作。 ?方便的功能和轻松实现多线程在生产环境中，数据流的源可能是文件或网络连接。为了学习流 API, Java 提供了诸如 IntStream 这样的类型，它可以用各种类型的元素生成流。这里有一个 IntStream 的例子：
IntStream??????????????????????????// 整型流????.range(1, 2048)????????????????// 生成此范围内的整型流????.parallel()????????????????????// 为多个线程分区数据????.filter(i -> ((i & 0x1) > 0))??// 奇偶校验 - 只允许奇数通过????.forEach(System.out::println); // 打印每个值 IntStream 类型包括一个 range 函数，该函数在指定的范围内生成一个整数值流，在本例中，以 1 为增量，从 1 递增到 2048。parallel 函数自动划分该工作到多个线程中，在各个线程中进行过滤和打印。（线程数通常与主机系统上的 CPU 数量匹配。）函数 forEach 参数是一个方法引用，在本例中是对封装在 System.out 中的 println 方法的引用，方法输出类型为 PrintStream。方法和构造器引用的语法将在稍后讨论。
由于具有多线程，因此整数值整体上以任意顺序打印，但在给定线程中是按顺序打印的。例如，如果线程 T1 打印 409 和 411，那么 T1 将按照顺序 409-411 打印，但是其它某个线程可能会预先打印 2045。parallel 调用后面的线程是并发执行的，因此它们的输出顺序是不确定的。
map/reduce 模式map/reduce 模式在处理大型数据集方面变得很流行。一个 map/reduce 宏操作由两个微操作构成。首先，将数据分散（ 映射(mapped)）到各个工作程序中，然后将单独的结果收集在一起 —— 也可能收集统计起来成为一个值，即 归约(reduction)。归约可以采用不同的形式，如以下示例所示。
下面 Number 类的实例用 EVEN 或 ODD 表示有奇偶校验的整数值：
public class Number {????enum Parity { EVEN, ODD }????private int value;????public Number(int n) { setValue(n); }????public void setValue(int value) { this.value = value; }????public int getValue() { return this.value; }????public Parity getParity() {????????return ((value & 0x1) == 0) ? Parity.EVEN : Parity.ODD;????}????public void dump() {????????System.out.format(\\\\"Value: %2d (parity: %s)n\\\\", getValue(),??????????????????????????(getParity() == Parity.ODD ? \\\\"odd\\\\" : \\\\"even\\\\"));????}} 下面的代码演示了用 Number 流进行 map/reduce 的情形，从而表明流 API 不仅可以处理 int 和 float 等基本类型，还可以处理程序员自定义的类类型。
在下面的代码段中，使用了 parallelStream 而不是 stream 函数对随机整数值列表进行流化处理。与前面介绍的 parallel 函数一样，parallelStream 变体也可以自动执行多线程。
final int howMany = 200;Random r = new Random();Number[] nums = new Number[howMany];for (int i = 0; i < howMany; i++) nums[i] = new Number(r.nextInt(100));List listOfNums = Arrays.asList(nums);??// 将数组转化为 listInteger sum4All = listOfNums????.parallelStream()?????????? // 自动执行多线程????.mapToInt(Number::getValue) // 使用方法引用，而不是 lambda????.sum();???????????????????? // 将流值计算出和值System.out.println(\\\\"The sum of the randomly generated values is: \\\\" + sum4All); 高阶的 mapToInt 函数可以接受一个 lambda 作为参数，但在本例中，它接受一个方法引用，即 Number::getValue。getValue 方法不需要参数，它返回给定的 Number 实例的 int 值。语法并不复杂：类名 Number 后跟一个双冒号和方法名。回想一下先前的例子 System.out::println，它在 System 类中的 static 属性 out 后面有一个双冒号。
方法引用 Number::getValue 可以用下面的 lambda 表达式替换。参数 n 是流中的 Number 实例中的之一：
mapToInt(n -> n.getValue()) 通常，lambda 表达式和方法引用是可互换的：如果像 mapToInt 这样的高阶函数可以采用一种形式作为参数，那么这个函数也可以采用另一种形式。这两个函数式编程结构具有相同的目的 —— 对作为参数传入的数据执行一些自定义操作。在两者之间进行选择通常是为了方便。例如，lambda 可以在没有封装类的情况下编写，而方法则不能。我的习惯是使用 lambda，除非已经有了适当的封装方法。
当前示例末尾的 sum 函数通过结合来自 parallelStream 线程的部分和，以线程安全的方式进行归约。但是，程序员有责任确保在 parallelStream 调用引发的多线程过程中，程序员自己的函数调用（在本例中为 getValue）是线程安全的。
最后一点值得强调。lambda 语法鼓励编写 纯函数(pure function)，即函数的返回值仅取决于传入的参数（如果有）；纯函数没有副作用，例如更新一个类中的 static 字段。因此，纯函数是线程安全的，并且如果传递给高阶函数的函数参数（例如 filter 和 map ）是纯函数，则流 API 效果最佳。
对于更细粒度的控制，有另一个流 API 函数，名为 reduce，可用于对 Number 流中的值求和:
Integer sum4AllHarder = listOfNums????.parallelStream()?????????????????????????? // 多线程????.map(Number::getValue)??????????????????????// 每个 Number 的值????.reduce(0, (sofar, next) -> sofar + next);??// 求和 此版本的 reduce 函数带有两个参数，第二个参数是一个函数：
??第一个参数（在这种情况下为零）是特征值，该值用作求和操作的初始值，并且在求和过程中流结束时用作默认值。 ?第二个参数是累加器，在本例中，这个 lambda 表达式有两个参数：第一个参数（sofar）是正在运行的和，第二个参数（next）是来自流的下一个值。运行的和以及下一个值相加，然后更新累加器。请记住，由于开始时调用了 parallelStream，因此 map 和 reduce 函数现在都在多线程上下文中执行。 ?在到目前为止的示例中，流值被收集，然后被规约，但是，通常情况下，流 API 中的 Collectors 可以累积值，而不需要将它们规约到单个值。正如下一个代码段所示，收集活动可以生成任意丰富的数据结构。该示例使用与前面示例相同的 listOfNums：
Map> numMap = listOfNums????.parallelStream()????.collect(Collectors.groupingBy(Number::getParity));List evens = numMap.get(Number.Parity.EVEN);List odds = numMap.get(Number.Parity.ODD); 第一行中的 numMap 指的是一个 Map，它的键是一个 Number 奇偶校验位（ODD 或 EVEN），其值是一个具有指定奇偶校验位值的 Number 实例的 List。同样，通过 parallelStream 调用进行多线程处理，然后 collect 调用（以线程安全的方式）将部分结果组装到 numMap 引用的 Map 中。然后，在 numMap 上调用 get 方法两次，一次获取 evens，第二次获取 odds。
实用函数 dumpList 再次使用来自流 API 的高阶 forEach 函数：
private void dumpList(String msg, List list) {????System.out.println(\\\\"n\\\\" + msg);????list.stream().forEach(n -> n.dump()); // 或者使用 forEach(Number::dump)} 这是示例运行中程序输出的一部分：
The sum of the randomly generated values is: 3322The sum again, using a different method:???? 3322Evens:Value: 72 (parity: even)Value: 54 (parity: even)...Value: 92 (parity: even)Odds:Value: 35 (parity: odd)Value: 37 (parity: odd)...Value: 41 (parity: odd) 用于代码简化的函数式结构 函数式结构（如方法引用和 lambda 表达式）非常适合在流 API 中使用。这些构造代表了 Java 中对高阶函数的主要简化。即使在糟糕的过去，Java 也通过 Method 和 Constructor 类型在技术上支持高阶函数，这些类型的实例可以作为参数传递给其它函数。由于其复杂性，这些类型在生产级 Java 中很少使用。例如，调用 Method 需要对象引用（如果方法是非静态的）或至少一个类标识符（如果方法是静态的）。然后，被调用的 Method 的参数作为对象实例传递给它，如果没有发生多态（那会出现另一种复杂性！），则可能需要显式向下转换。相比之下，lambda 和方法引用很容易作为参数传递给其它函数。
但是，新的函数式结构在流 API 之外具有其它用途。考虑一个 Java GUI 程序，该程序带有一个供用户按下的按钮，例如，按下以获取当前时间。按钮按下的事件处理程序可能编写如下：
JButton updateCurrentTime = new JButton(\\\\"Update current time\\\\");updateCurrentTime.addActionListener(new ActionListener() {