Java开发从入门到精通（二十）：Java的面向对象编程OOP：Stream流

Java大数据开发和安全开发

  • （一）Java的新特性：Stream流
    • 1.1 什么是Stream?
    • 1.2 Stream流的使用步骤
    • 1.3 获取Stream流
    • 1.4 Stream流常见的中间方法
    • 1.5 Stream流常见的终结方法

（一）Java的新特性：Stream流

1.1 什么是Stream?

  • 也叫Stream流，是Jdk8开始新增的一套API(java.util.stream.*)，可以用于操作集合或者数组的数据

Stream流的优势:

  • Stream流大量的结合了Lambda的语法风格来编程，提供了一种更加强大，更加简单的方式操
    作集合或者数组中的数据，代码更简洁，可读性更好。
    在这里插入图片描述
    体验Stream流
    需求:
    把下面集合中所有以“张”开头，且是3个字的元素存储到一个新的集合。
import java.util.ArrayList;
import java.util.List;

public class StreamTest {
    public static void main(String[] args) {
        List<String> list = new ArrayList<>();
        list.add("张无忌");
        list.add("周芷若");
        list.add("赵敏");
        list.add("张强");
        list.add("张三丰");
    }
}

使用集合和数组的API

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

public class StreamTest {
    public static void main(String[] args) {
        List<String>names =new ArrayList<>();
        Collections.addAll(names,"张三丰","张无忌","周芷若","赵敏","张强");
        System.out.println(names);
        // names=[张三丰，张无忌，周芷若，赵敏，张强】
        //          name
        // 找出姓张，且是3个字的名字，存入到一个新集合中去。
        List<String> list =new ArrayList<>();
        for(String name :names) {
            if (name.startsWith("张") && name.length() == 3) {
                list.add(name);
            }
        }
            System.out.println(list);
    }
}

开始使用Stream流来解决这个需求

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;

public class StreamTest {
    public static void main(String[] args) {
        List<String> names =new ArrayList<>();
        Collections.addAll(names,"张三丰","张无忌","周芷若","赵敏","张强");
        System.out.println(names);
        //开始使用Stream流来解决这个需求。
        List<String> list2 = names.stream().filter(s -> s.startsWith("张")).filter(a ->a.length()==3).collect(Collectors.toList());
        System.out.println(list2);
    }
}

1.2 Stream流的使用步骤

在这里插入图片描述
在这里插入图片描述

1.3 获取Stream流

  • 获取集合的Stream流

在这里插入图片描述

  • 获取 数组 的Stream流

在这里插入图片描述

  • 各种集合和数组获取Stream流的代码示例
import java.util.*;
import java.util.stream.Stream;

public class StreamTest {
    public static void main(String[] args) {
        //1、如何获取List集合的Stream流?
        List<String> names = new ArrayList<>();
        Collections.addAll(names,"张三丰","张无忌","周芷若","赵敏","张强");
        Stream<String> stream =names.stream(); //获取stream流

        // 2、如何获取Set集合的Stream流?
        Set<String> set = new HashSet<>();
        Collections.addAll(set,"刘德华","张曼玉","蜘蛛精","马德","德玛西亚");
        Stream<String>stream1=set.stream();  //获取stream流
        stream1.filter(s ->s.contains("德")).forEach(s -> System.out.println(s));

        // 3、如何获取Map集合的Stream流?
        Map<String,Double> map = new HashMap<>();
        map.put("古力娜扎",172.3);
        map.put("迪丽热巴",168.3);
        map.put("马尔扎哈",166.3);
        map.put("卡尔扎巴",168.3);

        Set<String> keys = map.keySet();
        Stream<String> ks = keys.stream(); //获取stream流 

        Collection<Double>values =map.values();
        Stream<Double>vs=values.stream();  //获取stream流

        Set<Map.Entry<String,Double>>entries = map.entrySet();
        Stream<Map.Entry<String, Double>> kvs = entries.stream();  
        kvs.filter(e ->e.getKey().contains("巴"))
                .forEach(e ->System.out.println(e.getKey()+ "-->"+ e.getValue()));

        // 4、如何获取数组的stream流?
        String[] names2 ={"张翠山","东方不败","唐大山","独孤求败"};
        Stream<String>sl=Arrays.stream(names2); //获取stream流
        Stream<String>s2=Stream.of(names2); //获取stream流

    }
}

1.4 Stream流常见的中间方法

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

在这里插入图片描述

  • 常见的中间方法的代码示例
package com.qianxin.jihekuangjia;

