Java 8 流 Stream ( 下 )

上一章节 Java 8 流 Stream ( 上 ) 因为时间关系，我们介绍到一半半就停止了。本章节我们继续。

limit() 方法

limit() 方法用于减少( 限制 ) 流中的元素数量。

例如下面的代码段演示了如何使用 limit() 方法只输出 10 个随机数

                Random random = new Random();
                random.ints().limit(10).forEach(System.out::println);

sorted() 方法

sorted() 方法用于给流中的元素进行排序。

下面的范例演示了如何按照排序顺序打印 10 个随机数

                Random random = new Random();
                random.ints().limit(10).sorted().forEach(System.out::println);

并发处理

parallelStream() 是需要并发处理的流的替代方案。stream() 方法产生的流只能是串行处理，可以理解为只在一个线程中，按照流中元素的顺序一个接一个的处理。

而并发处理，就是传说中的 map-reduce 方法，可以充分利用多核优势。

需要注意的是，parallelStream() 会打乱流的顺序，也就是返回的序列顺序不一定是输入的序列顺序。

例如下面的代码用于打印序列中的空字符串的数量

                List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");
            
                //get count of empty string
                int count = strings.parallelStream().filter(string -> string.isEmpty()).count();

因为 stream() 返回是串行流，而 parallelStream() 返回的是并行流。因此在串行和并行之间切换是非常简单的。

收集器（ Collectors ）

收集器（ Collectors ）用于将已经处理的流中的元素组合到一起。

Collectors 类提供了大量方法用于指示如何收集元素。

比如 Collectors.toList() 方法可以将流中的元素收集起来，并转换为列表

                List<String>strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");
                List<String> filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());
            
                System.out.println("Filtered List: " + filtered);

比如 Collectors.joining() 方法可以将流中的元素收集起来，并使用指定的字符串拼接符拼接成一个字符串。

                List<String>strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");
                String mergedString = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.joining(", "));
            
                System.out.println("Merged String: " + mergedString);

统计 ( Statistics )

Java 8 同时新增了大量的统计收集器来来获取流中的元素的一些统计信息。

前提是我们先要在流上调用 summaryStatistics() 方法返回统计信息概要，然后在调用相应的方法来获取具体的统计信息。

例如下面的代码，先调用 summaryStatistics() 方法返回统计概要，然后调用 getMax() 方法获取最大值

                List numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
            
                IntSummaryStatistics stats = integers.stream().mapToInt((x) -> x).summaryStatistics();
            
                System.out.println("Highest number in List : " + stats.getMax());

例如下面的代码，先调用 summaryStatistics() 方法返回统计概要，然后调用 getMin() 和 getSum() 方法获取最小值和所有数字之和

                List numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
            
                IntSummaryStatistics stats = integers.stream().mapToInt((x) -> x).summaryStatistics();
            
                System.out.println("Lowest number in List : " + stats.getMin());
                System.out.println("Sum of all numbers : " + stats.getSum());

例如下面的代码，先调用 summaryStatistics() 方法返回统计概要，然后调用 getAverage() 方法获取平均值

                List numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
            
                IntSummaryStatistics stats = integers.stream().mapToInt((x) -> x).summaryStatistics();
            
                System.out.println("Average of all numbers : " + stats.getAverage());

来源：https://www.twle.cn

Java 面试宝典是大明哥全力打造的 Java 精品面试题，它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题，而是一套完整的 Java 知识体系，一套你 Java 知识点的扫盲贴。

它的内容包括：

大厂真题：Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
原创内容：Java 面试宝典内容全部都是大明哥原创，内容全面且通俗易懂，回答部分可以直接作为面试回答内容。
持续更新：一次购买，永久有效。大明哥会持续更新 3+ 年，累计更新 1000+，宝典会不断迭代更新，保证最新、最全面。
覆盖全面：本宝典累计更新 1000+，从 Java 入门到 Java 架构的高频面试题，实现 360° 全覆盖。
不止面试：内容包含面试题解析、内容详解、知识扩展，它不仅仅只是一份面试题，更是一套完整的 Java 知识体系。
宝典详情：https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
宝典总览：https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
宝典进展：https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道，总字数 42w+。大明哥还在持续更新中，下图是大明哥在 2024-12 月份的更新情况：

想了解详情的小伙伴，扫描下面二维码加大明哥微信【daming091】咨询

同时，大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ，回复【面试题】即可免费领取。

阅读全文