2021-05-05 15:15  阅读(2281)
文章分类:Java 8 特性 文章标签:JavaJava 8
©  原文作者:简单教程 原文地址:https://www.twle.cn/

上一章节 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

点赞(3)
版权归原创作者所有,任何形式转载请联系作者; Java 技术驿站 >> Java 8 流 Stream ( 下 )
上一篇
Java 8 流 Stream ( 上 )
下一篇
Java 函数接口 ( Functional interface )