Java高级重点知识点-25-Stream流、方法引用

文章目录

  • Stream流
    • 流式思想概述
    • 获取流
    • 常用方法
  • 方法引用
    • 方法引用符
    • 通过对象名引用成员方法
    • 通过类名称引用静态方法
    • 通过super引用成员方法
    • 通过this引用成员方法
    • 类的构造器引用
    • 数组的构造器引用

Stream流

通过循环遍历来讲解流的优势;
要求:筛选所有姓张的人;然后筛选名字有三个字的人; 最后进行对结果进行打印输出。

import java.util.ArrayList;
import java.util.List;
public class Demo02NormalFilter {public static void main(String[] args) {List<String> list = new ArrayList<>();list.add("张无忌");list.add("周芷若");list.add("赵敏");list.add("张强");list.add("张三丰");List<String> zhangList = new ArrayList<>();for (String name : list) {if (name.startsWith("张")) {zhangList.add(name);}}List<String> shortList = new ArrayList<>();for (String name : zhangList) {if (name.length() == 3) {shortList.add(name);}}for (String name : shortList) {System.out.println(name);}}
}

在这里插入图片描述
这段代码中我们可以看到,我们首先通过遍历集合list来获取到了所有姓张的人,然后我们通过遍历shortList集合来获取到了名字长度为三个字的人。最终打印出了名字三个字并且姓张的人,很显然这个过程很麻烦,下面我们来看一下Stream流式写法;

import java.util.ArrayList;
import java.util.List;
public class Demo03StreamFilter {
public static void main(String[] args) {List<String> list = new ArrayList<>();list.add("张无忌");list.add("周芷若");list.add("赵敏");list.add("张强");list.add("张三丰");list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() == 3).forEach(System.out::println);}
}

在这里插入图片描述
这里我们可以看到我们通过filter()过滤方法过滤掉了姓张且名字长度为3的人,并且通过方法引用来输出打印。

流式思想概述

流式思想类似于工厂车间的“生产流水线”
Stream流”其实是一个集合元素的函数模型,它并不是集合,也不是数据结构,其本身并不存储任何元素(或其地址值)。
Stream(流)是一个来自数据源的元素队列

  • 元素是特定类型的对象,形成一个队列。 Java中的Stream并不会存储元素,而是按需计算。
    数据源 流的来源。 可以是集合,数组 等。
  • Pipelining: 中间操作都会返回流对象本身。 这样多个操作可以串联成一个管道, 如同流式风格(fluentstyle)。 这样做可以对操作进行优化, 比如延迟执行(laziness)和短路( short-circuiting)。
  • 内部迭代: 以前对集合遍历都是通过Iterator或者增强for的方式, 显式的在集合外部进行迭代, 这叫做外部迭代。 Stream提供了内部迭代的方式,流可以直接调用遍历方法。

获取流

java.util.stream.Stream<T> 是Java 8新加入的最常用的流接口

  • 所有的 Collection 集合都可以通过 stream 默认方法获取流;
  • Stream 接口的静态方法 of 可以获取数组对应的流。
  1. 根据Collection获取流
import java.util.*;
import java.util.stream.Stream;
public class Demo04GetStream {public static void main(String[] args) {List<String> list = new ArrayList<>();Stream<String> stream1 = list.stream();Set<String> set = new HashSet<>();Stream<String> stream2 = set.stream();Vector<String> vector = new Vector<>();Stream<String> stream3 = vector.stream();}
}
  1. 根据Map获取流

java.util.Map 接口不是 Collection 的子接口,且其K-V数据结构不符合流元素的单一特征,所以获取对应的流 需要分key、value或entry等情况

import java.util.HashMap;
import java.util.Map;
import java.util.stream.Stream;
public class Demo05GetStream {public static void main(String[] args) {Map<String, String> map = new HashMap<>();Stream<String> keyStream = map.keySet().stream();Stream<String> valueStream = map.values().stream();Stream<Map.Entry<String, String>> entryStream = map.entrySet().stream();}
}
  1. 根据数组获取流
    Stream 接口中提供了静态方法of来实现数组的流化。
import java.util.stream.Stream;
public class Demo06GetStream {public static void main(String[] args) {String[] array = { "张无忌", "张翠山", "张三丰", "张一元" };Stream<String> stream = Stream.of(array);}
}

