十八:Java8的其它新特性
————————————————
声明:本文是在CSDN
博主「lsqstudy」
的原创文章基础上修改的,遵循 CC 4.0 BY-SA 版权协议
原文链接:https://blog.csdn.net/PorkBird/article/details/113666542
00、Java8 概述
1.Java8 新特性简介
- Java 8 (又称为 jdk 1.8) 是 Java 语言开发的一个主要版本。
- Java 8 是 oracle 公司于 2014 年 3 月发布,可以看成是自 Java 5 以来最具革命性的版本。Java 8 为 Java 语言、编译器、类库、开发工具与 JVM 带来了大量新特性。
2.Java8 新特性的好处
- 速度更快
- 代码更少 (增加了新的语法:Lambda 表达式)
- 强大的 Stream API
- 便于并行
- 最大化减少空指针异常:Optional
- Nashorn 引擎,允许在 JVM 上运行 JS 应用
3. 并行流与串行流
并行流就是把一个内容分成多个数据块,并用不同的线程分别处理每个数据块的流。相比较串行的流,并行的流可以很大程度上提高程序的执行效率。
Java 8 中将并行进行了优化,我们可以很容易的对数据进行并行操作。Stream API 可以声明性地通过 parallel()与 sequential() 在并行流与顺序流之间进行切换
4. 本章目录
01、Lambda 表达式
1.Lambda 是一个匿名函数,我们可以把 Lambda 表达式理解为是一段可以传递的代码(将代码像数据一样进行传递)。使用它可以写出更简洁、更灵活的代码。作为一种更紧凑的代码风格,使 Java 的语言表达能力得到了提升。
2. 总结
- (1) 何时使用 lambda 表达式?
- 当需要对一个函数式接口实例化的时候,可以使用 lambda 表达式
- (2) 何时使用给定的函数式接口?
- 如果我们开发中需要定义一个函数式接口,首先看看在已有的 jdk 提供的函数式接口是否提供了能满足需求的函数式接口。如果有,则直接调用即可,不需要自己再定义了
1.1、Lambda 表达式使用举例
import org.junit.Test;
import java.util.Comparator;
/**
Lambda 表达式的使用举例
*/
public class LambdaTest {
//1. 例一:
public void test(){<span class="hljs-comment">//1.提供一个实现Runnable接口的匿名实现类的非匿名对象</span> <span class="hljs-type">Runnable</span> <span class="hljs-variable">r1</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Runnable</span>() { <span class="hljs-meta">@Override</span> <span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">run</span><span class="hljs-params">()</span> { System.out.println(<span class="hljs-string">"北京欢迎您"</span>); } }; r1.run(); System.out.println(<span class="hljs-string">"*****************************"</span>); <span class="hljs-comment">//2.Lambda表达式的写法</span> <span class="hljs-type">Runnable</span> <span class="hljs-variable">r2</span> <span class="hljs-operator">=</span> () -> System.out.println(<span class="hljs-string">"长安欢迎您"</span>); r2.run();
}
//2. 例二:
public void test2(){
//1. 提供 Comparator 接口匿名实现类的对象
Comparator<Integer> c1 = new Comparator<Integer>() {
public int compare(Integer o1, Integer o2) {
return Integer.compare(o1,o2);
}
};
int compare1 = c1.compare(8,16);//o1 小于 o2, 返回负整数
System.out.println(compare1);//-1System.out.println(<span class="hljs-string">"*****************************"</span>); <span class="hljs-comment">//2.Lambda表达式的写法</span> Comparator<Integer> c2 = (o1,o2) -> Integer.compare(o1,o2); <span class="hljs-type">int</span> <span class="hljs-variable">compare2</span> <span class="hljs-operator">=</span> c2.compare(<span class="hljs-number">28</span>,<span class="hljs-number">15</span>); System.out.println(compare2);<span class="hljs-comment">//1</span> System.out.println(<span class="hljs-string">"*****************************"</span>); <span class="hljs-comment">//3.方法引用</span> Comparator<Integer> c3 = Integer :: compare; <span class="hljs-type">int</span> <span class="hljs-variable">compare3</span> <span class="hljs-operator">=</span> c3.compare(<span class="hljs-number">28</span>,<span class="hljs-number">15</span>); System.out.println(compare3);<span class="hljs-comment">//1</span>
}
}
1.2、Lambda 表达式语法的使用 1
import org.junit.Test;
import java.util.ArrayList;
import java.util.function.Consumer;
/**
* Lambda 表达式的使用
*
* 1. 举例: (o1,o2) -> Integer.compare(o1,o2);
* 2. 格式:
* -> :lambda 操作符 或 箭头操作符
* ->左边:lambda 形参列表 (其实就是接口中的抽象方法的形参列表)
* ->右边:lambda 体 (其实就是重写的抽象方法的方法体)
*
* 3.Lambda 表达式的使用:(分为 6 种情况介绍)
* 总结:
* ->左边:lambda 形参列表的参数类型可以省略 (类型推断); 如果 lambda 形参列表只有一个参数,其一对() 也可以省略
* ->右边:lambda 体应该使用一对 {} 包裹;如果 lambda 体只有一条执行语句(可能是 return 语句),省略这一对{}
* 和 return 关键字
*
* 4.Lambda 表达式的本质:作为函数式接口的实例
*/
public class LambdaTest1 {
// 语法格式一:无参,无返回值
@Test
public void test(){
Runnable r1 = new Runnable() {
@Override
public void run() {
System.out.println("长安欢迎您");
}
};
r1.run();
System.out.println("+++++++++++++++++++++++++|");
Runnable r2 = () -> {
System.out.println("长安欢迎您");
};
r2.run();
}
// 语法格式二:Lambda 需要一个参数,但是没有返回值。
@Test
public void test2(){
Consumer<String> con = new Consumer<String>() {
@Override
public void accept(String s) {
System.out.println(s);
}
};
con.accept("善与恶的区别是什么?");
System.out.println("**************************");
Consumer<String> c1 = (String s) -> {
System.out.println(s);
};
c1.accept("先天人性无善恶, 后天人性有善恶。");
}
// 语法格式三:数据类型可以省略,因为可由编译器推断得出,称为“类型推断”
@Test
public void test3(){
Consumer<String> c1 = (String s) -> {
System.out.println(s);
};
c1.accept("先天人性无善恶, 后天人性有善恶。");
System.out.println("---------------------");
Consumer<String> c2 = (s) -> {
System.out.println(s);
};
c2.accept("如果没有邪恶的话我们怎么会知道人世间的那些善良呢?");
}
// 类型推断的其它例子:
@Test
public void test4(){
ArrayList<String> list = new ArrayList<>();// 类型推断
int[] arr = {1,2,3};// 类型推断
}
}
1.3、Lambda 表达式语法的使用 2
import org.junit.Test;
import java.util.Comparator;
import java.util.function.Consumer;
public class LambdaTest1 {
// 语法格式四:Lambda 若只需要一个参数时,参数的小括号可以省略
@Test
public void test5(){
Consumer<String> c1 = (s) -> {
System.out.println(s);
};
c1.accept("先天人性无善恶, 后天人性有善恶。");
System.out.println("---------------------");
Consumer<String> c2 = s -> {
System.out.println(s);
};
c2.accept("如果没有邪恶的话我们怎么会知道人世间的那些善良呢?");
}
// 语法格式五:Lambda 需要两个或以上的参数,多条执行语句,并且可以有返回值
@Test
public void test6(){
Comparator<Integer> c1 = new Comparator<Integer>() {
@Override
public int compare(Integer o1, Integer o2) {
System.out.println(o1);
System.out.println(o2);
return o1.compareTo(o2);
}
};
System.out.println(c1.compare(15,23));//-1
System.out.println("**************************");
Comparator<Integer> com2 = (o1,o2) -> {
System.out.println(o1);
System.out.println(o2);
return o1.compareTo(o2);
};
System.out.println(com2.compare(16,8));//1
}
// 语法格式六:当 Lambda 体只有一条语句时,return 与大括号若有,都可以省略
@Test
public void test7(){
Comparator<Integer> c1 = (o1,o2) -> {
return o1.compareTo(o2);
};
System.out.println(c1.compare(16,8));//1
System.out.println("**************************");
Comparator<Integer> c2 = (o1,o2) -> o1.compareTo(o2);
System.out.println(c2.compare(17,24));//-1
}
}
02、函数式 (Functional) 接口
2.1、函数式接口的介绍
/*
* 4.Lambda 表达式的本质:作为函数式接口的实例
*
* 5. 如果一个接口中,只声明了一个抽象方法,则此接口就称为函数式接口。我们可以在一个接口上使用
* @FunctionalInterface 注解,这样做可以检查它是否是一个函数式接口。
*
* 6. 所以以前用匿名实现类表示的现在都可以用 Lambda 表达式来写。
*
*/
/**
-
自定义函数式接口
*/
@FunctionalInterface// 这个注解加不加都是函数式接口,加上后可以检查它是否是一个函数式接口
public interface MyInterFace {
void method();
}
1. 如何理解函数式接口
- 在 java.util.function 包下定义了 Java 8 的丰富的函数式接口
- Java 从诞生日起就是一直倡导“一切皆对象”,在 Java 里面面向对象 (OOP) 编程是一切。但是随着 python、scala 等语言的兴起和新技术的挑战,Java 不得不做出调整以便支持更加广泛的技术要求,也即 java 不但可以支持 OOP 还可以支持 OOF(面向函数编程)
- 在函数式编程语言当中,函数被当做一等公民对待。在将函数作为一等公民的编程语言中,Lambda 表达式的类型是函数。但是在 Java8 中,有所不同。在 Java8 中,Lambda 表达式是对象,而不是函数,它们必须依附于一类特别的对象类型——函数式接口。
- 简单的说,在 Java8 中,Lambda 表达式就是一个函数式接口的实例。这就是 Lambda 表达式和函数式接口的关系。也就是说,只要一个对象是函数式接口的实例,那么该对象就可以用 Lambda 表达式来表示。
- 所以以前用匿名实现类表示的现在都可以用 Lambda 表达式来写。
2.2、Java 内置的函数式接口介绍及使用举例
下面这些接口实例化的时候可以使用 Lambda 表达式。
import org.junit.Test;
import java.util.*;
import java.util.function.Consumer;
import java.util.function.Predicate;
/**
-
java 内置的 4 大核心函数式接口
-
消费型接口 Consumer<T> void accept(T t)
-
供给型接口 Supplier<T> T get()
-
函数型接口 Function<T,R> R apply(T t)
断定型接口 Predicate<T> boolean test(T t)
*/
public class LambdaTest2 {//1. 例 1:
public void happyTime(double money, Consumer<Double> con) {
con.accept(money);
}
public void test(){
happyTime(30, new Consumer<Double>() {
public void accept(Double aDouble) {
System.out.println("熬夜太累了,点个外卖,价格为:" + aDouble);
}
});
System.out.println("********************");<span class="hljs-comment">//Lambda表达式写法</span> happyTime(<span class="hljs-number">20</span>, money -> System.out.println(<span class="hljs-string">"熬夜太累了,吃口麻辣烫,价格为:"</span> + money));
}
//2. 例 2:
// 根据给定的规则,过滤集合中的字符串。此 规则由 Predicate 的方法决定
public List<String> filterString(List<String> list, Predicate<String> pre){ArrayList<String> filterList = <span class="hljs-keyword">new</span> <span class="hljs-title class_">ArrayList</span><>(); <span class="hljs-keyword">for</span>(String s : list){ <span class="hljs-keyword">if</span>(pre.test(s)){ filterList.add(s); } } <span class="hljs-keyword">return</span> filterList;
}
public void test2(){
List<String> list = Arrays.asList("长安","上京","江南","渝州","凉州","兖州");List<String> filterStrs = filterString(list, <span class="hljs-keyword">new</span> <span class="hljs-title class_">Predicate</span><String>() { <span class="hljs-meta">@Override</span> <span class="hljs-keyword">public</span> <span class="hljs-type">boolean</span> <span class="hljs-title function_">test</span><span class="hljs-params">(String s)</span> { <span class="hljs-keyword">return</span> s.contains(<span class="hljs-string">"州"</span>); } }); System.out.println(filterStrs);<span class="hljs-comment">//[渝州, 凉州, 兖州]</span> System.out.println(<span class="hljs-string">"********************"</span>); List<String> filterStrs1 = filterString(list,s -> s.contains(<span class="hljs-string">"州"</span>)); System.out.println(filterStrs1);<span class="hljs-comment">//[渝州, 凉州, 兖州]</span>
}
}
03、方法引用与构造器引用
1. 方法引用(Method References)
- 当要传递给 Lambda 体的操作,已经有实现的方法了,可以使用方法引用!
- 方法引用可以看做是 Lambda 表达式深层次的表达。换句话说,方法引用就是 Lambda 表达式,也就是函数式接口的一个实例,通过方法的名字来指向一个方法,可以认为是 Lambda 表达式的一个语法糖。
- 如下三种主要使用情况:
- 对象:: 实例方法名
- 类:: 静态方法名
- 类:: 实例方法名
2. 要求(重要)
- 要求接口中的抽象方法的参数列表和返回值类型,与方法引用的方法的参数列表和返回值类型相同!(针对于情况 1 和情况 2)
- 当函数式接口方法的第一个参数是需要引用方法的调用者,并且第二个参数是需要引用方法的参数(或无参数)时:ClassName::methodName(针对于情况 3)
3.1、方法引用的使用情况
1、Employee 类
public class Employee {
<span class="hljs-keyword">private</span> <span class="hljs-type">int</span> id;
<span class="hljs-keyword">private</span> String name;
<span class="hljs-keyword">private</span> <span class="hljs-type">int</span> age;
<span class="hljs-keyword">private</span> <span class="hljs-type">double</span> salary;
<span class="hljs-keyword">public</span> <span class="hljs-type">int</span> <span class="hljs-title function_">getId</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> id;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setId</span><span class="hljs-params">(<span class="hljs-type">int</span> id)</span> {
<span class="hljs-built_in">this</span>.id = id;
}
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">getName</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> name;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setName</span><span class="hljs-params">(String name)</span> {
<span class="hljs-built_in">this</span>.name = name;
}
<span class="hljs-keyword">public</span> <span class="hljs-type">int</span> <span class="hljs-title function_">getAge</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> age;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setAge</span><span class="hljs-params">(<span class="hljs-type">int</span> age)</span> {
<span class="hljs-built_in">this</span>.age = age;
}
<span class="hljs-keyword">public</span> <span class="hljs-type">double</span> <span class="hljs-title function_">getSalary</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> salary;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setSalary</span><span class="hljs-params">(<span class="hljs-type">double</span> salary)</span> {
<span class="hljs-built_in">this</span>.salary = salary;
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">()</span> {
System.out.println(<span class="hljs-string">"Employee()....."</span>);
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">(<span class="hljs-type">int</span> id)</span> {
<span class="hljs-built_in">this</span>.id = id;
System.out.println(<span class="hljs-string">"Employee(int id)....."</span>);
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">(<span class="hljs-type">int</span> id, String name)</span> {
<span class="hljs-built_in">this</span>.id = id;
<span class="hljs-built_in">this</span>.name = name;
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">(<span class="hljs-type">int</span> id, String name, <span class="hljs-type">int</span> age, <span class="hljs-type">double</span> salary)</span> {
<span class="hljs-built_in">this</span>.id = id;
<span class="hljs-built_in">this</span>.name = name;
<span class="hljs-built_in">this</span>.age = age;
<span class="hljs-built_in">this</span>.salary = salary;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">toString</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> <span class="hljs-string">"Employee{"</span> + <span class="hljs-string">"id="</span> + id + <span class="hljs-string">", name='"</span> + name + <span class="hljs-string">'\''</span> + <span class="hljs-string">", age="</span> + age + <span class="hljs-string">", salary="</span> + salary + <span class="hljs-string">'}'</span>;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> <span class="hljs-type">boolean</span> <span class="hljs-title function_">equals</span><span class="hljs-params">(Object o)</span> {
<span class="hljs-keyword">if</span> (<span class="hljs-built_in">this</span> == o)
<span class="hljs-keyword">return</span> <span class="hljs-literal">true</span>;
<span class="hljs-keyword">if</span> (o == <span class="hljs-literal">null</span> || getClass() != o.getClass())
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-type">Employee</span> <span class="hljs-variable">employee</span> <span class="hljs-operator">=</span> (Employee) o;
<span class="hljs-keyword">if</span> (id != employee.id)
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-keyword">if</span> (age != employee.age)
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-keyword">if</span> (Double.compare(employee.salary, salary) != <span class="hljs-number">0</span>)
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-keyword">return</span> name != <span class="hljs-literal">null</span> ? name.equals(employee.name) : employee.name == <span class="hljs-literal">null</span>;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> <span class="hljs-type">int</span> <span class="hljs-title function_">hashCode</span><span class="hljs-params">()</span> {
<span class="hljs-type">int</span> result;
<span class="hljs-type">long</span> temp;
result = id;
result = <span class="hljs-number">31</span> * result + (name != <span class="hljs-literal">null</span> ? name.hashCode() : <span class="hljs-number">0</span>);
result = <span class="hljs-number">31</span> * result + age;
temp = Double.doubleToLongBits(salary);
result = <span class="hljs-number">31</span> * result + (<span class="hljs-type">int</span>) (temp ^ (temp >>> <span class="hljs-number">32</span>));
<span class="hljs-keyword">return</span> result;
}
}
2、测试类
import org.junit.Test;
import java.io.PrintStream;
import java.util.Comparator;
import java.util.function.*;
/**
* 方法引用的使用
*
* 1. 使用情境:当要传递给 Lambda 体的操作,已经有实现的方法了,可以使用方法引用!
*
* 2. 方法引用,本质上就是 Lambda 表达式,而 Lambda 表达式作为函数式接口的实例。所以
* 方法引用,也是函数式接口的实例。
*
* 3. 使用格式: 类 (或对象) :: 方法名
*
* 4. 具体分为如下的三种情况:
* 情况 1 对象 :: 非静态方法(实例方法)
* 情况 2 类 :: 静态方法
*
* 情况 3 类 :: 非静态方法
*
* 5. 方法引用使用的要求:要求接口中的抽象方法的形参列表和返回值类型与 方法引用的方法的
* 形参列表和返回值类型相同!(针对于情况 1 和情况 2)
*/
public class MethodRefTest {
<span class="hljs-comment">//*********************************情况一************************************</span>
<span class="hljs-comment">// 情况一:对象 :: 实例方法</span>
<span class="hljs-comment">//例1:Consumer中的void accept(T t)</span>
<span class="hljs-comment">// PrintStream中的void println(T t)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test</span><span class="hljs-params">()</span> {
<span class="hljs-comment">//Lambda表达式</span>
Consumer<String> c1 = str -> System.out.println(str);
c1.accept(<span class="hljs-string">"北京"</span>);
System.out.println(<span class="hljs-string">"*********************"</span>);
<span class="hljs-comment">//方法引用</span>
<span class="hljs-type">PrintStream</span> <span class="hljs-variable">ps</span> <span class="hljs-operator">=</span> System.out;
Consumer<String> c2 = ps::println;
c2.accept(<span class="hljs-string">"beijing"</span>);
}
<span class="hljs-comment">//例2(没看懂):Supplier中的T get()</span>
<span class="hljs-comment">// Employee中的String getName()</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test2</span><span class="hljs-params">()</span> {
<span class="hljs-type">Employee</span> <span class="hljs-variable">emp</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1001</span>,<span class="hljs-string">"Tom"</span>,<span class="hljs-number">19</span>,<span class="hljs-number">4200</span>);
<span class="hljs-comment">//Lambda表达式</span>
Supplier<String> sup1 = () -> emp.getName();
System.out.println(sup1.get());
System.out.println(<span class="hljs-string">"*******************"</span>);
<span class="hljs-comment">//方法引用</span>
Supplier<String> sup2 = emp::getName;
System.out.println(sup2.get());
}
<span class="hljs-comment">//*********************************情况二************************************</span>
<span class="hljs-comment">// 情况二:类 :: 静态方法</span>
<span class="hljs-comment">//例1:Comparator中的int compare(T t1,T t2)</span>
<span class="hljs-comment">// Integer中的int compare(T t1,T t2)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test3</span><span class="hljs-params">()</span> {
<span class="hljs-comment">//Lambda表达式</span>
Comparator<Integer> com1 = (t1, t2) -> Integer.compare(t1,t2);
System.out.println(com1.compare(<span class="hljs-number">11</span>,<span class="hljs-number">20</span>));<span class="hljs-comment">//-1</span>
System.out.println(<span class="hljs-string">"*********************"</span>);
<span class="hljs-comment">//方法引用</span>
Comparator<Integer> com2 = Integer::compare;
System.out.println(com2.compare(<span class="hljs-number">15</span>,<span class="hljs-number">7</span>));<span class="hljs-comment">//1</span>
}
<span class="hljs-comment">//例2:Function中的R apply(T t)</span>
<span class="hljs-comment">// Math中的Long round(Double d)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test4</span><span class="hljs-params">()</span> {
Function<Double,Long> func = <span class="hljs-keyword">new</span> <span class="hljs-title class_">Function</span><Double, Long>() {
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> Long <span class="hljs-title function_">apply</span><span class="hljs-params">(Double d)</span> {
<span class="hljs-keyword">return</span> Math.round(d);<span class="hljs-comment">//四舍五入</span>
}
};
System.out.println(<span class="hljs-string">"******************"</span>);
Function<Double,Long> func1 = d -> Math.round(d);
System.out.println(func1.apply(<span class="hljs-number">14.1</span>));<span class="hljs-comment">//14</span>
System.out.println(<span class="hljs-string">"******************"</span>);
Function<Double,Long> func2 = Math::round;
System.out.println(func2.apply(<span class="hljs-number">17.7</span>));<span class="hljs-comment">//18</span>
}
<span class="hljs-comment">//*********************************情况三************************************</span>
<span class="hljs-comment">// 情况三:类 :: 实例方法 (有难度)</span>
<span class="hljs-comment">// 例1:Comparator中的int comapre(T t1,T t2)</span>
<span class="hljs-comment">// String中的int t1.compareTo(t2)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test5</span><span class="hljs-params">()</span> {
Comparator<String> com1 = (s1,s2) -> s1.compareTo(s2);
System.out.println(com1.compare(<span class="hljs-string">"abc"</span>,<span class="hljs-string">"abd"</span>));<span class="hljs-comment">//-1</span>
System.out.println(<span class="hljs-string">"******************"</span>);
Comparator<String> com2 = String :: compareTo;
System.out.println(com2.compare(<span class="hljs-string">"abd"</span>,<span class="hljs-string">"abm"</span>));<span class="hljs-comment">//-9</span>
}
<span class="hljs-comment">//例2:BiPredicate中的boolean test(T t1, T t2);</span>
<span class="hljs-comment">// String中的boolean t1.equals(t2)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test6</span><span class="hljs-params">()</span> {
BiPredicate<String,String> pre1 = (s1, s2) -> s1.equals(s2);
System.out.println(pre1.test(<span class="hljs-string">"abc"</span>,<span class="hljs-string">"abc"</span>));<span class="hljs-comment">//true</span>
System.out.println(<span class="hljs-string">"******************"</span>);
BiPredicate<String,String> pre2 = String :: equals;
System.out.println(pre2.test(<span class="hljs-string">"abc"</span>,<span class="hljs-string">"abd"</span>));<span class="hljs-comment">//false</span>
}
<span class="hljs-comment">// 例3(不懂):Function中的R apply(T t)</span>
<span class="hljs-comment">// Employee中的String getName();</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test7</span><span class="hljs-params">()</span> {
<span class="hljs-type">Employee</span> <span class="hljs-variable">employee</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">007</span>, <span class="hljs-string">"Tom"</span>, <span class="hljs-number">21</span>, <span class="hljs-number">8000</span>);
Function<Employee,String> func1 = e -> e.getName();
System.out.println(func1.apply(employee));<span class="hljs-comment">//Tom</span>
System.out.println(<span class="hljs-string">"******************"</span>);
Function<Employee,String> f2 = Employee::getName;
System.out.println(f2.apply(employee));<span class="hljs-comment">//Tom</span>
}
}
3.2、构造器引用与数组引用的使用
格式:ClassName::new
与函数式接口相结合,自动与函数式接口中方法兼容。
可以把构造器引用赋值给定义的方法,要求构造器参数列表要与接口中抽象方法的参数列表一致!且方法的返回值即为构造器对应类的对象。
1、Employee 类——同上
2、测试类
import org.junit.Test;
import java.util.Arrays;
import java.util.function.*;
/**
- 一、构造器引用
-
和方法引用类似,函数式接口的抽象方法的形参列表 和构造器的形参列表一致。
-
抽象方法的返回值类型即为构造器所属的类的类型
- 二、数组引用
-
可以把数组看做是一个特殊的类,则写法与构造器引用一致。
*/
public class ConstructorRefTest {
<span class="hljs-comment">//构造器引用</span>
<span class="hljs-comment">//例1:Supplier中的T get()</span>
<span class="hljs-comment">// Employee的空参构造器:Employee()</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test</span><span class="hljs-params">()</span> {
Supplier<Employee> sup1 = <span class="hljs-keyword">new</span> <span class="hljs-title class_">Supplier</span><Employee>() {
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> Employee <span class="hljs-title function_">get</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>();
}
};
System.out.println(<span class="hljs-string">"********************"</span>);
Supplier<Employee> sup2 = () -> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>();
System.out.println(sup2.get());
System.out.println(<span class="hljs-string">"********************"</span>);
Supplier<Employee> sup3 = Employee::<span class="hljs-keyword">new</span>;
System.out.println(sup3.get());
}
<span class="hljs-comment">//例2:Function中的R apply(T t)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test2</span><span class="hljs-params">()</span> {
Function<Integer, Employee> f1 = id -> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(id);
<span class="hljs-type">Employee</span> <span class="hljs-variable">employee</span> <span class="hljs-operator">=</span> f1.apply(<span class="hljs-number">1001</span>);
System.out.println(employee);
System.out.println(<span class="hljs-string">"********************"</span>);
Function<Integer, Employee> f2 = Employee::<span class="hljs-keyword">new</span>;
<span class="hljs-type">Employee</span> <span class="hljs-variable">employee1</span> <span class="hljs-operator">=</span> f2.apply(<span class="hljs-number">1002</span>);
System.out.println(employee1);
}
<span class="hljs-comment">//例3:BiFunction中的R apply(T t,U u)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test3</span><span class="hljs-params">()</span> {
BiFunction<Integer, String, Employee> f1 = (id, name) -> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(id, name);
System.out.println(f1.apply(<span class="hljs-number">1001</span>, <span class="hljs-string">"Fruk"</span>));
System.out.println(<span class="hljs-string">"*******************"</span>);
BiFunction<Integer, String, Employee> f2 = Employee::<span class="hljs-keyword">new</span>;
System.out.println(f2.apply(<span class="hljs-number">1002</span>, <span class="hljs-string">"Bon"</span>));
}
<span class="hljs-comment">//数组引用</span>
<span class="hljs-comment">//例1:Function中的R apply(T t)</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test4</span><span class="hljs-params">()</span> {
Function<Integer, String[]> f1 = length -> <span class="hljs-keyword">new</span> <span class="hljs-title class_">String</span>[length];
String[] arr1 = f1.apply(<span class="hljs-number">5</span>);
System.out.println(Arrays.toString(arr1));
System.out.println(<span class="hljs-string">"*******************"</span>);
Function<Integer, String[]> f2 = String[]::<span class="hljs-keyword">new</span>;
String[] arr2 = f2.apply(<span class="hljs-number">7</span>);
System.out.println(Arrays.toString(arr2));
}
}
04、强大的 Stream API
4.1、Stream API 的概述
Java8 中有两大最为重要的改变。第一个是 Lambda 表达式;另外一个则是 Stream API。
1.Stream API 说明
-
Stream 关注的是对数据的运算,与 CPU 打交道。集合关注的是数据的存储,与内存打交道
-
java8 提供了一套 api, 使用这套 api 可以对内存中的数据进行过滤、排序、映射、归约等操作。类似于 sql 对数据库中表的相关操作。
2. 为什么要使用 Stream API
- 实际开发中,项目中多数数据源都来自于 Mysql,Oracle 等。但现在数据源可以更多了,有 MongDB,Radis 等,而这些 NoSQL 的数据就需要 Java 层面去处理。
3. 什么是 Stream?
1)是数据渠道,用于操作数据源(集合、数组等)所生成的元素序列。
2)注意:
- ①Stream 自己不会存储元素。
- ②Stream 不会改变源对象。相反,他们会返回一个持有结果的新 Stream。
- ③Stream 操作是延迟执行的。这意味着他们会等到需要结果的时候才执行
4.Stream 执行流程
- ① Stream 的实例化
- ② 一系列的中间操作(过滤、映射、...)
- ③ 终止操作(终端操作)
5. 说明:
- 一个中间操作链,对数据源的数据进行处理
- 一旦执行终止操作,就执行中间操作链,并产生结果。之后,不会再被使用
4.2、Stream 的实例化
1、EmployeeData 类
import java.util.ArrayList;
import java.util.List;
/**
* 提供用于测试的数据
*/
public class EmployeeData {
<span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> List<Employee> <span class="hljs-title function_">getEmployees</span><span class="hljs-params">()</span>{
List<Employee> list = <span class="hljs-keyword">new</span> <span class="hljs-title class_">ArrayList</span><>();
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1001</span>, <span class="hljs-string">"马化腾"</span>, <span class="hljs-number">34</span>, <span class="hljs-number">6000.38</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1002</span>, <span class="hljs-string">"马云"</span>, <span class="hljs-number">12</span>, <span class="hljs-number">9876.12</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1003</span>, <span class="hljs-string">"刘强东"</span>, <span class="hljs-number">33</span>, <span class="hljs-number">3000.82</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1004</span>, <span class="hljs-string">"雷军"</span>, <span class="hljs-number">26</span>, <span class="hljs-number">7657.37</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1005</span>, <span class="hljs-string">"李彦宏"</span>, <span class="hljs-number">65</span>, <span class="hljs-number">5555.32</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1006</span>, <span class="hljs-string">"比尔盖茨"</span>, <span class="hljs-number">42</span>, <span class="hljs-number">9500.43</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1007</span>, <span class="hljs-string">"任正非"</span>, <span class="hljs-number">26</span>, <span class="hljs-number">4333.32</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1008</span>, <span class="hljs-string">"扎克伯格"</span>, <span class="hljs-number">35</span>, <span class="hljs-number">2500.32</span>));
<span class="hljs-keyword">return</span> list;
}
}
2、Employee 类
public class Employee {
<span class="hljs-keyword">private</span> <span class="hljs-type">int</span> id;
<span class="hljs-keyword">private</span> String name;
<span class="hljs-keyword">private</span> <span class="hljs-type">int</span> age;
<span class="hljs-keyword">private</span> <span class="hljs-type">double</span> salary;
<span class="hljs-keyword">public</span> <span class="hljs-type">int</span> <span class="hljs-title function_">getId</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> id;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setId</span><span class="hljs-params">(<span class="hljs-type">int</span> id)</span> {
<span class="hljs-built_in">this</span>.id = id;
}
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">getName</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> name;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setName</span><span class="hljs-params">(String name)</span> {
<span class="hljs-built_in">this</span>.name = name;
}
<span class="hljs-keyword">public</span> <span class="hljs-type">int</span> <span class="hljs-title function_">getAge</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> age;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setAge</span><span class="hljs-params">(<span class="hljs-type">int</span> age)</span> {
<span class="hljs-built_in">this</span>.age = age;
}
<span class="hljs-keyword">public</span> <span class="hljs-type">double</span> <span class="hljs-title function_">getSalary</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> salary;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setSalary</span><span class="hljs-params">(<span class="hljs-type">double</span> salary)</span> {
<span class="hljs-built_in">this</span>.salary = salary;
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">()</span> {
System.out.println(<span class="hljs-string">"Employee()....."</span>);
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">(<span class="hljs-type">int</span> id)</span> {
<span class="hljs-built_in">this</span>.id = id;
System.out.println(<span class="hljs-string">"Employee(int id)....."</span>);
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">(<span class="hljs-type">int</span> id, String name)</span> {
<span class="hljs-built_in">this</span>.id = id;
<span class="hljs-built_in">this</span>.name = name;
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Employee</span><span class="hljs-params">(<span class="hljs-type">int</span> id, String name, <span class="hljs-type">int</span> age, <span class="hljs-type">double</span> salary)</span> {
<span class="hljs-built_in">this</span>.id = id;
<span class="hljs-built_in">this</span>.name = name;
<span class="hljs-built_in">this</span>.age = age;
<span class="hljs-built_in">this</span>.salary = salary;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">toString</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> <span class="hljs-string">"Employee{"</span> + <span class="hljs-string">"id="</span> + id + <span class="hljs-string">", name='"</span> + name + <span class="hljs-string">'\''</span> + <span class="hljs-string">", age="</span> + age + <span class="hljs-string">", salary="</span> + salary + <span class="hljs-string">'}'</span>;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> <span class="hljs-type">boolean</span> <span class="hljs-title function_">equals</span><span class="hljs-params">(Object o)</span> {
<span class="hljs-keyword">if</span> (<span class="hljs-built_in">this</span> == o)
<span class="hljs-keyword">return</span> <span class="hljs-literal">true</span>;
<span class="hljs-keyword">if</span> (o == <span class="hljs-literal">null</span> || getClass() != o.getClass())
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-type">Employee</span> <span class="hljs-variable">employee</span> <span class="hljs-operator">=</span> (Employee) o;
<span class="hljs-keyword">if</span> (id != employee.id)
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-keyword">if</span> (age != employee.age)
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-keyword">if</span> (Double.compare(employee.salary, salary) != <span class="hljs-number">0</span>)
<span class="hljs-keyword">return</span> <span class="hljs-literal">false</span>;
<span class="hljs-keyword">return</span> name != <span class="hljs-literal">null</span> ? name.equals(employee.name) : employee.name == <span class="hljs-literal">null</span>;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> <span class="hljs-type">int</span> <span class="hljs-title function_">hashCode</span><span class="hljs-params">()</span> {
<span class="hljs-type">int</span> result;
<span class="hljs-type">long</span> temp;
result = id;
result = <span class="hljs-number">31</span> * result + (name != <span class="hljs-literal">null</span> ? name.hashCode() : <span class="hljs-number">0</span>);
result = <span class="hljs-number">31</span> * result + age;
temp = Double.doubleToLongBits(salary);
result = <span class="hljs-number">31</span> * result + (<span class="hljs-type">int</span>) (temp ^ (temp >>> <span class="hljs-number">32</span>));
<span class="hljs-keyword">return</span> result;
}
}
3、测试类
import org.junit.Test;
import java.util.Arrays;
import java.util.List;
import java.util.stream.IntStream;
import java.util.stream.Stream;
/**
测试 Stream 的实例化
*/
public class StreamAPITest {//创建 Stream 方式一:通过集合
public void test(){
List<Employee> employees = EmployeeData.getEmployees();// 得到一个集合<span class="hljs-comment">//1.方法1:default Stream<E> stream() : 返回一个顺序流</span> Stream<Employee> stream = employees.stream(); <span class="hljs-comment">//2.方法2:default Stream<E> parallelStream() : 返回一个并行流</span> Stream<Employee> parallelStream = employees.parallelStream();
}
//创建 Stream 方式二:通过数组
public void test2(){
int[] arr = new int[]{1,2,3,4,5,6};
// 调用 Arrays 类的 static <T> Stream<T> stream(T[] array): 返回一个流
IntStream stream = Arrays.stream(arr);<span class="hljs-type">Employee</span> <span class="hljs-variable">e1</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1001</span>,<span class="hljs-string">"Tom"</span>); <span class="hljs-type">Employee</span> <span class="hljs-variable">e2</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1002</span>,<span class="hljs-string">"Jerry"</span>); Employee[] arr1 = <span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>[]{e1,e2}; Stream<Employee> stream1 = Arrays.stream(arr1);
}
//***************** 创建 Stream 方式三:通过 Stream 的 of()****************
public void test3(){
Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5, 6);
}//***************创建 Stream 方式四:创建无限流 (了解)***************
public void test4(){
// 方式 1:迭代
//public static<T> Stream<T> iterate(final T seed, final UnaryOperator<T> f)
// 遍历前 10 个偶数
Stream.iterate(0, t -> t + 2).limit(10).forEach(System.out::println);<span class="hljs-comment">//方式2:生成</span> <span class="hljs-comment">//public static<T> Stream<T> generate(Supplier<T> s)</span> Stream.generate(Math::random).limit(<span class="hljs-number">10</span>).forEach(System.out::println);
}
}
4.3、Stream 的中间操作:筛选与切片
1. 多个中间操作可以连接起来形成一个流水线,除非流水线上触发终止操作,否则中间操作不会执行任何的处理!而在终止操作时一次性全部处理,称为“惰性求值”。
2. 筛选与切片
方法 | 描述 |
---|---|
filter(Predicate p) | 接收 Lambda ,从流中排除某些元素 |
distinct() | 筛选,通过流所生成元素的 hashCode()和 equals() 去除重复元素 |
limit(long maxSize) | 截断流,使其元素不超过给定数量 |
skip(long n) | 跳过元素,返回一个扔掉了前 n 个元素的流。若流中元素不足 n 个,则返回一个空流。与limit(n) 互补 |
import org.junit.Test;
import java.util.List;
import java.util.stream.Stream;
/**
-
测试 Stream 的中间操作
*/
public class StreamAPITest2 {
//1- 筛选与切片
@Test
public void test(){
List<Employee> list = EmployeeData.getEmployees();
<span class="hljs-comment">//filter(Predicate p)——接收 Lambda,从流中排除某些元素。</span>
Stream<Employee> stream = list.stream();
<span class="hljs-comment">//练习:查询员工表中薪资大于7000的员工信息</span>
stream.filter(e -> e.getSalary() > <span class="hljs-number">7000</span>).forEach(System.out::println);
System.out.println(<span class="hljs-string">"*************************"</span>);
<span class="hljs-comment">//limit(n)——截断流,使其元素不超过给定数量。</span>
list.stream().limit(<span class="hljs-number">3</span>).forEach(System.out::println);
System.out.println(<span class="hljs-string">"*************************"</span>);
<span class="hljs-comment">//skip(n) —— 跳过元素,返回一个扔掉了前 n 个元素的流。若流中元素不足 n 个,则返回一个空流。与 limit(n) 互补</span>
list.stream().skip(<span class="hljs-number">3</span>).forEach(System.out::println);
System.out.println(<span class="hljs-string">"*************************"</span>);
<span class="hljs-comment">//distinct()——筛选,通过流所生成元素的 hashCode() 和 equals() 去除重复元素</span>
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1010</span>,<span class="hljs-string">"刘强东"</span>,<span class="hljs-number">40</span>,<span class="hljs-number">8000</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1010</span>,<span class="hljs-string">"刘强东"</span>,<span class="hljs-number">40</span>,<span class="hljs-number">8000</span>));
list.add(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Employee</span>(<span class="hljs-number">1010</span>,<span class="hljs-string">"刘强东"</span>,<span class="hljs-number">40</span>,<span class="hljs-number">8000</span>));
// System.out.println(list);
list.stream().distinct().forEach(System.out::println);
}
}
4.4、Stream 的中间操作:映射
方法 | 描述 |
---|---|
map(Function f) | 接收一个函数作为参数,该函数会被应用到每个元素上,并将其映射成一个新的元素。 |
mapToDouble(ToDoubleFunction f) | 接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新的 DoubleStream。 |
mapToInt(ToIntFunction f) | 接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新的 IntStream。 |
mapToLong(ToLongFunction f) | 接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新的 LongStream。 |
flatMap(Function f) | 接收一个函数作为参数,将流中的每个值都换成另一个流,然后把所有流连接成一个流 |
import org.junit.Test;// 代码有很多不懂得地方
import java.util.*;
import java.util.stream.Stream;
/**
-
测试 Stream 的中间操作
*/
public class StreamAPITest2 {
//2- 映射
@Test
public void test2(){
//map(Function f)——接收一个函数作为参数,将元素转换成其他形式或提取信息,该函数会被应用到每个元素上,并将其映射成一个新的元素。
List<String> list = Arrays.asList("aa", "bb", "cc", "dd");
list.stream().map(str -> str.toUpperCase()).forEach(System.out::println);
<span class="hljs-comment">//练习1:获取姓名长度大于3的 员工的姓名。</span>
List<Employee> employees = EmployeeData.getEmployees();
Stream<String> namesStream = employees.stream().map(e -> e.getName());
namesStream.filter(name -> name.length() > <span class="hljs-number">3</span>).forEach(System.out::println);
System.out.println(<span class="hljs-string">"************************"</span>);
<span class="hljs-comment">//练习2:</span>
Stream<Stream<Character>> streamStream=list.stream().map(StreamAPITest2::fromStringToStream);
streamStream.forEach(s ->{
s.forEach(System.out::println);
});
System.out.println(<span class="hljs-string">"************************"</span>);
<span class="hljs-comment">//flatMap(Function f)——接收一个函数作为参数,将流中的每个值都换成另一个流,然后把所有流连接成一个流。</span>
Stream<Character> characterStream = list.stream().flatMap(StreamAPITest2::fromStringToStream);
characterStream.forEach(System.out::println);
}
// 将字符串中的多个字符构成的集合转换为对应的 Stream 的实例
public static Stream<Character> fromStringToStream(String str){
ArrayList<Character> list = new ArrayList<>();
for(Character c : str.toCharArray()){
list.add(c);
}
return list.stream();
}
@Test
public void test3(){
ArrayList list1 = new ArrayList();
list1.add(1);
list1.add(2);
list1.add(3);
<span class="hljs-type">ArrayList</span> <span class="hljs-variable">list2</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">ArrayList</span>();
list2.add(<span class="hljs-number">4</span>);
list2.add(<span class="hljs-number">5</span>);
list2.add(<span class="hljs-number">6</span>);
// list1.add(list2);//[1, 2, 3, [4, 5, 6]]
list1.addAll(list2);//[1, 2, 3, 4, 5, 6]
System.out.println(list1);
}
}
4.5、Stream 的中间操作:排序
方法 | 描述 |
---|---|
sorted() | 产生一个新流,其中按自然顺序排序 |
sorted(Comparator com) | 产生一个新流,其中按比较器顺序排序 |
import org.junit.Test;
import java.util.*;
import java.util.stream.Stream;
/**
-
测试 Stream 的中间操作
*/
public class StreamAPITest2 {
//3- 排序
@Test
public void test4(){
<span class="hljs-comment">//1.sorted()——自然排序(默认从小到大)</span>
List<Integer> list = Arrays.asList(<span class="hljs-number">25</span>,<span class="hljs-number">45</span>,<span class="hljs-number">36</span>,<span class="hljs-number">12</span>,<span class="hljs-number">85</span>,<span class="hljs-number">64</span>,<span class="hljs-number">72</span>,-<span class="hljs-number">95</span>,<span class="hljs-number">4</span>);
list.stream().sorted().forEach(System.out::println);
<span class="hljs-comment">//抛异常,原因:Employee没有实现Comparable接口</span>
// List<Employee> employees = EmployeeData.getEmployees();
// employees.stream().sorted().forEach(System.out::println);
System.out.println(<span class="hljs-string">"***************************"</span>);
<span class="hljs-comment">//2.sorted(Comparator com)——定制排序</span>
List<Employee> employees = EmployeeData.getEmployees();
employees.stream().sorted( (e1,e2) -> {
<span class="hljs-comment">//年龄从小到大,年龄一样时,salary从大到小</span>
<span class="hljs-type">int</span> <span class="hljs-variable">ageValue</span> <span class="hljs-operator">=</span> Integer.compare(e1.getAge(),e2.getAge());
<span class="hljs-keyword">if</span>(ageValue != <span class="hljs-number">0</span>){
<span class="hljs-keyword">return</span> ageValue;
}<span class="hljs-keyword">else</span>{
<span class="hljs-keyword">return</span> -Double.compare(e1.getSalary(),e2.getSalary());
}
}).forEach(System.out::println);
}
}
4.6、Stream 的终止操作:匹配与查找
0.Stream 的终止操作
- 终端操作会从流的流水线生成结果。其结果可以是任何不是流的值,例如:List、Integer,甚至是 void 。
- 流进行了终止操作后,不能再次使用。
1. 匹配与查找
方法 | 描述 |
---|---|
allMatch(Predicate p) | 检查是否匹配所有元素 |
anyMatch(Predicate p) | 检查是否至少匹配一个元素 |
noneMatch(Predicate p) | 检查是否没有匹配所有元素 |
findFirst() | 返回第一个元素 |
findAny() | 返回当前流中的任意元素 |
count() | 返回流中元素总数 |
max(Comparator c) | 返回流中最大值 |
min(Comparator c) | 返回流中最小值 |
forEach(Consumer c) | 内部迭代 (使用 Collection 接口需要用户去做迭代,称为外部迭代。相反,Stream API 使用内部迭代——它帮你把迭代做了) |
import day11_20b.Employee;
import day11_20b.EmployeeData;
import org.junit.Test;
import java.util.List;
import java.util.Optional;
import java.util.stream.Stream;
public class StreamAPITest3 {
//1- 匹配与查找
@Test
public void test(){
List<Employee> employees = EmployeeData.getEmployees();
<span class="hljs-comment">//1.allMatch(Predicate p)——检查是否匹配所有元素。</span>
<span class="hljs-comment">//练习:是否所有的员工的年龄都大于18</span>
<span class="hljs-type">boolean</span> <span class="hljs-variable">allMatch</span> <span class="hljs-operator">=</span> employees.stream().allMatch(e -> e.getAge() > <span class="hljs-number">18</span>);
System.out.println(allMatch);<span class="hljs-comment">//false</span>
<span class="hljs-comment">//2.anyMatch(Predicate p)——检查是否至少匹配一个元素。</span>
<span class="hljs-comment">//练习:是否存在员工的工资大于 10000</span>
<span class="hljs-type">boolean</span> <span class="hljs-variable">anyMatch</span> <span class="hljs-operator">=</span> employees.stream().anyMatch(e -> e.getSalary() > <span class="hljs-number">10000</span>);
System.out.println(anyMatch);<span class="hljs-comment">//false</span>
<span class="hljs-comment">//3.noneMatch(Predicate p)——检查是否没有匹配的元素。</span>
<span class="hljs-comment">//练习:是否存在员工姓“马”。本题中,有姓马的,所以返回false</span>
<span class="hljs-type">boolean</span> <span class="hljs-variable">noneMatch</span> <span class="hljs-operator">=</span> employees.stream().noneMatch(e -> e.getName().startsWith(<span class="hljs-string">"马"</span>));
System.out.println(noneMatch);<span class="hljs-comment">//false</span>
<span class="hljs-comment">//4.findFirst——返回第一个元素</span>
Optional<Employee> employee = employees.stream().findFirst();
System.out.println(employee);
<span class="hljs-comment">//5.findAny——返回当前流中的任意元素</span>
Optional<Employee> employee1 = employees.parallelStream().findAny();
System.out.println(employee1);
}
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test2</span><span class="hljs-params">()</span>{
List<Employee> employees = EmployeeData.getEmployees();
<span class="hljs-comment">//6.count——返回流中元素的总个数</span>
<span class="hljs-type">long</span> <span class="hljs-variable">count</span> <span class="hljs-operator">=</span> employees.stream().filter(e -> e.getSalary() > <span class="hljs-number">4500</span>).count();
System.out.println(count);<span class="hljs-comment">//5</span>
<span class="hljs-comment">//7.max(Comparator c)——返回流中最大值</span>
<span class="hljs-comment">//练习:返回最高的工资:</span>
Stream<Double> salaryStream = employees.stream().map(e -> e.getSalary());
Optional<Double> maxSalary = salaryStream.max(Double::compare);
System.out.println(maxSalary);<span class="hljs-comment">//Optional[9876.12]</span>
<span class="hljs-comment">//8.min(Comparator c)——返回流中最小值</span>
<span class="hljs-comment">//练习:返回最低工资的员工</span>
Optional<Employee> employee = employees.stream().min((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()));
System.out.println(employee);
System.out.println();
<span class="hljs-comment">//9.forEach(Consumer c)——内部迭代(forEach():是stream里的一个终止操作)</span>
employees.stream().forEach(System.out::println);
System.out.println();<span class="hljs-comment">//遍历所有员工</span>
<span class="hljs-comment">//使用集合的遍历操作(forEach():在这里只是集合里面的一个普通方法)</span>
employees.forEach(System.out::println);<span class="hljs-comment">//遍历所有员工</span>
}
}
4.7、Stream 的终止操作:归约
方法 | 描述 |
---|---|
reduce(T iden, BinaryOperator b) | 可以将流中元素反复结合起来,得到一个值。返回 T |
reduce(BinaryOperator b) | 可以将流中元素反复结合起来,得到一个值。返回 Optional |
备注:map 和 reduce 的连接通常称为 map-reduce 模式,因 Google 用它来进行网络搜索而出名。
import day11_20b.Employee;
import day11_20b.EmployeeData;
import org.junit.Test;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.stream.Stream;
public class StreamAPITest3 {
<span class="hljs-comment">//2-归约</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test3</span><span class="hljs-params">()</span>{
<span class="hljs-comment">//1.reduce(T identity, BinaryOperator)——可以将流中元素反复结合起来,得到一个值。返回 T</span>
<span class="hljs-comment">//练习1:计算1-10的自然数的和</span>
List<Integer> list = Arrays.asList(<span class="hljs-number">1</span>,<span class="hljs-number">2</span>,<span class="hljs-number">3</span>,<span class="hljs-number">4</span>,<span class="hljs-number">5</span>,<span class="hljs-number">6</span>,<span class="hljs-number">7</span>,<span class="hljs-number">8</span>,<span class="hljs-number">9</span>,<span class="hljs-number">10</span>);
<span class="hljs-comment">//参数1:初始值 参数2:</span>
<span class="hljs-type">Integer</span> <span class="hljs-variable">sum</span> <span class="hljs-operator">=</span> list.stream().reduce(<span class="hljs-number">0</span>, Integer::sum);
System.out.println(sum);<span class="hljs-comment">//55</span>
<span class="hljs-comment">//2.reduce(BinaryOperator) ——可以将流中元素反复结合起来,得到一个值。返回 Optional<T></span>
<span class="hljs-comment">//练习2:计算公司所有员工工资的总和</span>
List<Employee> employees = EmployeeData.getEmployees();
Stream<Double> salaryStream = employees.stream().map(Employee::getSalary);<span class="hljs-comment">//映射为Salary</span>
<span class="hljs-comment">//Optional<Double> sumMoney = salaryStream.reduce(Double::sum);//这个方法和下面这个一样</span>
Optional<Double> sumMoney = salaryStream.reduce((d1,d2) -> d1 + d2);
System.out.println(sumMoney);<span class="hljs-comment">//Optional[48424.08],是所有员工薪水的z</span>
}
}
4.8、Stream 的终止操作:收集
方法 | 描述 |
---|---|
collect(Collector c) | 将流转换为其他形式。接收一个 Collector 接口的实现,用于给 Stream 中元素做汇总的方法 |
Collector 接口中方法的实现决定了如何对流执行收集的操作 ( 如收集到List、Set、Map
)。
Collectors 实用类提供了很多静态方法,可以方便地创建常见收集器实例,具体方法与实例如下表:
import day11_20b.Employee;
import day11_20b.EmployeeData;
import org.junit.Test;
import java.util.*;
import java.util.stream.*;
public class StreamAPITest3 {
//3- 收集
@Test
public void test4() {
//collect(Collector c)——将流转换为其他形式。
// 接收一个 Collector 接口的实现,用于给 Stream 中元素做汇总的方法
<span class="hljs-comment">//练习1:查找工资大于6000的员工,结果返回为一个List</span>
List<Employee> employees = EmployeeData.getEmployees();
List<Employee> employeeList = employees.stream().filter(e -> e.getSalary() > <span class="hljs-number">6000</span>).collect(Collectors.toList());
employeeList.forEach(System.out::println);
System.out.println(<span class="hljs-string">"*******************"</span>);
<span class="hljs-comment">//查找工资大于6000的员工,结果返回为一个Set</span>
Set<Employee> employeeSet = employees.stream().filter(e -> e.getSalary() > <span class="hljs-number">6000</span>).collect(Collectors.toSet());
employeeSet.forEach(System.out::println);
}
}
05、Optional 类
5.1、Optional 类的介绍
1、Boy 类
public class Boy {
private Girl girl;
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Boy</span><span class="hljs-params">()</span> {
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Boy</span><span class="hljs-params">(Girl girl)</span> {
<span class="hljs-built_in">this</span>.girl = girl;
}
<span class="hljs-keyword">public</span> Girl <span class="hljs-title function_">getGirl</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> girl;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setGirl</span><span class="hljs-params">(Girl girl)</span> {
<span class="hljs-built_in">this</span>.girl = girl;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">toString</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> <span class="hljs-string">"Boy{"</span> +
<span class="hljs-string">"girl="</span> + girl +
<span class="hljs-string">'}'</span>;
}
}
2、Girl 类
public class Girl {
private String name;
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Girl</span><span class="hljs-params">()</span> {
}
<span class="hljs-keyword">public</span> <span class="hljs-title function_">Girl</span><span class="hljs-params">(String name)</span> {
<span class="hljs-built_in">this</span>.name = name;
}
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">getName</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> name;
}
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">setName</span><span class="hljs-params">(String name)</span> {
<span class="hljs-built_in">this</span>.name = name;
}
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">toString</span><span class="hljs-params">()</span> {
<span class="hljs-keyword">return</span> <span class="hljs-string">"Girl{"</span> +
<span class="hljs-string">"name='"</span> + name + <span class="hljs-string">'\''</span> +
<span class="hljs-string">'}'</span>;
}
}
3、测试类
import org.junit.Test;
import java.util.Optional;
/**
- Optional 类:为了在程序中避免出现空指针异常而创建的。
- 常用的方法:ofNullable(T t)
-
orElse(T t)
/
public class OptionalTest {
/*
* Optional.of(T t) : 创建一个 Optional 实例,t 必须非空;
* Optional.empty() : 创建一个空的 Optional 实例
* Optional.ofNullable(T t):t 可以为 null
*/
@Test
public void test(){
String str = "hello";
//1.of(T t): 封装数据 t 生成 Optional 对象。要求 t 是非空的,否则报错。
Optional<String> op1 = Optional.of(str);
<span class="hljs-comment">//2.get() 通常与of()方法搭配使用。用于获取内部封装的数据value,如果value为空,则get()报错。</span>
<span class="hljs-type">String</span> <span class="hljs-variable">str1</span> <span class="hljs-operator">=</span> op1.get();
System.out.println(str1);<span class="hljs-comment">//hello</span>
}
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test2</span><span class="hljs-params">()</span>{
<span class="hljs-type">String</span> <span class="hljs-variable">str</span> <span class="hljs-operator">=</span> <span class="hljs-string">"beijing"</span>;
// str = null;
<span class="hljs-comment">//3.ofNullable(T t):t可以为null</span>
Optional<String> op1 = Optional.ofNullable(str);
System.out.println(op1);<span class="hljs-comment">//Optional[beijing]</span>
<span class="hljs-comment">//4.orElse(T t1):如果当前的Optional内部的value非空,则返回此value值.</span>
<span class="hljs-comment">// 如果value值为空,则返回orElse()方法中的参数t1.</span>
<span class="hljs-type">String</span> <span class="hljs-variable">str2</span> <span class="hljs-operator">=</span> op1.orElse(<span class="hljs-string">"shanghai"</span>);
System.out.println(str2);<span class="hljs-comment">//beijing</span>
}
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test3</span><span class="hljs-params">()</span>{
<span class="hljs-comment">//5.empty():创建的Optional对象内部的value = null</span>
Optional<Object> op1 = Optional.empty();
<span class="hljs-comment">//6.boolean isPresent()判断是否包含对象,此时不包含,为false,又加了个!,所以为true</span>
<span class="hljs-keyword">if</span>(!op1.isPresent()){
System.out.println(<span class="hljs-string">"数据为空"</span>);
}
System.out.println(op1);<span class="hljs-comment">//Optional.empty</span>
System.out.println(op1.isPresent());<span class="hljs-comment">//false</span>
}
}
5.2、Optional 类的使用举例
1、测试类
import org.junit.Test;
import java.util.Optional;
public class OptionalTest {
<span class="hljs-comment">//1.优化前的getGirlName():</span>
<span class="hljs-keyword">private</span> String <span class="hljs-title function_">getGirlName</span><span class="hljs-params">(Boy boy)</span> {
<span class="hljs-keyword">return</span> boy.getGirl().getName();
}
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test3</span><span class="hljs-params">()</span>{
<span class="hljs-type">Boy</span> <span class="hljs-variable">boy</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Boy</span>();
<span class="hljs-type">String</span> <span class="hljs-variable">girlName</span> <span class="hljs-operator">=</span> getGirlName(boy);
System.out.println(girlName);<span class="hljs-comment">//Girl没有赋值,空指针异常</span>
}
<span class="hljs-comment">//2.优化(不使用Optional类)后的getGirlName():</span>
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">getGirlName1</span><span class="hljs-params">(Boy boy)</span>{
<span class="hljs-keyword">if</span>(boy != <span class="hljs-literal">null</span>){
<span class="hljs-type">Girl</span> <span class="hljs-variable">girl</span> <span class="hljs-operator">=</span> boy.getGirl();
<span class="hljs-keyword">if</span>(girl != <span class="hljs-literal">null</span>){
<span class="hljs-keyword">return</span> girl.getName();
}
}
<span class="hljs-keyword">return</span> <span class="hljs-literal">null</span>;
}
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test4</span><span class="hljs-params">()</span>{
<span class="hljs-type">Boy</span> <span class="hljs-variable">boy</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">Boy</span>();
boy = <span class="hljs-literal">null</span>;
<span class="hljs-type">String</span> <span class="hljs-variable">girlName</span> <span class="hljs-operator">=</span> getGirlName1(boy);
System.out.println(girlName);
}
<span class="hljs-comment">//3.使用Optional类的getGirlName():</span>
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">getGirlName2</span><span class="hljs-params">(Boy boy)</span>{
Optional<Boy> boyOptional = Optional.ofNullable(boy);
<span class="hljs-comment">//此时的boy1一定非空。</span>
<span class="hljs-type">Boy</span> <span class="hljs-variable">boy1</span> <span class="hljs-operator">=</span> boyOptional.orElse(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Boy</span>(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Girl</span>(<span class="hljs-string">"古力娜扎"</span>)));
<span class="hljs-type">Girl</span> <span class="hljs-variable">girl</span> <span class="hljs-operator">=</span> boy1.getGirl();<span class="hljs-comment">//如果形参boy非空,此时得到的girl为null</span>
Optional<Girl> girlOptional = Optional.ofNullable(girl);
<span class="hljs-comment">//girl1一定非空</span>
<span class="hljs-type">Girl</span> <span class="hljs-variable">girl1</span> <span class="hljs-operator">=</span> girlOptional.orElse(<span class="hljs-keyword">new</span> <span class="hljs-title class_">Girl</span>(<span class="hljs-string">"刘亦菲"</span>));
<span class="hljs-keyword">return</span> girl1.getName();
}
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">test5</span><span class="hljs-params">()</span>{
<span class="hljs-type">Boy</span> <span class="hljs-variable">boy</span> <span class="hljs-operator">=</span> <span class="hljs-literal">null</span>;
boy = <span class="hljs-keyword">new</span> <span class="hljs-title class_">Boy</span>();
// boy = new Boy(new Girl("李清照"));
String girlName = getGirlName2(boy);
System.out.println(girlName);// 刘亦菲, 此时 Boy 不空,Girl 空
}
}