Lamda 使用案例(一)
2023-12-30 13:47:49
文章目录
Collect 集合处理
Collectors 提供数据统计的静态方法
对集合进行数据统计,进行计数、平均值、最值、求和
计数:count
平均值:averagingInt、averagingLong、averagingDouble
最值:maxBy、minBy
求和:summingInt、summingLong、summingDouble
统计以上所有:summarizingInt、summarizingLong、summarizingDouble
//案例:统计员工人数、平均工资、工资总额、最高工资。
public static void main(String[] args) {
List<Person> person = Person.getPerson();
求总数
Long count = person.stream().collect(Collectors.counting());
//求平均工资
Double averageSalary = person.stream().collect(Collectors.averagingDouble(Person::getSalary));
//求最高工资
Optional<Integer> maxSalary = person.stream().map(Person::getSalary).collect(Collectors.maxBy(Integer::compare));
// 求工资之和
Integer sum = person.stream().collect(Collectors.summingInt(Person::getSalary));
// 一次性统计所有信息
DoubleSummaryStatistics summarizingSalary = person.stream().collect(Collectors.summarizingDouble(Person::getSalary));
System.out.println("员工总数:"+count);
System.out.println("平均工资:"+averageSalary);
System.out.println("最高工资:"+maxSalary.get());
System.out.println("员工工资之和:"+sum);
System.out.println("一次性统计员工工资之和:"+summarizingSalary);
}
Joining 将stream中元素使用特定连接符拼接,没有则直接连接
public static void main(String[] args) {
List<Person> person = Person.getPerson();
//使用,链接所有员工姓名
String mans = person.stream().map(Person::getName).collect(Collectors.joining(","));
System.out.println("公司所有员工:"+mans);
//拼接字符串
List<String> strings = Arrays.asList("A", "B", "C", "D");
String collect = strings.stream().collect(Collectors.joining("-"));
System.out.println(collect);
}
分区和分组
分区:按条件将stream分为两个Map,
分组:将集合分为多个map
public static void main(String[] args) {
List<Person> person = Person.getPerson();
// 将员工按薪资是否高于8000分组
Map<Boolean, List<Person>> collect = person.stream().collect(Collectors.partitioningBy(x -> x.getSalary() > 8000));
// 将员工按性别分组
Map<String, List<Person>> collect1 = person.stream().collect(Collectors.groupingBy(Person::getSex));
// 将员工先按性别分组,再按地区分组
Map<String, Map<String, List<Person>>> collect2 = person.stream().collect(Collectors.groupingBy(Person::getSex, Collectors.groupingBy(Person::getArea)));
System.out.println("员工薪资是否高于八千分组:" + collect);
System.out.println("员工性别分组:" + collect1);
System.out.println("员工性别、地区分组:" + collect2);
}
Collectors类提供的reducing方法,相比于stream本身的reduce方法,增加了对自定义归约的支持
public static void main(String[] args) {
/**
* 计算员工扣税后薪资总和
* */
List<Person> person = Person.getPerson();
// 每个员工减去起征点后的薪资之和---Collectors.reducing()方式
Integer sumWithout = person.stream().collect(Collectors.reducing(0,Person::getSalary, (x, y) -> (x + y - 5000)));
System.out.println("员工扣税后薪资总和"+sumWithout);
//使用stream的reduce方式
Optional<Integer> sumSalary = person.stream().map(Person::getSalary).reduce(Integer::sum);
System.out.println("员工薪资总和" + sumSalary.get());
}
收集流处理后元素
public static void main(String[] args) {
/**
* 收集流处理后元素
* 对集合数据对2取余为0的数值分别收集为list和set--set不可重复,6对应的只会存储一份
* */
List<Integer> list = Arrays.asList(1, 6, 3, 4, 6, 7, 9, 6, 20);
List<Integer> collect = list.stream().filter(x -> x % 2 == 0).collect(Collectors.toList());
Set<Integer> set = list.stream().filter(x -> x % 2 == 0).collect(Collectors.toSet());
collect.stream().forEach(System.out::println);
set.stream().forEach(System.out::print);
//员工工资大于8000的姓名和对应属性map
Map<String, Person> map = Person.getPerson().stream().filter(x -> x.getSalary() > 8000).collect(Collectors.toMap(Person::getName, p -> p));
System.out.println(map);
}
Filter 筛选器
FilterAndColl
筛选工资高于8000的人,并形成新的集合。形成新集合依赖collect
public static void main(String[] args) {
List<Person> persons = Person.getPerson();
List<String> collect = persons.stream().filter(x -> x.getSalary() > 7500).map(Person::getName).collect(Collectors.toList());
System.out.print("高于8000的员工姓名:" + collect);
}
Foreach_find_match
Stream支持类似集合的遍历和匹配元素,Stream中的元素以Optional类型存在
public static void main(String[] args) {
List<Integer> list = Arrays.asList(7, 6, 9, 3, 8, 2, 1);
// 遍历输出符合条件的元素
list.stream().filter(x -> x > 6).forEach(System.out::println);
// 匹配第一个
Optional<Integer> findFirst = list.stream().filter(x -> x > 6).findFirst();
// 匹配任意(适用于并行流)
Optional<Integer> findAny = list.parallelStream().filter(x -> x > 6).findAny();
// 是否包含符合特定条件的元素
boolean anyMatch = list.stream().anyMatch(x -> x < 6);
System.out.println("匹配第一个值:" + findFirst.get());
System.out.println("匹配任意一个值:" + findAny.get());
System.out.println("是否存在大于6的值:" + anyMatch);
}
Map_FlatMap
FlatMap
接收一个函数作为参数,将流中的每个值都换成另外一个流,然后把所有流连接成一个流
public static void main(String[] args) {
merge2StrList();
}
/**
* 将两个字符数组合并成一个新的字符数组
* */
public static void merge2StrList(){
List<String> srcList = Arrays.asList("o,o,p,s", "21,11,51,42");
List<String> desList = srcList.stream().flatMap(s -> {
//将集合的每个元素转化成一个stream流
String[] split = s.split(",");
Stream<String> stream = Arrays.stream(split);
return stream;
}).collect(Collectors.toList());
System.out.println("转换前的集合:" + srcList);
System.out.println("转换后的集合:" + desList);
}
Map
接收一个函数作为参数,该函数会被应用到每个元素上,并将其映射成一个新的元素
public static void main(String[] args) {
demo1();
increaseSalary();
}
/**
* 英文字符串数组的元素全部改为大写。整数数组每个元素+3
* */
public static void demo1(){
String[] strArr = { "abcd", "bcdd", "defde", "fTr" };
final List<String> strToupper = Arrays.stream(strArr).map(String::toUpperCase).collect(Collectors.toList());
List<Integer> integers = Arrays.asList(77, 8, 45, 12, 11);
final List<Integer> addIntegers = integers.stream().map(x -> x + 3).collect(Collectors.toList());
System.out.println("都转为大写的字符串是:" + strToupper);
System.out.println("都加3的数值是:" + addIntegers);
}
/**
*将员工的薪资全部增加1000
* */
public static void increaseSalary(){
List<Person> personList = Person.getPerson();
/**
* 改变原来员工集合的方式--新旧集合中的工资都改动
* */
List<Person> personNewList = personList.stream().map(personT -> {
personT.setSalary(personT.getSalary() + 1000);
return personT;
}).collect(Collectors.toList());
System.out.println("改变原集合改动前:" + personList.get(0).getName() + "--" + personList.get(0).getSalary());
System.out.println("改变原集合改动后:" + personNewList.get(0).getName() + "--" + personNewList.get(0).getSalary());
/**
* 不改变原来员工集合的方式--旧集合中的工资未改动
* */
List<Person> personNewList2 = personList.stream().map(person -> {
Person personNew = new Person(person.getName(), 0, 0, null, null);
personNew.setSalary(person.getSalary() + 1000);
return personNew;
}).collect(Collectors.toList());
System.out.println("不改变原集合改动前:" + personList.get(0).getName() + "--" + personList.get(0).getSalary());
System.out.println("不改变原集合改动后:" + personNewList2.get(0).getName() + "--" + personNewList2.get(0).getSalary());
}
文章来源:https://blog.csdn.net/weixin_43221207/article/details/135304240
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!