常用方法

  • 延迟方法:返回值类型仍然是 Stream 接口自身类型的方法,因此支持链式调用。(除了终结方法外,其余方法均为延迟方法。)
  • 终结方法:返回值类型不再是 Stream 接口自身类型的方法,因此不再支持类似 StringBuilder 那样的链式调用。

逐一处理:forEach

  • void forEach(Consumer<? super T> action);
import java.util.stream.Stream;
public class StreamForEach {public static void main(String[] args) {Stream<String> stream = Stream.of("张三", "张三丰", "周姐");stream.forEach(name‐> System.out.println(name));}
}

过滤:filter

  • Stream<T> filter(Predicate<? super T> predicate);
import java.util.stream.Stream;
public class Demo07StreamFilter {public static void main(String[] args) {Stream<String> original = Stream.of("张三", "张三丰", "周姐");Stream<String> result = original.filter(s ‐> s.startsWith("张"));}
}

映射:map

  • <R> Stream<R> map(Function<? super T, ? extends R> mapper); 将流中的元素映射到另一个流中
import java.util.stream.Stream;
public class Demo08StreamMap {public static void main(String[] args) {Stream<String> original = Stream.of("10", "12", "18");Stream<Integer> result = original.map(str‐>Integer.parseInt(str));}
}

统计个数:count

  • long count(); 这里的返回值是long类型,不再和旧集合一样是int类型,也就是说可以用来获取更大的集合对象的大小。
import java.util.stream.Stream;
public class Demo09StreamCount {public static void main(String[] args) {Stream<String> original = Stream.of("张三", "张三丰", "周姐");Stream<String> result = original.filter(s ‐> s.startsWith("张"));System.out.println(result.count()); // 2}
}

取用前几个:limit

  • Stream<T> limit(long maxSize); 对流进行截取,只取用前maxSize个
import java.util.stream.Stream;
public class Demo10StreamLimit {public static void main(String[] args) {Stream<String> original = Stream.of("张三", "张三丰", "周姐");Stream<String> result = original.limit(2);System.out.println(result.count()); // 2}
}

跳过前几个:skip

  • Stream<T> skip(long n); skip 方法获取一个截取之后的新流
import java.util.stream.Stream;
public class Demo11StreamSkip {public static void main(String[] args) {Stream<String> original = Stream.of("张三", "张三丰", "周姐");Stream<String> result = original.skip(2);System.out.println(result.count()); // 1}
}

组合:concat

  • static <T> Stream<T> concat(Stream<? extends T> a, Stream<? extends T> b) 两个流合并成为一个流
import java.util.stream.Stream;
public class Demo12StreamConcat {public static void main(String[] args) {Stream<String> streamA = Stream.of("张三");Stream<String> streamB = Stream.of("李四");Stream<String> result = Stream.concat(streamA, streamB);}
}

方法引用

冗余的Lambda场景:

  1. 首先定义一个函数式接口
@FunctionalInterface
public interface Printable {void print(String str);
}
  1. 通过lambda表达式来使用该字符串
public class PrintSimple {private static void printString(Printable data) {data.print("Hello, World!");}public static void main(String[] args) {printString(s ‐> System.out.println(s));}
}

对字符串进行控制台打印输出的操作方案,明明已经有了现成的实现,那就是 System.out对象中的 println(String) 方法。因此我们不必自己动手调用该方法。使用方法引用即可。

public class Demo02PrintRef {private static void printString(Printable data) {data.print("Hello, World!");}public static void main(String[] args) {printString(System.out::println);}
}

方法引用符

双冒号 :: 为引用运算符,而它所在的表达式被称为方法引用。

  • Lambda表达式写法: s -> System.out.println(s); 语义:拿到参数之后经Lambda之手,继而传递给 System.out.println 方法去处理。
  • 方法引用写法: System.out::println 语义: 直接让 System.out 中的 println 方法来取代Lambda。

注意: Lambda 中 传递的参数 一定是方法引用中 的那个方法可以接收的类型,否则会抛出异常
函数式接口是Lambda的基础,而方法引用是Lambda的孪生兄弟。因此方法引用同时也是可推导可省略的;

通过对象名引用成员方法

