stream()作为JDK8的新特性,主要做用于集合的操作,简化其操作流程
其主要的操作大致可分为三种:
一、获取数据源进行封装
二、对数据的处理封装
三、收集结果的返回
stream流的熟练的使用可以大幅度的减少代码的工作量,使其更简便的操作数据,其弊端在于可读性不好
多说无益:举例示意:
实体类(实体类集成了lombok方法有注解代替):
package com.moon.pojo; import lombok.AllArgsConstructor; import lombok.Data; @Data @AllArgsConstructor public class User { private String name; private Integer age; private Integer salary; }
测试代码(集成了testng):
@Test public void Stream(){ List<User> list = Arrays.asList(new User("小明", 20, 3000), new User("小红", 21, 4000), new User("小霞", 25, 6000)); /*常规操作*/ //list中的User实体中age<21的: List<User> newList=new ArrayList<User>(); for(User user: list){ if (user.getAge()<21)newList.add(user); } //list中user实体的薪资salary>4000 List<User>newList2 =new ArrayList<User>(); for (User user:list){ if (user.getSalary()>4000)newList2.add(user); }
使用stream流操作:
Predicate<User> predicate=user -> user.getAge()<21; Predicate<User> predicate1=user -> user.getSalary()>4000; List<User> collect = list.stream() .filter(predicate)//添加过滤条件 .filter(predicate1)//添加过滤条件 .collect(Collectors.toList());//生成新集合 //等价于 Predicate<User>predicate2=user -> user.getAge()<21; Predicate<User>predicate3=user -> user.getSalary()>4000; List<User> collect1=list.stream() .filter(predicate2.and(predicate1)) //&&等价and,||等价or .collect(Collectors.toList()); //等价于 List<User> collect2=list.stream() .filter(user -> user.getAge()<21) .filter(user -> user.getSalary()>4000) .collect(Collectors.toList());
常用的API
一、.fillter过滤
取出list中字符串长度大于5的元素
List<String> strings = Arrays.asList("stream", "lambda", "java"); strings.stream() .filter(str->str.length()>5) .forEach(str-> System.out.println(str));
二、limit截取
取出list中的前两个元素
List<String> strings = Arrays.asList("stream", "lambda", "java"); strings.stream() .limit(2) .forEach(str-> System.out.println(str));
三、sorted排序
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6); integerList.stream() .sorted() //.sorted(Comparator.reverseOrder)降序 .forEach(num-> System.out.println(num));//123456 默认升序
四、最大值max和最小值min
最大值max
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6); System.out.println(integerList.stream() .max(Integer::compareTo).get());
最小值min
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6); System.out.println(integerList.stream().min(Integer::compareTo).get());
五、count :元素个数
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6); System.out.println(integerList.stream() .count());
六、map:对链表中的每个元素进行操作
每个列表中每个元素加10
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6); integerList.stream() .map(num->num+10) .forEach(num-> System.out.println(num));
七、reduce对列表元素进行追加,返回一个值
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6); System.out.println(integerList.stream() .reduce((sum,num)->sum+num));
八、collection基于目标集合生成新的集合
取偶数集合
List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6); List<Integer> collect3 = integerList.stream() .filter(num -> num % 2 == 0) .collect(Collectors.toList()); System.out.println(collect3);