Stream的终止操作
终端操作会从流的流水线生成结果。其结果可以是任何不是流的值，例如: List、Integer、甚至是 void。
流进行了终止操作后,不能再次使用。
方法 描述 allMatch(Predicate p) 检查是否匹配所有元素 anyMatch(Predicate p) 检查是否至少匹配一个元素 noneMatch(Predicate p) 检查是否没有匹配所有元素 findFirst() 返回第一个元素 findAny() 返回当前流中的任意元素
StreamAPITest2.java
package com.klvchen.java3;
import com.klvchen.java2.Employee;
import com.klvchen.java2.EmployeeData;
import org.junit.Test;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class StreamAPITest2 {
//1-匹配与查询
@Test
public void test1(){
List<employee> employees = EmployeeData.getEmployees();
// allMatch(Predicate p) — 检查是否匹配所有元素。
// 练习:是否所有的员工的年龄都大于18
boolean allMatch = employees.stream().allMatch(e -> e.getAge() > 18);
System.out.println(allMatch);
// anyMatch(Predicate p) — 检查是否至少匹配一个元素。
// 练习:是否存在员工的工资大于10000
boolean anyMatch = employees.stream().anyMatch(e -> e.getSalary() > 10000);
System.out.println(anyMatch);
// noneMatch(Predicate p) — 检查是否没有匹配的元素。
// 练习:是否存在员工姓“雷”
boolean noneMatch = employees.stream().noneMatch(e -> e.getName().startsWith("雷"));
System.out.println(noneMatch);
//findFirst — 返回第一个元素
Optional<employee> employee = employees.stream().findFirst();
System.out.println(employee);
//findAny — 返回当前流中的任意元素
Optional<employee> employee1 = employees.parallelStream().findAny();
System.out.println(employee1);
}
@Test
public void test2(){
List<employee> employees = EmployeeData.getEmployees();
// count —— 返回流中元素的总个数
long count = employees.stream().filter(e -> e.getSalary() > 5000).count();
System.out.println(count);
// max(Comparator c) — 返回流中最大值
// 练习:返回最高的工资:
Stream<double> salaryStream = employees.stream().map(e -> e.getSalary());
Optional<double> maxSalary = salaryStream.max(Double::compare);
System.out.println(maxSalary);
// min(comparator c)—返回流中最小值
// 练习:返回最低工资的员工
Optional<employee> employee = employees.stream().min((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()));
System.out.println(employee);
System.out.println();
// forEach(consumer c) — 内部迭代
employees.stream().forEach(System.out::println);
System.out.println();
// 使用集合的遍历操作
employees.forEach(System.out::println);
}
//2-归约
@Test
public void test3(){
// reduce(T identity, BinaryOperator) — 可以将流中元素反复结合起来，得到一个值。返回
// 练1:计算1-10的自然数的和
List<integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
Integer sum = list.stream().reduce(0, Integer::sum);
System.out.println(sum);
// reduce(Binary0perator) 一 可以将流中元素反复结合起来，得到一个值。返回Optional
// 练习2:计算公司所有员工工资的总和
List<employee> employees = EmployeeData.getEmployees();
Stream<double> salaryStream = employees.stream().map(Employee::getSalary);
//Optional<double> sumMoney = salaryStream.reduce(Double::sum);
Optional<double> sumMoney = salaryStream.reduce((d1, d2) -> d1 + d2);
System.out.println(sumMoney);
}
//3-收集
@Test
public void test4(){
// collect(collector c) — 将流转换为其他形式。接收一个 Collector 接口的实现，用于给Stream
// 练习1:查找工资大于6000的员工，结果返回为一个 List 或 Set
List<employee> employees = EmployeeData.getEmployees();
List<employee> employeeList = employees.stream().filter( e -> e.getSalary() > 6000).collect(Collectors.toList());
employeeList.forEach(System.out::println);
System.out.println();
Set<employee> employeeSet = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toSet());
employeeSet.forEach(System.out::println);
}
}
</employee></employee></employee></double></double></double></employee></integer></employee></double></double></employee></employee></employee></employee>
Original: https://www.cnblogs.com/klvchen/p/15733139.html
Author: klvchen
Title: Java 基础(Stream APl) 二
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/537535/
转载文章受原作者版权保护。转载请注明原作者出处！