  1. 首先定义一个函数式接口
@FunctionalInterface
public interface Printable {void print(String str);
}
  1. 创建一个实现了指定方法的类
public class MethodRefObject {public void printUpperCase(String str) {System.out.println(str.toUpperCase());}
}
  1. 测试
public class Demo04MethodRef {private static void printString(Printable lambda) {lambda.print("Hello");}public static void main(String[] args) {MethodRefObject obj = new MethodRefObject();printString(obj::printUpperCase);}
}

在这里插入图片描述
这里我们可以看到,我们通过方法引用了MethodRefObject中的printUpperCase(String str)方法,并没有通过lambda表达式来实现,而是使用一个已经实现了类中的方法,与我们引用System.out对象中的println()方法类似。

通过类名称引用静态方法

通过java.lang.Math 类中的静态方法 abs举例

  1. 声明一个函数式接口
@FunctionalInterface
public interface Calcable {int calc(int num);
}
  1. 使用lambda表达式来实现
public class Demo05Lambda {private static void method(int num, Calcable lambda) {System.out.println(lambda.calc(num));}public static void main(String[] args) {method(10, n ‐> Math.abs(n));}
}
  1. 使用方法引用的方式来实现
public class Demo06MethodRef {private static void method(int num, Calcable lambda) {System.out.println(lambda.calc(num));}public static void main(String[] args) {method(10, Math::abs);}
}

通过super引用成员方法

如果存在继承关系,当Lambda中需要出现super调用时,也可以使用方法引用进行替代。

  1. 定义函数式接口
@FunctionalInterface
public interface Greetable {void greet();
}
  1. 定义父类
public class Human {public void sayHello() {System.out.println("Hello!");}
}
  1. 定义子类(Lambda)
public class Man extends Human {@Overridepublic void sayHello() {System.out.println("大家好,我是Man!");}//定义方法method,参数传递Greetable接口public void method(Greetable g){g.greet();}public void show(){//调用method方法,使用Lambda表达式method(()->{//创建Human对象,调用sayHello方法new Human().sayHello();});//简化Lambdamethod(()->new Human().sayHello());//使用super关键字代替父类对象method(()->super.sayHello());}
}
  1. 定义子类(方法引用)
public class Man extends Human {@Overridepublic void sayHello() {System.out.println("大家好,我是Man!");}//定义方法method,参数传递Greetable接口public void method(Greetable g){g.greet();}public void show(){method(super::sayHello);}
}

通过this引用成员方法

这里与父类super类似,直接展示通过方法引用的写法

public class Husband {private void buyHouse() {System.out.println("买套房子");}private void marry(Richable lambda) {lambda.buy();}public void beHappy() {marry(this::buyHouse);}
}

类的构造器引用

  1. 定义一个Person类
public class Person {private String name;public Person(String name) {this.name = name;}public String getName() {return name;}public void setName(String name) {this.name = name;}
}
  1. 定义用来创建Person 对象的函数式接口
public interface PersonBuilder {Person buildPerson(String name);
}
  1. 使用Lambda表达式创建指定名称的Person对象
public class Demo09Lambda {public static void printName(String name, PersonBuilder builder) {System.out.println(builder.buildPerson(name).getName());}public static void main(String[] args) {printName("赵丽颖", name ‐> new Person(name));}
}
  1. 使用方法引用创建指定名称的Person对象
public class Demo10ConstructorRef {public static void printName(String name, PersonBuilder builder) {System.out.println(builder.buildPerson(name).getName());}public static void main(String[] args) {printName("赵丽颖", Person::new);}
}

数组的构造器引用

数组也是 Object 的子类对象,所以同样具有构造器

