java8新特性

12 Java 8新特性 - 图1

1. Lambda表达式

何时可以使用Lambda表达式?

当需要对一个函数式接口实例化的时候,可以使用lambda表达式。

1.1. Lambda表达式举例

  1. import org.junit.Test;
  2. import java.util.Comparator;
  3. /**
  4. * Lambda表达式的使用举例
  5. *
  6. * @author shkstart
  7. * @create 2019 上午 11:30
  8. */
  9. public class LambdaTest {
  10. @Test
  11. public void test1(){
  12. Runnable r1 = new Runnable() {
  13. @Override
  14. public void run() {
  15. System.out.println("我爱北京天安门");
  16. }
  17. };
  18. r1.run();
  19. System.out.println("***********************");
  20. Runnable r2 = () -> System.out.println("我爱北京故宫");
  21. r2.run();
  22. }
  23. @Test
  24. public void test2(){
  25. Comparator<Integer> com1 = new Comparator<Integer>() {
  26. @Override
  27. public int compare(Integer o1, Integer o2) {
  28. return Integer.compare(o1,o2);
  29. }
  30. };
  31. int compare1 = com1.compare(12,21);
  32. System.out.println(compare1);
  33. System.out.println("***********************");
  34. //Lambda表达式的写法
  35. Comparator<Integer> com2 = (o1,o2) -> Integer.compare(o1,o2);
  36. int compare2 = com2.compare(32,21);
  37. System.out.println(compare2);
  38. System.out.println("***********************");
  39. //方法引用
  40. Comparator<Integer> com3 = Integer :: compare;
  41. int compare3 = com3.compare(32,21);
  42. System.out.println(compare3);
  43. }
  44. }

1.2. Lambda表达式的使用

举例: (o1,o2) -> Integer.compare(o1,o2);

格式:

  1. -> lambda操作符 箭头操作符
  2. ->左边:lambda形参列表 (其实就是接口中的抽象方法的形参列表)
  3. ->右边:lambda (其实就是重写的抽象方法的方法体)

总结

->左边:lambda形参列表的参数类型可以省略(类型推断);如果lambda形参列表只有一个参数,其一对()也可以省略

->右边:lambda体应该使用一对{}包裹;如果lambda体只有一条执行语句(可能是return语句),省略这一对{}和return关键字

1.2.1. 语法格式一:无参,无返回值

  1. //语法格式一:无参,无返回值
  2. @Test
  3. public void test1(){
  4. Runnable r1 = new Runnable() {
  5. @Override
  6. public void run() {
  7. System.out.println("我爱北京天安门");
  8. }
  9. };
  10. r1.run();
  11. System.out.println("***********************");
  12. Runnable r2 = () -> {
  13. System.out.println("我爱北京故宫");
  14. };
  15. r2.run();
  16. }

1.2.2. 语法格式二:Lambda 需要一个参数,但是没有返回值。

  1. //语法格式二:Lambda 需要一个参数,但是没有返回值。
  2. @Test
  3. public void test2(){
  4. Consumer<String> con = new Consumer<String>() {
  5. @Override
  6. public void accept(String s) {
  7. System.out.println(s);
  8. }
  9. };
  10. con.accept("谎言和誓言的区别是什么?");
  11. System.out.println("*******************");
  12. Consumer<String> con1 = (String s) -> {
  13. System.out.println(s);
  14. };
  15. con1.accept("一个是听得人当真了,一个是说的人当真了");
  16. }

1.2.3. 语法格式三:数据类型可以省略,因为可由编译器推断得出,称为“类型推断”

  1. //语法格式三:数据类型可以省略,因为可由编译器推断得出,称为“类型推断”
  2. @Test
  3. public void test3(){
  4. Consumer<String> con1 = (String s) -> {
  5. System.out.println(s);
  6. };
  7. con1.accept("一个是听得人当真了,一个是说的人当真了");
  8. System.out.println("*******************");
  9. Consumer<String> con2 = (s) -> {
  10. System.out.println(s);
  11. };
  12. con2.accept("一个是听得人当真了,一个是说的人当真了");
  13. }

