Java——Stream流（2/2）：Stream流的中间方法、终结方法（方法、案例演示）

Stream流的中间方法

方法

案例演示

Stream流的终结方法

方法

案例演示1

收集

案例演示2

Stream流的中间方法

方法

中间方法指的是调用完成后会返回新的Stream流，可以继续使用(支持链式编程)。

Stream提供的常用中间方法	说明
Stream<T> filter(Predicate<? super T> predicate)	用于对流中的数据进行过滤。
Stream<T> sorted()	对元素进行升序排序
Stream<T> sorted(Comparator<?super T> comparator)	按照指定规则排序
Stream<T> limit(long maxSize)	获取前几个元素
Stream<T> skip(long n)	跳过前几个元素
Stream<T> distinct()	去除流中重复的元素。
<R> Stream<R> map(Function<? super T,? extends R> mapper)	对元素进行加工，并返回对应的新流
static <T> Stream<T> concat(Stream a，Stream b)	合并a和b两个流为一个流

案例演示

需求1：找出成绩大于等于60分的数据，并升序后，再输出。

public class streamTest3 {public static void main(String[] args) {List<Double> scores = new ArrayList<>();Collections.addAll(scores,88.5,100.0,60.0,99.0,9.5,99.6,25.0);//需求1：找出成绩大于等于60分的数据，并升序后，再输出。scores.stream().filter(s -> s >= 60).sorted().forEach(s -> System.out.println(s));}
}

运行结果：

需求2：找出年龄大于等于23，且年龄小于等于30岁的学生，并按照年龄降序输出。

public class streamTest3 {public static void main(String[] args) {List<Student> students = new ArrayList<>();Student s1 = new Student("蜘蛛精", 172.5,26 );Student s2 = new Student("蜘蛛精",172.5,26);Student s3 = new Student("紫霞",167.6,23);Student s4 = new Student("白晶晶",169.0,25);Student s5 = new Student("牛魔王",183.3,35);Student s6 = new Student("牛夫人",168.5,34);Collections.addAll(students,s1,s2,s3,s4,s5,s6);//需求2：找出年龄大于等于23，且年龄小于等于30岁的学生，并按照年龄降序输出。students.stream().filter(s -> s.getAge() >= 23 && s.getAge() <= 30).sorted((o1,o2) -> o2.getAge() - o1.getAge())  //重载的sort方法.forEach(s -> System.out.println(s));}
}

运行结果：

需求3：取出身高最高的前3名学生，并输出。

    //需求3：取出身高最高的前3名学生，并输出。students.stream().sorted((o1,o2) -> Double.compare(o2.getHeight(),o1.getHeight())).limit(3).forEach(s -> System.out.println(s));

运行结果：

再简化输出语句：

需求4：取出身高倒数的2名学生

//需求4：取出身高倒数的2名学生
students.stream().sorted((o1,o2) -> Double.compare(o2.getHeight(),o1.getHeight())).skip(students.size() - 2).forEach(System.out::println);

运行结果：

需求5：找出身高超过168的学生叫什么名字，要求去除重复的名字，再输出。

//需求5：找出身高超过168的学生叫什么名字，要求去除重复的名字，再输出。
students.stream().filter(s -> s.getHeight() > 168).map(Student::getName /* s->s.getName()*/ ).distinct().forEach(System.out::println);

运行结果：

concat的使用

Stream<String> st1 = Stream.of("张三","李四");
Stream<String> st2 = Stream.of("张三2","李四2","王五");
Stream<String> allSt = Stream.concat(st1,st2);
allSt.forEach(System.out::println);

运行结果：

Stream流的终结方法

方法

终结方法指的是调用完成后，不会返回新Stream了，没法继续使用流了。

Stream提供的常用终结方法	说明
void forEach(Consumer action)	对此流运算后的元素执行遍历
long count()	统计此流运算后的元素个数
Optional<T> max(Comparator<? super T > comparator)	获取此流运算后的最大值元素
Optional<T> min(Comparator<? super T> comparator)	获取此流运算后的最小值元素

案例演示1

需求1：计算出身高超过168的学生有几人

public class streamTest4 {public static void main(String[] args) {List<Student> students = new ArrayList<>();Student s1 = new Student("蜘蛛精", 172.5,26 );Student s2 = new Student("蜘蛛精",172.5,26);Student s3 = new Student("紫霞",167.6,23);Student s4 = new Student("白晶晶",169.0,25);Student s5 = new Student("牛魔王",183.3,35);Student s6 = new Student("牛夫人",168.5,34);Collections.addAll(students,s1,s2,s3,s4,s5,s6);//需求1：计算出身高超过168的学生有几人long size = students.stream().filter(s -> s.getHeight() > 168).count();System.out.println(size);}
}

运行结果：

需求2：请找出身高最高的学生对象，并输出

//需求2：请找出身高最高的学生对象，并输出
Student s = students.stream().max((o1,o2) -> Double.compare(o1.getHeight(),o2.getHeight())).get();
System.out.println(s);

运行结果：

需求3：请找出身高最矮的学生对象，并输出

//需求3：请找出身高最矮的学生对象，并输出
Student ss = students.stream().min((o1,o2) -> Double.compare(o1.getHeight(),o2.getHeight())).get();
System.out.println(ss);

运行结果：

收集

收集Stream流：就是把Stream流操作后的结果转回到集合或者数组中去返回。

Stream流：方便操作集合/数组的手段；集合/数组：才是开发中的目的。

Stream提供的常用终结方法	说明
R collect(Collector collector)	把流处理后的结果收集到一个指定的集合中去
Object[] toArray()	把流处理后的结果收集到一个数组中去

Collectors工具类提供了具体的收集方式	说明
public static<T> Collector toList()	把元素收集到List集合中
public static<T> Collector toSet()	把元素收集到Set集合中
public static Collector toMap(Function keyMapper，Function valueMapper)	把元素收集到Map集合中

案例演示2

需求4：请找出身高超过170的学生对象，并放到一个新集合中去返回

//需求4：请找出身高超过170的学生对象，并放到一个新集合中去返回
List<Student> students1 = students.stream().filter(a -> a.getHeight() > 170).collect(Collectors.toList());
System.out.println(students1);
System.out.println("-----------------------");
Set<Student> students2 = students.stream().filter(a -> a.getHeight() > 170).collect(Collectors.toSet());
System.out.println(students2);

运行结果：

注意：流只能收集一次 （就像是水喝光了，或者是迭代器的指针指到了最后的位置）

例如：

需求5：请找出身高超过170的学生对象，并把学生对象的名字和身高，存入到一个Map集合返回。

（需要手动去重）

//需求5：请找出身高超过170的学生对象，并把学生对象的名字和身高，存入到一个Map集合返回。
Map<String,Double> map =students.stream().filter(a -> a.getHeight() > 170).distinct().collect(Collectors.toMap(a -> a.getName(),a -> a.getHeight()));
System.out.println(map);

运行结果：

Stream流收集为数组

Object[] arr1 = students.stream().filter(a -> a.getHeight() > 170).toArray();//如果不想要Object类型，则
Student[] arr2 = students.stream().filter(a -> a.getHeight() > 170).toArray(len -> new Student[len]);
System.out.println(Arrays.toString(arr2));

运行结果：