Java——Stream流(2/2):Stream流的中间方法、终结方法(方法、案例演示)

简介: Java——Stream流(2/2):Stream流的中间方法、终结方法(方法、案例演示)

Stream流的中间方法

方法

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

图片.png

案例演示

需求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了,没法继续使用流了。
  • 图片.png

案例演示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() 把流处理后的结果收集到一个数组中去

图片.png

案例演示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));

运行结果:



END



目录
相关文章
|
11天前
|
Java API 数据处理
Java新特性:使用Stream API重构你的数据处理
Java新特性:使用Stream API重构你的数据处理
|
13天前
|
Java 开发者
Java 函数式编程全解析:静态方法引用、实例方法引用、特定类型方法引用与构造器引用实战教程
本文介绍Java 8函数式编程中的四种方法引用:静态、实例、特定类型及构造器引用,通过简洁示例演示其用法,帮助开发者提升代码可读性与简洁性。
|
18天前
|
Java 大数据 API
Java Stream API:现代集合处理与函数式编程
Java Stream API:现代集合处理与函数式编程
177 100
|
18天前
|
Java API 数据处理
Java Stream API:现代集合处理新方式
Java Stream API:现代集合处理新方式
192 101
|
18天前
|
并行计算 Java 大数据
Java Stream API:现代数据处理之道
Java Stream API:现代数据处理之道
171 101
|
28天前
|
存储 数据可视化 Java
Java Stream API 的强大功能
Java Stream API 是 Java 8 引入的重要特性,它改变了集合数据的处理方式。通过声明式语法,开发者可以更简洁地进行过滤、映射、聚合等操作。Stream API 支持惰性求值和并行处理,提升了代码效率和可读性,是现代 Java 开发不可或缺的工具。
Java Stream API 的强大功能
|
2月前
|
存储 NoSQL Java
Java Stream API:集合操作与并行处理
Stream API 是 Java 8 提供的集合处理工具,通过声明式编程简化数据操作。它支持链式调用、延迟执行和并行处理,能够高效实现过滤、转换、聚合等操作,提升代码可读性和性能。
|
22天前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
Java 数据库 Spring
61 0
|
1月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
98 16

热门文章

最新文章