1.2.4. 语法格式四:Lambda 若只需要一个参数时,参数的小括号可以省略

  1. //语法格式四:Lambda 若只需要一个参数时,参数的小括号可以省略
  2. @Test
  3. public void test5(){
  4. Consumer<String> con1 = (s) -> {
  5. System.out.println(s);
  6. };
  7. con1.accept("一个是听得人当真了,一个是说的人当真了");
  8. System.out.println("*******************");
  9. Consumer<String> con2 = s -> {
  10. System.out.println(s);
  11. };
  12. con2.accept("一个是听得人当真了,一个是说的人当真了");
  13. }

1.2.5. 语法格式五:Lambda 需要两个或以上的参数,多条执行语句,并且可以有返回值

  1. @Test
  2. public void test6(){
  3. Comparator<Integer> com1 = new Comparator<Integer>() {
  4. @Override
  5. public int compare(Integer o1, Integer o2) {
  6. System.out.println(o1);
  7. System.out.println(o2);
  8. return o1.compareTo(o2);
  9. }
  10. };
  11. System.out.println(com1.compare(12,21));
  12. System.out.println("*****************************");
  13. Comparator<Integer> com2 = (o1,o2) -> {
  14. System.out.println(o1);
  15. System.out.println(o2);
  16. return o1.compareTo(o2);
  17. };
  18. System.out.println(com2.compare(12,6));
  19. }

1.2.6. 语法格式六:当 Lambda 体只有一条语句时,return 与大括号若有,都可以省略

  1. //语法格式六:当 Lambda 体只有一条语句时,return 与大括号若有,都可以省略
  2. @Test
  3. public void test7(){
  4. Comparator<Integer> com1 = (o1,o2) -> {
  5. return o1.compareTo(o2);
  6. };
  7. System.out.println(com1.compare(12,6));
  8. System.out.println("*****************************");
  9. Comparator<Integer> com2 = (o1,o2) -> o1.compareTo(o2);
  10. System.out.println(com2.compare(12,21));
  11. }
  12. @Test
  13. public void test8(){
  14. Consumer<String> con1 = s -> {
  15. System.out.println(s);
  16. };
  17. con1.accept("一个是听得人当真了,一个是说的人当真了");
  18. System.out.println("*****************************");
  19. Consumer<String> con2 = s -> System.out.println(s);
  20. con2.accept("一个是听得人当真了,一个是说的人当真了");
  21. }

1.3. Lambda表达式的本质

Lambda表达式的本质就是一个函数式接口的实例。

2. 函数式(Functional)接口

如果一个接口中,只声明了一个抽象方法,则此接口就称为函数式接口。我们可以在一个接口上使用 @FunctionalInterface 注解,这样做可以检查它是否是一个函数式接口。

所以以前用匿名实现类表示的现在都可以用Lambda表达式来写。

何时使用给定的函数式接口?
如果我们开发中需要定义一个函数式接口,首先看看已有的jdk提供的函数式接口是否提供了能满足需求的函数式接口。如果有,则直接调用即可,不需要自己再定义了。

2.1. java内置的4大核心函数式接口

12 Java 8新特性 - 图2

2.2. java内置的其他函数式接口

12 Java 8新特性 - 图3

2.3. 四大核心函数式接口举例

  1. /**
  2. * java内置的4大核心函数式接口
  3. *
  4. * 消费型接口 Consumer<T> void accept(T t)
  5. * 供给型接口 Supplier<T> T get()
  6. * 函数型接口 Function<T,R> R apply(T t)
  7. * 断定型接口 Predicate<T> boolean test(T t)
  8. *
  9. *
  10. * @author shkstart
  11. * @create 2019 下午 2:29
  12. */
  13. public class LambdaTest2 {
  14. @Test
  15. public void test1(){
  16. happyTime(500, new Consumer<Double>() {
  17. @Override
  18. public void accept(Double aDouble) {
  19. System.out.println("学习太累了,去天上人间买了瓶矿泉水,价格为:" + aDouble);
  20. }
  21. });
  22. System.out.println("********************");
  23. happyTime(400,money -> System.out.println("学习太累了,去天上人间喝了口水,价格为:" + money));
  24. }
  25. public void happyTime(double money, Consumer<Double> con){
  26. con.accept(money);
  27. }
  28. @Test
  29. public void test2(){
  30. List<String> list = Arrays.asList("北京","南京","天津","东京","西京","普京");
  31. List<String> filterStrs = filterString(list, new Predicate<String>() {
  32. @Override
  33. public boolean test(String s) {
  34. return s.contains("京");
  35. }
  36. });
  37. System.out.println(filterStrs);
  38. List<String> filterStrs1 = filterString(list,s -> s.contains("京"));
  39. System.out.println(filterStrs1);
  40. }
  41. //根据给定的规则,过滤集合中的字符串。此规则由Predicate的方法决定
  42. public List<String> filterString(List<String> list, Predicate<String> pre){
  43. ArrayList<String> filterList = new ArrayList<>();
  44. for(String s : list){
  45. if(pre.test(s)){
  46. filterList.add(s);
  47. }
  48. }
  49. return filterList;
  50. }
  51. }

