美文网首页程序员
强大的Stream API(二) Stream的(filter,

强大的Stream API(二) Stream的(filter,

作者: Mason啊 | 来源:发表于2017-12-20 16:20 被阅读424次

    接着上一篇文章继续,如果没有看过上一篇文章的可以去看看强大的Stream API(一) Stream的创建,然后接着看下面的文章,如果对Stream的创建方式有了解,直接继续往下看。
    关于Stream的中间操作不会放一篇文章去写,不然篇幅会比较长,可能会分几篇文章写,ok,接下来我们直接看它中间操作到底有哪些吧。
    首先说一下中间操作:多个中间操作可以连接起来形成一个流水线,除非流水线上触发终止操作,否则中间操作不会执行任何的处理!而在终止操作时一次性全部处理,称为“惰性求值”。

    一、筛选与切片
    这里面有以下方法

    filter(Predicate p) 接收 Lambda , 从流中排除某些元素。
    distinct() 筛选,通过流所生成元素的 hashCode() 和 equals() 去除重复元素
    limit(long maxSize) 截断流,使其元素不超过给定数量。
    skip(long n) 跳过元素,返回一个扔掉了前 n 个元素的流。若流中元素不足 n 个,则返回一个空流。与 limit(n) 互补
    接下来将用代码的方式一一带领大家去看看这个方法的作用,不然只看文字不看效果觉得学习的效果还是不是很好。

    1、filter(Predicate p),其中方法的解释上面也说的很清楚了,这里就不在继续啰嗦了,现在有这么一个需求,就是过滤出年龄大于20岁的员工
    这里是一个员工的集合

    List<Employee> emps = Arrays.asList(
                new Employee(101, "张三", 28, 9999),
                new Employee(102, "李四", 49, 666),
                new Employee(103, "王五", 38, 333),
                new Employee(104, "赵六", 12, 7777),
                new Employee(105, "田七", 6, 222)
        );
     @Test
        public void test1() {
            emps.stream()
                    .filter((e) -> e.getAge() > 20)
                    .forEach(System.out::println);
        }
    

    System.out::println 这里使用的是方法引用中的 对象的引用 :: 实例方法名,关于这个我在只后的文章中都不提了,如果还有不理解的请阅读我的这篇文章Lambda表达式学习(四)Lambda 表达式方法引用、构造器引用和数组引用OK,接下来我们看看运行的效果

    image.png 从图片中可以看出filter方法的作用。根据你的条件筛选出你要的结果。

    2、distinct()方法就是去重,上面的解释也很清楚,这里就不给出代码了,如果想看看效果的同学可以去实现一下,注意的是要重写hashCode()方法和equals()方法。

    3、limit(long maxSize) 截取前面maxSize条数据,在上面的代码的基础上我加了个方法

    @Test
        public void test1() {
            emps.stream()
                    .filter((e) -> e.getAge() > 20)
                    .limit(2)
                    .forEach(System.out::println);
        }
    
    然后在看下结果 image.png

    结果就是这个样了。

    4、与limit相反的就是skip(long n),跳过前面几条,代码和上面差不多,就不写出来了。

    二、映射

    map(Function f) 接收 Lambda , 将元素转换成其他形式或提取信息;接收一个函数作为参数,该函数会被应用到每个元素上,并将其映射成一个新的元素。
    mapToDouble(ToDoubleFunction f) 接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新的 DoubleStream。
    mapToInt(ToIntFunction f) 接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新的 IntStream。
    mapToLong(ToLongFunction f) 接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新的 LongStream。
    flatMap(Function f) 接收一个函数作为参数,将流中的每个值都换成另一个流,然后把所有流连接成一个流。

    每一个方法的作用这里都写的很清楚了,在接下来的讲解中就直接给出代码了,如果有需要的地方我会提一下。上面我不会全写,我会先写两个常用的,其他的用法都是类似的。
    1、map(Function f)

    List<String> strList = Arrays.asList("aaa", "bbb", "ccc", "ddd", "eee");
    Stream<String> stream = strList.stream()
                   .map(String::toUpperCase);
    stream.forEach(System.out::println);
    

    这个就是把所有的元素转换成大写。

    2、flatMap(Funtion f)

     public static Stream<Character> filterCharacter(String str){
            List<Character> list = new ArrayList<>();
            for (Character ch : str.toCharArray()) {
                list.add(ch);
            }
            return list.stream();
        }
    

    这是讲一个字符串转化为一个字符集合,然后通过流的方式返回

    Stream<Stream<Character>> stream2 = strList.stream()
                   .map(StreamApiTest::filterCharacter);
    stream2.forEach((sm) -> {
                sm.forEach(System.out::print);
            });
    
    Stream<Character> stream3 = strList.stream()
                   .flatMap(StreamApiTest::filterCharacter);
     stream3.forEach(System.out::print);
    

    这两种方式实现的效果是一样的,但是可以看map的返回的是一个Stream流中的泛型是一个流,而flatMap返回的流的泛型的是一个Character,然后冲forEach的方式也可以看出其中的差异。
    其中mapToDouble,mapToInt,mapToLong返回的是相对应的流,我就实现其中的一个,其他的原理都是一样的,如果有兴趣的同学可以自己去实现一下看看。

    List<Double> doubles = Arrays.asList(1D,2D,3D,4D);
    
    DoubleStream ds = doubles.stream()
                    .mapToDouble((d) -> d * 2);
            ds.forEach(System.out::println);
    
    image.png

    ok,先讲到这里,如果有兴趣的可以继续看我的下一篇文章。
    强大的Stream API(三) Stream的(filter,limit,skip,map)等中间操作之二

    相关文章

      网友评论

        本文标题:强大的Stream API(二) Stream的(filter,

        本文链接:https://www.haomeiwen.com/subject/slggwxtx.html