  1. 定义一个函数式接口
@FunctionalInterface
public interface ArrayBuilder {int[] buildArray(int length);
}
  1. 使用lambda表达式应用该接口
public class Demo11ArrayInitRef {private static int[] initArray(int length, ArrayBuilder builder) {return builder.buildArray(length);}public static void main(String[] args) {int[] array = initArray(10, length ‐> new int[length]);}
}
  1. 使用方法引用应用该接口
public class Demo12ArrayInitRef {private static int[] initArray(int length, ArrayBuilder builder) {return builder.buildArray(length);}public static void main(String[] args) {int[] array = initArray(10, int[]::new);}
}

欢迎java热爱者了解文章,作者将会持续更新中,期待各位友友的关注和收藏。。。

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

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

记一次若依框架和Springboot常见报错的实战漏洞挖掘

目录 前言 本次测实战利用图​ 1.判段系统框架 2.登录页面功能点测试 2.1 弱口令 2.2 webpack泄露信息判断 2.3 未授权接口信息发现 3.进一步测试发现新的若依测试点 3.1 默认弱口令 3.2 历史漏洞 4.访问8080端口发现spring经典爆粗 4.1 druid弱口令 4.2 SwaggerU…

HumanoidBench——模拟仿人机器人算法有未来

概述 论文地址&#xff1a;https://arxiv.org/pdf/2403.10506 仿人机器人具有类似人类的外形&#xff0c;有望在各种环境和任务中为人类提供支持。然而&#xff0c;昂贵且易碎的硬件是这项研究面临的挑战。因此&#xff0c;本研究开发了使用先进模拟技术的 HumanoidBench。该基…

【鸿蒙学习笔记】关系型数据库概述

目录标题 关系型数据库的运行机制样例代码共通方法 DBUtilsIndex 代码效果 关系型数据库的运行机制 1、 关系型数据库对应用提供通用的操作接口&#xff0c;底层使用SQLite作为持久化存储引擎&#xff0c;支持SQLite具有的数据库特性&#xff0c;包括但不限于事务、索引、视图…

代理IP池:解析与应用

代理IP大家都了解不少了&#xff0c;代理IP池又是什么呢&#xff1f;下面简单介绍一下吧&#xff01; 1. 概述 代理IP池就是由多个代理IP地址组成的集合&#xff0c;用于实现更高效的网络访问和数据获取。这些IP地址通常来自不同的地理位置和网络提供商&#xff0c;经过动态管…

谷粒商城实战笔记-24-分布式组件-SpringCloud Alibaba-Nacos配置中心-命名空间与配置分组

文章目录 一&#xff0c;命名空间1&#xff0c;简介1.1&#xff0c;命名空间的主要功能和特点1.2&#xff0c;使用场景1.3&#xff0c;如何指定命名空间 2&#xff0c;命名空间实战2.1&#xff0c;环境隔离2.2&#xff0c;服务隔离 二&#xff0c;配置集三&#xff0c;配置集ID…

LabVIEW的Actor Framework (AF) 结构介绍

LabVIEW的Actor Framework (AF) 是一种高级架构&#xff0c;用于开发并发、可扩展和模块化的应用程序。通过面向对象编程&#xff08;OOP&#xff09;和消息传递机制&#xff0c;AF结构实现了高效的任务管理和数据处理。其主要特点包括并发执行、动态可扩展性和强大的错误处理能…

Day1每日编程题日记:数字统计、两个数组的交集、点击消除

前言&#xff1a;该篇用于记录自看。曾回看昨天的做题代码&#xff0c;竟然会觉得陌生&#xff0c;这竟然是我写的&#xff0c;细细读了一下&#xff0c;原来我当时是这么想的。因此我觉得记代码没有实际用处&#xff0c;重点是领悟了思想&#xff0c;这样子代码就在心中&#…

发布:PhonePrompter_PC(手机录视频提词器_电脑版)

PhonePrompter_PC(手机录视频提词器_电脑版) 目 录 1. 概述... 2 2. 应用手册... 3 下载地址&#xff1a;百度网盘 请输入提取码 提取码&#xff1a;8wsa 1. 概述 平时工作和生活中需要用手机竖屏或横屏模式录制造工作、科技、历史、生活等方面的一些视…

web后端开发--请求响应

目录 前言 请求 简单参数 原始方法 Spring方式 Post请求乱码处理 实体参数 简单实体参数 复杂实体参数 ​编辑 数组集合参数 数组参数 ​编辑 集合参数 日期参数 ​编辑 Json参数 ​编辑 传递json数据 json数组 json对象&#xff08;POJO&#xff09; jso…

【Flask从入门到精通:第一课:flask的基本介绍、flask快速搭建项目并运行】

从0开始入手到上手一个新的框架&#xff0c;应该怎么展开&#xff1f;flask这种轻量级的框架与django这种的重量级框架的区别&#xff1f;针对web开发过程中&#xff0c;常见的数据库ORM的操作。跟着学习flask的过程中&#xff0c;自己去学习和了解一个新的框架&#xff08;San…

CSS【详解】长度单位 ( px,%,em,rem,vw,vh,vmin,vmax,ex,ch )

px 像素 pixel 的缩写&#xff0c;即电子屏幕上的1个点&#xff0c;以分辨率为 1024 * 768 的屏幕为例&#xff0c;即水平方向上有 1024 个点&#xff0c;垂直方向上有 768 个点&#xff0c;则 width:1024px 即表示元素的宽度撑满整个屏幕。 随屏幕分辨率不同&#xff0c;1px …

小程序问题

1.获取节点 wx.createSelectorQuery() wx.createSelectorQuery().in(this) //组件中加in(this)&#xff0c;不然获取不到 2.使用实例 wx.createSelectorQuery().in(this).select(#share).fields({node: true,size: true}).exec(async (res) > {const canvas res[0].node;…

如何将Docker镜像源更改为阿里云的镜像加速地址

在使用Docker时&#xff0c;尤其是在国内环境下&#xff0c;由于网络原因&#xff0c;从Docker Hub拉取镜像可能会遇到速度较慢的问题。为了提高拉取速度&#xff0c;我们可以将Docker的镜像源更改为阿里云等国内镜像源。下面详细介绍如何获取并配置阿里云的Docker镜像加速地址…

C++三大特征:多态

1.virtual关键字 1.1何为虚函数 virtual用于在base类中声明一个虚函数&#xff0c;[虚函数]的主要作用是[允许]在派生类&#xff08;也称为子类)中对该函数进行[重写](override) 1.2何为重写 重写就是在drived类中写一个函数(返回类型,名称,参数列表)与base类相同的函数,dr…

C++基础(二)

目录 1.类和对象 1.1类的定义 1.2访问限定符 1.3类域 2.实例化 2.1实例化概念 2.2对象大小 3.this指针 4.类的默认成员函数 4.1构造函数 4.2析构函数 4.5运算符重载 1.类和对象 1.1类的定义 类的定义格式 class为定义类的关键字&#xff0c;Stack为类的名字&…

从零开始实现大语言模型(四):简单自注意力机制

1. 前言 理解大语言模型结构的关键在于理解自注意力机制(self-attention)。自注意力机制可以判断输入文本序列中各个token与序列中所有token之间的相关性&#xff0c;并生成包含这种相关性信息的context向量。 本文介绍一种不包含训练参数的简化版自注意力机制——简单自注意…

uni-app/vue项目如何封装全局消息提示组件

效果图&#xff1a; 第一步&#xff1a;封装组件和方法&#xff0c;采用插件式注册&#xff01; 在项目目录下新建components文件夹&#xff0c;里面放两个文件&#xff0c;分别是index.vue和index.js. index.vue&#xff1a; <template><div class"toast&quo…

【Linux杂货铺】2.进程优先级

1.进程优先级基本概念 进程优先级是操作系统中用于确定进程调度顺序的一个指标。每个进程都会被分配一个优先级&#xff0c;优先级较高的进程会在调度时优先被执行。进程优先级的设定通常根据进程的重要性、紧急程度、资源需求等因素来确定。操作系统会根据进程的优先级来决定进…

nuPlan 是一个针对自动驾驶车辆的闭环机器学习(ML-based)规划基准测试

nuPlan: A closed-loop ML-based planning benchmark for autonomous vehicles nuPlan 是一个针对自动驾驶车辆的闭环机器学习&#xff08;ML-based&#xff09;规划基准测试 Abstract In this work, we propose the world’s first closed-loop ML-based planning benchmar…

【JavaScript】解决 JavaScript 语言报错:Uncaught ReferenceError: XYZ is not defined

文章目录 一、背景介绍常见场景 二、报错信息解析三、常见原因分析1. 变量未声明2. 拼写错误3. 块级作用域4. 使用未定义的函数或对象5. 代码执行顺序 四、解决方案与预防措施1. 确保变量已声明2. 检查拼写错误3. 注意块级作用域4. 定义和调用函数5. 正确的代码执行顺序 五、示…