3. 方法引用与构造器引用

3.1. 方法应用概念

方法引用,本质上就是Lambda表达式,而Lambda表达式作为函数式接口的实例。所以方法引用,也是函数式接口的实例。

3.2. 方法引用使用情境

当要传递给Lambda体的操作,已经有实现的方法了,可以使用方法引用!

3.3. 方法引用使用格式

使用格式: 类(或对象) :: 方法名

3.3.1. 情况一:对象 :: 实例方法

  1. // 情况一:对象 :: 实例方法
  2. //Consumer中的void accept(T t)
  3. //PrintStream中的void println(T t)
  4. @Test
  5. public void test1() {
  6. Consumer<String> con1 = str -> System.out.println(str);
  7. con1.accept("北京");
  8. System.out.println("*******************");
  9. PrintStream ps = System.out;
  10. Consumer<String> con2 = ps::println;
  11. con2.accept("beijing");
  12. }
  13. //Supplier中的T get()
  14. //Employee中的String getName()
  15. @Test
  16. public void test2() {
  17. Employee emp = new Employee(1001,"Tom",23,5600);
  18. Supplier<String> sup1 = () -> emp.getName();
  19. System.out.println(sup1.get());
  20. System.out.println("*******************");
  21. Supplier<String> sup2 = emp::getName;
  22. System.out.println(sup2.get());
  23. }

3.3.2. 情况二:类 :: 静态方法

  1. // 情况二:类 :: 静态方法
  2. //Comparator中的int compare(T t1,T t2)
  3. //Integer中的int compare(T t1,T t2)
  4. @Test
  5. public void test3() {
  6. Comparator<Integer> com1 = (t1,t2) -> Integer.compare(t1,t2);
  7. System.out.println(com1.compare(12,21));
  8. System.out.println("*******************");
  9. Comparator<Integer> com2 = Integer::compare;
  10. System.out.println(com2.compare(12,3));
  11. }
  12. //Function中的R apply(T t)
  13. //Math中的Long round(Double d)
  14. @Test
  15. public void test4() {
  16. Function<Double,Long> func = new Function<Double, Long>() {
  17. @Override
  18. public Long apply(Double d) {
  19. return Math.round(d);
  20. }
  21. };
  22. System.out.println("*******************");
  23. Function<Double,Long> func1 = d -> Math.round(d);
  24. System.out.println(func1.apply(12.3));
  25. System.out.println("*******************");
  26. Function<Double,Long> func2 = Math::round;
  27. System.out.println(func2.apply(12.6));
  28. }