import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class StreamTest {
    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));

        List<Student> students =new ArrayList<>();
        Student s1= new Student( "蜘蛛精",26, 172.5);
        Student s2 = new Student( "蜘蛛精",26,172.5);
        Student s3 = new Student( "紫霞",23, 167.6);
        Student s4= new Student( "白晶晶",25,169.0);
        Student s5 = new Student( "牛魔王", 35,183.3);
        Student s6=new Student( "牛夫人",34,168.5);
        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())
                .forEach(s ->System.out.println(s));
        // 需求3:取出身高最高的前3名学生，并输出。
        students.stream().sorted((o1,o2)-> Double.compare(o2.getHeight(), o1.getHeight()))
                .limit(3).forEach(s ->System.out.println(s));//不同写法1

        students.stream().sorted((o1,o2)-> Double.compare(o2.getHeight(), o1.getHeight()))
                .limit(3).forEach(System.out::println);//不同写法2
        // 需求4:取出身高倒数的2名学生，并输出。
        students.stream().sorted((o1,o2)-> Double.compare(o2.getHeight(),o1.getHeight()))
                .skip(students.size()-2).forEach(System.out::println);
        //需求5:找出身高超过168的学生叫什么名字，要求去除重复的名字，再输出。
        students.stream().filter(s ->s.getHeight()> 168).map(Student::getName)
                .distinct().forEach(System.out::println);

        // distinct去重复，自定义类型的对象(希望内容一样就认为重复，重写hashCode,equal
        students.stream().filter(s->s.getHeight()> 168).distinct().forEach(System.out::println);

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

package com.qianxin.jihekuangjia;

import java.util.Objects;

public class Student {
    private String name;
    private int age;
    private double height;

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        Student student = (Student) o;
        return age == student.age && Double.compare(height, student.height) == 0 && Objects.equals(name, student.name);
    }

    @Override
    public int hashCode() {
        return Objects.hash(name, age, height);
    }

    public Student() {
    }

    public Student(String name, int age, double height) {
        this.name = name;
        this.age = age;
        this.height = height;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public double getHeight() {
        return height;
    }

    public void setHeight(double height) {
        this.height = height;
    }

    @Override
    public String toString() {
        return "Student{" +
                "name='" + name + '\'' +
                ", age=" + age +
                ", height=" + height +
                '}';
    }
}

1.5 Stream流常见的终结方法

  • 终结方法指的是调用完成后，不会返回新Stream了，没法继续使用流了
    在这里插入图片描述
  • 常见的终结方法的代码示例
import java.util.*;
import java.util.stream.Collectors;

