流表示一系列元素并支持不同类型的操作来对这些元素执行计算。在Java 8中，Collection接口有两种方法来生成Stream

　　stream()parallelStream()

　　流操作包括中间或终端，中间操作返回一个流，所以我们可以链接多个中间操作而不使用分号。 终端操作是void的或返回非流结果。

　　Stream是可以执行顺序和并行聚合操作的一系列元素 。 任何给定的“Stream”都可能有无限量的数据流过它。 你所得到的结果是从“Stream”接收的数据在到达时被单独处理，而不是完全对数据执行批处理。 当与lambda表达式 结合时，它们提供了使用函数方法对数据序列执行操作的简明方法。

　　Stream fruitStream=Stream.of("apple", "banana", "pear", "kiwi", "orange");

　　fruitStream.filter(s -> s.contains("a"))

　　.map(String::toUpperCase)

　　.sorted()

　　.forEach(System.out::println);

　　上述代码执行的操作可以总结如下：

　　1. 使用静态工厂方法Stream.of(values)创建一个包含fruit String的顺序排序Stream的Stream 元素；

　　2. filter()操作仅保留与给定谓词（由谓词返回true测试时的元素）匹配的元素。 在这种情况下，它保留含有“a”的元素。 谓词作为lambda表达式给出；

　　3. map() 操作转换 每个元素使用给定的函数，称为映射器。 在这种情况下，每个fruit String使用method-reference映射到将string字符串转换为大写版本String::toUppercase。

　　Note 如果映射函数返回与其输入参数不同的类型，那么map()操作将返回具有不同泛型类型的流。 例如在一个Stream调用.map(String :: isEmpty)返回一个Stream

　　4. sorted()操作对Stream的元素进行排序 根据它们的自然排序（根据在’String’的情况下对所在字典的顺序，其实都知道）；

　　5. 最后， forEach(action) 操作执行一个动作，作用于“Stream”的每个元素，将其传递给一个 Consumer。 在该示例中，每个元素只是被打印到控制台。 该操作是游戏终端操作，因此不可能再次进行操作。

　　Note 在Stream中定义的操作之所以被执行，是因为最后有终端操作。 假如没有终端操作，’Stream’将不被处理，因为’Stream’输出不被任何终端操作使用(省的浪费计算资源，所以很多书上称之为被动式foreach)。

　　操作（如上所示）链接在一起以形成可以被视为对数据的查询。

　　一个Stream不能重复使用。 一旦调用任何中间或终端操作，“Stream”对象将变得不可用。 Stream代替地使用中间Stream对象，以便将中间操作链接在一起，通过一系列Stream操作来生成一个Stream对象作为中间对象，最后再调用这个生成的Stream对象来完成最终的操作，最后一步的操作只能进行一次，之后，此流已经没了(生命周期已结束)。

　　Stream stream=

　　Stream.of("d2", "a2", "b1", "b3", "c")

　　.filter(s -> s.startsWith("a"));

　　stream.anyMatch(s -> true); // The Stream has been used and is now consumed.

　　stream.noneMatch(s -> true); // IllegalStateException; stream was already used

　　Stream接口扩展了 AutoCloseable。Streams可以通过调用 close方法或使用try-with -resource语句来关闭。

　　请注意，Stream通常不必关闭。仅需要关闭在IO通道上运行的流。 大多数Stream 型不对古玩资源操作，因此不需要关闭。

　　Stream 应该关闭的示例用例是，当您从文件创建一个Stream 行时：

　　try(final Stream lines=Files.lines(Paths.get("somePath"))){

　　lines.forEach(System.out::println);

　　}

　　Stream对象的处理可以是顺序或 parallel(并行)。

　　在 sequential 模式中，按照“Stream”的源的顺序处理元素。 如果Stream是有序的（例如 SortedMap实现或List，处理过程保证匹配源的排序。 然而，在其他情况下，应注意不要依赖于顺序。

　　List integerList=Arrays.asList(0, 1, 2, 3, 42);

　　// sequential

　　long howManyOddNumbers=integerList.stream()

　　.filter(e -> (e % 2)==1).count();

　　System.out.println(howManyOddNumbers); // Output: 2

　　并行模式允许在多个核上使用多个线程，但不能保证处理元素的顺序。

　　如果在顺序的 Stream 上虽然调用了多个方法，则不一定必须要调用每个方法。 例如，如果一个 Stream 被过滤，并且元素的数量减少到一，则不会发生对诸如sort的方法的后续调用。 这可以提高顺序的Stream的性能 - 这是一个并行的Stream不可能实现的优化。

　　* Example:

　　// parallel

　　long howManyOddNumbersParallel=integerList.parallelStream()

　　.filter(e -> (e % 2)==1).count();

　　System.out.println(howManyOddNumbersParallel); // Output: 2