3.3.3. 情况三:类 :: 实例方法 (有难度)

  1. // 情况三:类 :: 实例方法 (有难度)
  2. // Comparator中的int comapre(T t1,T t2)
  3. // String中的int t1.compareTo(t2)
  4. @Test
  5. public void test5() {
  6. Comparator<String> com1 = (s1,s2) -> s1.compareTo(s2);
  7. System.out.println(com1.compare("abc","abd"));
  8. System.out.println("*******************");
  9. Comparator<String> com2 = String :: compareTo;
  10. System.out.println(com2.compare("abd","abm"));
  11. }
  12. //BiPredicate中的boolean test(T t1, T t2);
  13. //String中的boolean t1.equals(t2)
  14. @Test
  15. public void test6() {
  16. BiPredicate<String,String> pre1 = (s1,s2) -> s1.equals(s2);
  17. System.out.println(pre1.test("abc","abc"));
  18. System.out.println("*******************");
  19. BiPredicate<String,String> pre2 = String :: equals;
  20. System.out.println(pre2.test("abc","abd"));
  21. }
  22. // Function中的R apply(T t)
  23. // Employee中的String getName();
  24. @Test
  25. public void test7() {
  26. Employee employee = new Employee(1001, "Jerry", 23, 6000);
  27. Function<Employee,String> func1 = e -> e.getName();
  28. System.out.println(func1.apply(employee));
  29. System.out.println("*******************");
  30. Function<Employee,String> func2 = Employee::getName;
  31. System.out.println(func2.apply(employee));
  32. }

3.4. 方法引用的使用要求

要求接口中的抽象方法的形参列表和返回值类型方法引用的方法的形参列表和返回值类型相同!(针对于情况1和情况2)

当函数式接口方法的第一个参数是需要引用方法的调用者,并且第二个参数是需要引用方法的参数(或无参数)时:className::methodName。(针对于情况3)

3.5. 使用建议

如果给函数式接口提供实例,恰好满足方法引用的使用情境,大家就可以考虑使用方法引用给函数式接口提供实例。如果不熟悉方法引用,那么还可以使用Lambda表达式。

3.6. 构造器引用

要求:和方法引用类似,函数式接口的抽象方法的形参列表和构造器的形参列表一致。抽象方法的返回值类型即为构造器所属的类的类型

  1. //构造器引用
  2. //Supplier中的T get()
  3. //Employee的空参构造器:Employee()
  4. @Test
  5. public void test1(){
  6. Supplier<Employee> sup = new Supplier<Employee>() {
  7. @Override
  8. public Employee get() {
  9. return new Employee();
  10. }
  11. };
  12. System.out.println("*******************");
  13. Supplier<Employee> sup1 = () -> new Employee();
  14. System.out.println(sup1.get());
  15. System.out.println("*******************");
  16. Supplier<Employee> sup2 = Employee :: new;
  17. System.out.println(sup2.get());
  18. }
  19. //Function中的R apply(T t)
  20. @Test
  21. public void test2(){
  22. Function<Integer,Employee> func1 = id -> new Employee(id);
  23. Employee employee = func1.apply(1001);
  24. System.out.println(employee);
  25. System.out.println("*******************");
  26. Function<Integer,Employee> func2 = Employee :: new;
  27. Employee employee1 = func2.apply(1002);
  28. System.out.println(employee1);
  29. }
  30. //BiFunction中的R apply(T t,U u)
  31. @Test
  32. public void test3(){
  33. BiFunction<Integer,String,Employee> func1 = (id,name) -> new Employee(id,name);
  34. System.out.println(func1.apply(1001,"Tom"));
  35. System.out.println("*******************");
  36. BiFunction<Integer,String,Employee> func2 = Employee :: new;
  37. System.out.println(func2.apply(1002,"Tom"));
  38. }

3.7. 数组引用

大家可以把数组看做是一个特殊的类,则写法与构造器引用一致。

  1. //数组引用
  2. //Function中的R apply(T t)
  3. @Test
  4. public void test4(){
  5. Function<Integer,String[]> func1 = length -> new String[length];
  6. String[] arr1 = func1.apply(5);
  7. System.out.println(Arrays.toString(arr1));
  8. System.out.println("*******************");
  9. Function<Integer,String[]> func2 = String[] :: new;
  10. String[] arr2 = func2.apply(10);
  11. System.out.println(Arrays.toString(arr2));
  12. }

4. 强大的Stream API

4.1. Stream API概述

java8提供了一套api,使用这套api可以对内存中的数据进行过滤、排序、映射、归约等操作。类似于sql对数据库中表的相关操作。

stream与集合的区别?

stream关注的是对数据的运算,与cpu打交道。集合关注的是数据的存储,与内存打交道。

注意:

  1. Stream 自己不会存储元素。
  2. ②**Stream 不会改变源对象。相反,他们会返回一个持有结果的新Stream。**
  3. Stream 操作是**延迟执行**的。这意味着他们会等到需要结果(**终止操作**)的时候才执行。