public class StreamTest {
    public static void main(String[] args) {
        List<Student> students =new ArrayList<>();
        Student s1= new Student( "蜘蛛精",26, 172.5);
        Student s2 = new Student( "蜘蛛精",26,172.5);
        Student s3 = new Student( "紫霞",23, 167.6);
        Student s4= new Student( "白晶晶",25,169.0);
        Student s5 = new Student( "牛魔王", 35,183.3);
        Student s6=new Student( "牛夫人",34,168.5);
        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:请找出身高最高的学生对象，并输出。
        Student s = students.stream().max((o1, o2)-> Double.compare(o1.getHeight(), o2.getHeight())).get();
        System.out.println(s);

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

收集Stream流的方法
收集Stream流:就是把Stream流操作后的结果转回到集合或者数组中去返回
Stream流:方便操作集合/数组的手段; 集合/数组:才是开发中的目的
在这里插入图片描述

import java.util.*;
import java.util.stream.Collectors;

public class StreamTest {
    public static void main(String[] args) {
        List<Student> students =new ArrayList<>();
        Student s1= new Student( "蜘蛛精",26, 172.5);
        Student s2 = new Student( "蜘蛛精",26,172.5);
        Student s3 = new Student( "紫霞",23, 167.6);
        Student s4= new Student( "白晶晶",25,169.0);
        Student s5 = new Student( "牛魔王", 35,183.3);
        Student s6=new Student( "牛夫人",34,168.5);
        Collections.addAll(students,s1,s2,s3,s4,s5,s6);
      
        // 需求4:请找出身高超过170的学生对象，并放到一个新集合中去返回，
        // 流只能收集一次。
        List<Student> students1 = students.stream().filter(a -> a.getHeight()> 170).collect(Collectors.toList());
        System.out.println(students1);

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

        Student[] arr1 =students.stream().filter(a ->a.getHeight()>170).toArray(len -> new Student[len]);
        System.out.println(Arrays.toString(arr1));
    }
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/544522.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

GNU Radio创建Zadoff-Chu序列C++ OOT块

GNU Radio创建Zadoff-Chu序列C++ OOT块

文章目录 前言一、ZC序列是什么&#xff1f;二、创建自定义的 C OOT 块1、创建 OOT 模块2、创建 OOT 块3、修改 C 文件4、编译及安装 OOT 块 三、测试1、grc 图2、运行结果①、时域图②、时域幅值模图③、IQ 曲线 四、其他五、资源自取 前言 本文实现在 GNU Radio 中创建 Zado…
阅读更多...
银河麒麟之PaddleOCR模型部署

银河麒麟之PaddleOCR模型部署

一、PaddleOCR简介 PaddleOCR是一个基于飞桨框架开发的开源OCR工具&#xff0c;提供了一系列强大的文本识别功能。PaddleOCR支持多种文本识别任务&#xff0c;包括文字检测、文字识别、文本方向检测等。它具有高效、准确的特点&#xff0c;适用于多种场景下的文本识别需求&…
阅读更多...
信息系统项目管理师——管理类计算

信息系统项目管理师——管理类计算

风险管理——风险曝光度 风险曝光度概率*影响&#xff0c;概率指风险发生的概率&#xff0c;影响指风险一旦发生&#xff0c;受到影响的项。 题号【GX20061101](61) 知识点[风险曝光度] 风险的成本估算完成后&#xff0c;可以针对风险表中每个风险计算其风险曝光度。某软件小…
阅读更多...
Servlet测试1

Servlet测试1

通过按钮提交get,post请求&#xff0c;并且后端响应数据&#xff0c;显示到前端 当点击get按钮时 是发起Get请求 后端接收到Get请求后&#xff0c;把数据写入到body内 当点击pst按钮时 是发起Post请求 后端接收到Post请求后&#xff0c;把数据写入到body内 之后前端就从bod…
阅读更多...
【机器学习300问】67、均方误差与交叉熵误差，两种损失函数的区别？

【机器学习300问】67、均方误差与交叉熵误差，两种损失函数的区别？

一、均方误差&#xff08;Mean Squared Error, MSE&#xff09; 假设你是一个教练&#xff0c;在指导学生射箭。每次射箭后&#xff0c;你可以测量子弹的落点距离靶心的差距&#xff08;误差&#xff09;。MSE就像是计算所以射击误差的平方后的平均值。它强调了每一次偏离靶心的…
阅读更多...
Finetuning vs. Prompting：大语言模型两种使用方式

Finetuning vs. Prompting：大语言模型两种使用方式

目录 前言1. 对于大型语言模型的两种不同期待2. Finetune(专才)3. Prompt(通才)3.1 In-context Learning3.2 Instruction-tuning3.3 Chain of Thought(COT) Prompting3.4 用机器来找Prompt 总结参考 前言 这里和大家分享下关于大语言模型的两种使用方式&#xff0c;一种是 Fine…
阅读更多...
简单理解数据存取

简单理解数据存取

1.存 1.从编写程序开始说起&#xff0c;源代码中初始化一个变量&#xff0c;在文本编辑器中显示的是10进制的数&#xff0c; 2.程序运行后&#xff0c;先在内存开辟相应空间&#xff0c;然后&#xff1a; &#xff08;开始实质用数据了&#xff09; 一.将十进制转换为二进制…
阅读更多...
ASP.NET基于BS的计算机等级考试系统的设计与实现

ASP.NET基于BS的计算机等级考试系统的设计与实现

摘 要 随着计算机技术的发展及计算机的日益普及&#xff0c;基于B/S结构的考试系统与无纸化办公一样已成为大势所趋。论文详细论述了一个基于B/S结构的计算机等级考试系统的设计过程。软件采用ASP.NET 2005作开发平台&#xff0c;C#作编程语言&#xff0c;SQL Server 2005作…
阅读更多...
比较指令CMP

比较指令CMP

cmp 比较 将2个值比较输出给软元件 大于条件软元件得电 等于软元件1得电 小于软元件2得电 1&#xff0c;当计数起接通一次Y2得电 当计数器等于5时Y1 得电 当计数器大于5时Y0得电
阅读更多...
python中time库的time.time()函数的作用是什么？

python中time库的time.time()函数的作用是什么？

python中time库的time.time()函数的作用是什么&#xff1f; 作用&#xff1a;Python time time() 返回当前时间的时间戳&#xff08;1970纪元后经过的浮点秒数&#xff09;。 time()方法语法&#xff1a;time.time() #!/usr/bin/python # Write Python 3 code in this onlin…
阅读更多...
蓝桥杯——18

蓝桥杯——18

学习视频&#xff1a;21-广度优先搜索练习_哔哩哔哩_bilibili Q&#xff1a;密码锁 #include<iostream> #include<queue> using namespace std; int s, e; bool vis[10000]; struct node {int state;int step;node(int s1, int s2) {state s1;step s2;} }; int…
阅读更多...
《经典论文阅读2》基于随机游走的节点表示学习—Deepwalk算法

《经典论文阅读2》基于随机游走的节点表示学习—Deepwalk算法

word2vec使用语言天生具备序列这一特性训练得到词语的向量表示。而在图结构上&#xff0c;则存在无法序列的难题&#xff0c;因为图结构它不具备序列特性&#xff0c;就无法得到图节点的表示。deepwalk 的作者提出&#xff1a;可以使用在图上随机游走的方式得到一串序列&#x…
阅读更多...
Java 设计模式系列：模板方法模式

Java 设计模式系列：模板方法模式

简介 模板方法模式是一种行为型设计模式&#xff0c;它定义一个操作中的算法骨架&#xff0c;将一些步骤推迟到子类中。模板方法模式使得子类可以不改变一个算法的结构&#xff0c;即可重定义该算法的某些特定步骤。 在模板方法模式中&#xff0c;抽象类中定义了一系列基本操…
阅读更多...
网络篇10 | 网络层 IP

网络篇10 | 网络层 IP

网络篇10 | 网络层 IP 01 简介02 名称解释03 IP报文格式(IPv4)1&#xff09;4位版本协议(version)2&#xff09;4位首部长度(header length)3&#xff09;8位服务类型(Type Of Service, TOS)4&#xff09;16位总长度5&#xff09;16位(分片)标识6&#xff09;3位(分片)标志7&am…
阅读更多...
深度学习学习日记4.14 数据增强 Unet网络部分

深度学习学习日记4.14 数据增强 Unet网络部分

数据增强 transforms.Compose([&#xff1a;这表示创建一个转换组合&#xff0c;将多个数据转换操作串联在一起 transforms.RandomHorizontalFlip()&#xff1a;这个操作是随机水平翻转图像&#xff0c;以增加数据的多样性。它以一定的概率随机地水平翻转输入的图像。 transfo…
阅读更多...
coreldraw2024直装版下载 永久免费使用附下载安装教程（ 仅限 win10用户 ）

coreldraw2024直装版下载 永久免费使用附下载安装教程（ 仅限 win10用户 ）

CorelDRAW 2024具有一些特别的优势&#xff0c;这些优势不仅体现在其丰富的功能和卓越的性能上&#xff0c;还体现在其跨平台的兼容性上。 首先&#xff0c;CorelDRAW 2024支持多种操作系统平台&#xff0c;包括但不限于Windows 10和Windows 11等高级操作系统。这意味着无论是…
阅读更多...
webpack-(plugin，本地服务器，路径别名，安装vue)

webpack-(plugin，本地服务器，路径别名，安装vue)

安装vue npm i vue-loader -D npm i vue 编写一个vue文件&#xff1a; 在index.html中设置 一个id为app的div 将vue文件挂载到app中 vue比较特殊&#xff0c;除了使用loader外&#xff0c;还使用了plugin const path require("path"); const { VueLoaderPlugin …
阅读更多...
zabbix 使用 dataease 做数据大屏

zabbix 使用 dataease 做数据大屏

1、环境介绍 操作系统&#xff1a;龙蜥os 7.9 软件&#xff1a;dataease v1.18.18 zabbix&#xff1a; 6.0 2、软件下载 https://community.fit2cloud.com/#/products/dataease/downloads 3、将软件包上传到服务器并解压缩 tar -xvf dataease-v1.18.18-offline.tar.gz4、修改…
阅读更多...
鸿蒙端云一体化开发--开发云函数--适合小白体制

鸿蒙端云一体化开发--开发云函数--适合小白体制

开发云函数 那什么是云函数&#xff1f;我们将来又怎么去使用这个云函数呢&#xff1f; 答&#xff1a;我们之前要编写一些服务端的业务逻辑代码&#xff0c;那现在&#xff0c;在这种端云一体化的开发模式下&#xff0c;我们是把服务端的业务逻辑代码&#xff0c;通过云函数来…
阅读更多...
Mybatis中SqlSession接口中的selectList方法

Mybatis中SqlSession接口中的selectList方法

1、SqlSession SqlSession是Mybatis持久层框架提供的接口&#xff0c;该接口中包含了大量的CRUD操作方法&#xff08;既增删改查方法&#xff09;。 2、selectList方法 selectList方法是用于查询的方法&#xff0c;该方法具有多态性&#xff0c;如图所示&#xff08;打开myb…
阅读更多...
最新文章

Copyright @ 2022~2023