4.2. Stream的操作三个步骤

创建 Stream(Stream的实例化)

  1. 一个数据源(如:集合、数组),获取一个流

中间操作

  1. 一个中间操作链,对数据源的数据进行处理

终止操作(终端操作)

  1. **一旦执行终止操作,就执行中间操作链**,**并产生结果。之后,不会再被使用**

12 Java 8新特性 - 图4

4.3. Stream的实例化

4.3.1. 创建Stream方式一:通过集合

  1. //创建 Stream方式一:通过集合
  2. @Test
  3. public void test1(){
  4. List<Employee> employees = EmployeeData.getEmployees();
  5. // default Stream<E> stream() : 返回一个顺序流
  6. Stream<Employee> stream = employees.stream();
  7. // default Stream<E> parallelStream() : 返回一个并行流
  8. Stream<Employee> parallelStream = employees.parallelStream();
  9. }

4.3.2. 创建Stream方式二:通过数组

  1. //创建 Stream方式二:通过数组
  2. @Test
  3. public void test2(){
  4. int[] arr = new int[]{1,2,3,4,5,6};
  5. //调用Arrays类的static <T> Stream<T> stream(T[] array): 返回一个流
  6. IntStream stream = Arrays.stream(arr);
  7. Employee e1 = new Employee(1001,"Tom");
  8. Employee e2 = new Employee(1002,"Jerry");
  9. Employee[] arr1 = new Employee[]{e1,e2};
  10. Stream<Employee> stream1 = Arrays.stream(arr1);
  11. }

4.3.3. 创建Stream方式三:通过Stream的of()

  1. //创建 Stream方式三:通过Stream的of()
  2. @Test
  3. public void test3(){
  4. Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5, 6);
  5. }

4.3.4. 创建Stream方式四:创建无限流(了解)

  1. //创建 Stream方式四:创建无限流
  2. @Test
  3. public void test4(){
  4. // 迭代
  5. // public static<T> Stream<T> iterate(final T seed, final UnaryOperator<T> f)
  6. //遍历前10个偶数
  7. Stream.iterate(0, t -> t + 2).limit(10).forEach(System.out::println);
  8. // 生成
  9. // public static<T> Stream<T> generate(Supplier<T> s)
  10. Stream.generate(Math::random).limit(10).forEach(System.out::println);
  11. }

4.4. Stream的中间操作

4.4.1. 筛选与切片

  1. //1-筛选与切片
  2. @Test
  3. public void test1(){
  4. List<Employee> list = EmployeeData.getEmployees();
  5. // filter(Predicate p)——接收 Lambda , 从流中排除某些元素。
  6. Stream<Employee> stream = list.stream();
  7. //练习:查询员工表中薪资大于7000的员工信息
  8. stream.filter(e -> e.getSalary() > 7000).forEach(System.out::println);
  9. System.out.println();
  10. // limit(n)——截断流,使其元素不超过给定数量。
  11. list.stream().limit(3).forEach(System.out::println);
  12. System.out.println();
  13. // skip(n) —— 跳过元素,返回一个扔掉了前 n 个元素的流。若流中元素不足 n 个,则返回一个空流。与 limit(n) 互补
  14. list.stream().skip(3).forEach(System.out::println);
  15. System.out.println();
  16. // distinct()——筛选,通过流所生成元素的 hashCode() 和 equals() 去除重复元素
  17. list.add(new Employee(1010,"刘强东",40,8000));
  18. list.add(new Employee(1010,"刘强东",41,8000));
  19. list.add(new Employee(1010,"刘强东",40,8000));
  20. list.add(new Employee(1010,"刘强东",40,8000));
  21. list.add(new Employee(1010,"刘强东",40,8000));
  22. // System.out.println(list);
  23. list.stream().distinct().forEach(System.out::println);
  24. }

4.4.2. 映射

  1. //映射
  2. @Test
  3. public void test2(){
  4. // map(Function f)——接收一个函数作为参数,将元素转换成其他形式或提取信息,该函数会被应用到每个元素上,并将其映射成一个新的元素。
  5. List<String> list = Arrays.asList("aa", "bb", "cc", "dd");
  6. list.stream().map(str -> str.toUpperCase()).forEach(System.out::println);
  7. // 练习1:获取员工姓名长度大于3的员工的姓名。
  8. List<Employee> employees = EmployeeData.getEmployees();
  9. Stream<String> namesStream = employees.stream().map(Employee::getName);
  10. namesStream.filter(name -> name.length() > 3).forEach(System.out::println);
  11. System.out.println();
  12. //练习2:
  13. Stream<Stream<Character>> streamStream = list.stream().map(StreamAPITest1::fromStringToStream);
  14. streamStream.forEach(s ->{
  15. s.forEach(System.out::println);
  16. });
  17. System.out.println();
  18. // flatMap(Function f)——接收一个函数作为参数,将流中的每个值都换成另一个流,然后把所有流连接成一个流。
  19. Stream<Character> characterStream = list.stream().flatMap(StreamAPITest1::fromStringToStream);
  20. characterStream.forEach(System.out::println);
  21. }
  22. //将字符串中的多个字符构成的集合转换为对应的Stream的实例
  23. public static Stream<Character> fromStringToStream(String str){//aa
  24. ArrayList<Character> list = new ArrayList<>();
  25. for(Character c : str.toCharArray()){
  26. list.add(c);
  27. }
  28. return list.stream();
  29. }
  30. @Test
  31. public void test3(){
  32. ArrayList list1 = new ArrayList();
  33. list1.add(1);
  34. list1.add(2);
  35. list1.add(3);
  36. ArrayList list2 = new ArrayList();
  37. list2.add(4);
  38. list2.add(5);
  39. list2.add(6);
  40. // list1.add(list2);
  41. list1.addAll(list2);
  42. System.out.println(list1);
  43. }

4.4.3. 排序

  1. //3-排序
  2. @Test
  3. public void test4(){
  4. // sorted()——自然排序
  5. List<Integer> list = Arrays.asList(12, 43, 65, 34, 87, 0, -98, 7);
  6. list.stream().sorted().forEach(System.out::println);
  7. //抛异常,原因:Employee没有实现Comparable接口
  8. // List<Employee> employees = EmployeeData.getEmployees();
  9. // employees.stream().sorted().forEach(System.out::println);
  10. // sorted(Comparator com)——定制排序
  11. List<Employee> employees = EmployeeData.getEmployees();
  12. employees.stream().sorted( (e1,e2) -> {
  13. int ageValue = Integer.compare(e1.getAge(),e2.getAge());
  14. if(ageValue != 0){
  15. return ageValue;
  16. }else{
  17. return -Double.compare(e1.getSalary(),e2.getSalary());
  18. }
  19. }).forEach(System.out::println);
  20. }

4.5. Stream的终止操作

4.5.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 使用内部迭 代——它帮你把迭代做了)

  1. //1-匹配与查找
  2. @Test
  3. public void test1(){
  4. List<Employee> employees = EmployeeData.getEmployees();
  5. // allMatch(Predicate p)——检查是否匹配所有元素。
  6. // 练习:是否所有的员工的年龄都大于18
  7. boolean allMatch = employees.stream().allMatch(e -> e.getAge() > 18);
  8. System.out.println(allMatch);
  9. // anyMatch(Predicate p)——检查是否至少匹配一个元素。
  10. // 练习:是否存在员工的工资大于 10000
  11. boolean anyMatch = employees.stream().anyMatch(e -> e.getSalary() > 10000);
  12. System.out.println(anyMatch);
  13. // noneMatch(Predicate p)——检查是否没有匹配的元素。
  14. // 练习:是否存在员工姓“雷”
  15. boolean noneMatch = employees.stream().noneMatch(e -> e.getName().startsWith("雷"));
  16. System.out.println(noneMatch);
  17. // findFirst——返回第一个元素
  18. Optional<Employee> employee = employees.stream().findFirst();
  19. System.out.println(employee);
  20. // findAny——返回当前流中的任意元素
  21. Optional<Employee> employee1 = employees.parallelStream().findAny();
  22. System.out.println(employee1);
  23. }
  24. @Test
  25. public void test2(){
  26. List<Employee> employees = EmployeeData.getEmployees();
  27. // count——返回流中元素的总个数
  28. long count = employees.stream().filter(e -> e.getSalary() > 5000).count();
  29. System.out.println(count);
  30. // max(Comparator c)——返回流中最大值
  31. // 练习:返回最高的工资:
  32. Stream<Double> salaryStream = employees.stream().map(e -> e.getSalary());
  33. Optional<Double> maxSalary = salaryStream.max(Double::compare);
  34. System.out.println(maxSalary);
  35. // min(Comparator c)——返回流中最小值
  36. // 练习:返回最低工资的员工
  37. Optional<Employee> employee = employees.stream().min((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()));
  38. System.out.println(employee);
  39. System.out.println();
  40. // forEach(Consumer c)——内部迭代
  41. employees.stream().forEach(System.out::println);
  42. //使用集合的遍历操作
  43. employees.forEach(System.out::println);
  44. }

4.5.2. 归约

reduce(T iden, BinaryOperator b) 可以将流中元素反复结合起来,得到一 个值。返回 T

reduce(BinaryOperator b) 可以将流中元素反复结合起来,得到一 个值。返回 Optional

  1. //2-归约
  2. @Test
  3. public void test3(){
  4. // reduce(T identity, BinaryOperator)——可以将流中元素反复结合起来,得到一个值。返回 T
  5. // 练习1:计算1-10的自然数的和
  6. List<Integer> list = Arrays.asList(1,2,3,4,5,6,7,8,9,10);
  7. Integer sum = list.stream().reduce(0, Integer::sum);
  8. System.out.println(sum);
  9. // reduce(BinaryOperator) ——可以将流中元素反复结合起来,得到一个值。返回 Optional<T>
  10. // 练习2:计算公司所有员工工资的总和
  11. List<Employee> employees = EmployeeData.getEmployees();
  12. Stream<Double> salaryStream = employees.stream().map(Employee::getSalary);
  13. // Optional<Double> sumMoney = salaryStream.reduce(Double::sum);
  14. Optional<Double> sumMoney = salaryStream.reduce((d1,d2) -> d1 + d2);
  15. System.out.println(sumMoney.get());
  16. }

4.5.3. 收集

collect(Collector c) 将流转换为其他形式。接收一个 Collector 接口的实现,用于给Stream中元素做汇总 的方法。Collector需要使用Collectors提供实例

12 Java 8新特性 - 图5

  1. //3-收集
  2. @Test
  3. public void test4(){
  4. // collect(Collector c)——将流转换为其他形式。接收一个 Collector接口的实现,用于给Stream中元素做汇总的方法
  5. // 练习1:查找工资大于6000的员工,结果返回为一个List或Set
  6. List<Employee> employees = EmployeeData.getEmployees();
  7. List<Employee> employeeList = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toList());
  8. employeeList.forEach(System.out::println);
  9. System.out.println();
  10. Set<Employee> employeeSet = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toSet());
  11. employeeSet.forEach(System.out::println);
  12. }

5. Optional类

Optional类:为了在程序中避免出现空指针异常而创建的。Optional 类(java.util.Optional) 是一个容器类,它可以保存类型T的值,代表 这个值存在。或者仅仅保存null,表示这个值不存在。原来用 null 表示一个值不 存在,现在 Optional 可以更好的表达这个概念。并且可以避免空指针异常。

5.1. 常用方法

5.1.1. 创建Optional类对象的方法

Optional.of(T t) : 创建一个 Optional 实例,t必须非空; 否则会报错

Optional.empty() : 创建一个空的 Optional 实例

Optional.ofNullable(T t):t可以为null

  1. /*
  2. Optional.of(T t) : 创建一个 Optional 实例,t必须非空;
  3. Optional.empty() : 创建一个空的 Optional 实例
  4. Optional.ofNullable(T t):t可以为null
  5. */
  6. @Test
  7. public void test1(){
  8. Girl girl = new Girl();
  9. // girl = null;
  10. //of(T t):保证t是非空的
  11. Optional<Girl> optionalGirl = Optional.of(girl);
  12. }
  13. @Test
  14. public void test2(){
  15. Girl girl = new Girl();
  16. // girl = null;
  17. //ofNullable(T t):t可以为null
  18. Optional<Girl> optionalGirl = Optional.ofNullable(girl);
  19. System.out.println(optionalGirl);
  20. //orElse(T t1):如果单前的Optional内部封装的t是非空的,则返回内部的t.
  21. //如果内部的t是空的,则返回orElse()方法中的参数t1.
  22. Girl girl1 = optionalGirl.orElse(new Girl("赵丽颖"));
  23. System.out.println(girl1);
  24. }

5.1.2. 判断Optional容器中是否包含对象

boolean isPresent() : 判断是否包含对象

void ifPresent(Consumer consumer) :如果有值,就执行Consumer 接口的实现代码,并且该值会作为参数传给它。

  1. @Test
  2. public void test1(){
  3. //empty():创建的Optional对象内部的value = null
  4. Optional<Object> op1 = Optional.empty();
  5. if(!op1.isPresent()){//Optional封装的数据是否包含数据
  6. System.out.println("数据为空");
  7. }
  8. System.out.println(op1);
  9. System.out.println(op1.isPresent());
  10. //如果Optional封装的数据value为空,则get()报错。否则,value不为空时,返回value.
  11. // System.out.println(op1.get());
  12. }

5.1.3. 获取Optional容器的对象

T get(): 如果调用对象包含值,返回该值,否则抛异常

T orElse(T other) :如果有值则将其返回,否则返回指定的other对象。

T orElseGet(Supplier other) :如果有值则将其返回,否则返回由 Supplier接口实现提供的对象。

T orElseThrow(Supplier exceptionSupplier) :如果有值则将其返 回,否则抛出由Supplier接口实现提供的异常。

  1. @Test
  2. public void test2(){
  3. String str = "hello";
  4. // str = null;
  5. //of(T t):封装数据t生成Optional对象。要求t非空,否则报错。
  6. Optional<String> op1 = Optional.of(str);
  7. //get()通常与of()方法搭配使用。用于获取内部的封装的数据value
  8. String str1 = op1.get();
  9. System.out.println(str1);
  10. }
  11. @Test
  12. public void test3(){
  13. String str = "beijing";
  14. str = null;
  15. //ofNullable(T t) :封装数据t赋给Optional内部的value。不要求t非空
  16. Optional<String> op1 = Optional.ofNullable(str);
  17. //orElse(T t1):如果Optional内部的value非空,则返回此value值。如果
  18. //value为空,则返回t1.
  19. String str2 = op1.orElse("shanghai");
  20. System.out.println(str2);//
  21. }

5.2. 基本使用

  1. public String getGirlName(Boy boy){
  2. return boy.getGirl().getName();
  3. }
  4. @Test
  5. public void test3(){
  6. Boy boy = new Boy();
  7. boy = null;
  8. String girlName = getGirlName(boy);
  9. System.out.println(girlName);
  10. }
  11. //优化以后的getGirlName():
  12. public String getGirlName1(Boy boy){
  13. if(boy != null){
  14. Girl girl = boy.getGirl();
  15. if(girl != null){
  16. return girl.getName();
  17. }
  18. }
  19. return null;
  20. }
  21. @Test
  22. public void test4(){
  23. Boy boy = new Boy();
  24. boy = null;
  25. String girlName = getGirlName1(boy);
  26. System.out.println(girlName);
  27. }
  28. //使用Optional类的getGirlName():
  29. public String getGirlName2(Boy boy){
  30. Optional<Boy> boyOptional = Optional.ofNullable(boy);
  31. //此时的boy1一定非空
  32. Boy boy1 = boyOptional.orElse(new Boy(new Girl("迪丽热巴")));
  33. Girl girl = boy1.getGirl();
  34. Optional<Girl> girlOptional = Optional.ofNullable(girl);
  35. //girl1一定非空
  36. Girl girl1 = girlOptional.orElse(new Girl("古力娜扎"));
  37. return girl1.getName();
  38. }
  39. @Test
  40. public void test5(){
  41. Boy boy = null;
  42. boy = new Boy();
  43. boy = new Boy(new Girl("苍老师"));
  44. String girlName = getGirlName2(boy);
  45. System.out.println(girlName);
  46. }