超级实习生计划学习打卡—

学习内容

流式计算
Stream，也就是流，也叫做流式计算。利用 Steam ，可以让 java 以声明性地迭代方式处理集合。

元素是特定类型的对象，形成一个队列。 Stream并不会存储元素，而是按需计算。

流的来源可以是集合，数组等。

两大特征
Pipelining: 中间操作都会返回流对象本身。这样多个操作可以串联成一个管道，如同流式风格（fluent style）。这样做可以对操作进行优化，比如延迟执行(laziness)和短路( short-circuiting)。

内部迭代：以前对集合遍历都是通过Iterator或者增强for的方式, 显式的在集合外部进行迭代，这叫做外部迭代。 Stream提供了内部迭代的方式，流可以直接调用遍历方法。

两大操作
Java8 的 Stream API 中定义了两大类流式操作，一种是中间操作，一种是终端操作。

所谓中间操作，就是类似于流水线上，给上游工序做一些加工和包装，然后再传给自己的下游工序。同样的道理，中间操作流会返回另一个流对象，这个流对象的数据是需要继续传递给后面的流操作处理的。

终端操作就是真正结果的操作，类似于流水线上最后一道工序。

获取流的方式
所有的 Collection 集合都可以通过 stream 默认方法获取流；
Stream 接口的静态方法 of 可以获取数组对应的流。
flatMap 方法
使用flatMap方法的效果是，各个数组并不是分别映射一个流，而是映射成流的内容，所有使用生成的单个流被合并起来，即扁平化为一个流。

例如，将流1：{"H","e","l","l","o"} 与流2：{"W","o","r","l","d"} 用普通方式合并，结果为：{"H","e","l","l","o","W","o","r","l","d"}。

用 flatMap 合并，其结果为：{"H","e","l","o","W","r","d"} 。

工作内容
任务1
除了消费型函数式接口，从搜索引擎或 CSDN 上再分别找一些供给型、映射型和预测型函数式接口的实际应用例子。

package com.xxm.advanced_camp.mission12_FunctionalParadigm;import java.util.Locale;
import java.util.function.*;public class TestTask2 {public static void main(String[] args) {//供给型int arr[] = {24, 12, 34, 87, 5};int maxNum = getMax(() -> {int max = arr[0];for (int x : arr) {if (x > max) {max = x;}}return max;});System.out.println("供给型函数接口测试。数组最大值为：" + maxNum);//消费型printString(s -> System.out.println(s));//映射型toUpper(s -> s.toUpperCase());//预测型lenthLongerThanThree(s -> s.length() > 3);}//供给型，方法public static int getMax(Supplier<Integer> supplier) {return supplier.get();}//消费型，方法public static void printString(Consumer<String> consumer) {consumer.accept("消费型接口测试：HelloWorld");}//映射型，方法public static String toUpper(UnaryOperator<String> function) {String s = function.apply("映射型接口测试：HelloWorld");System.out.println(s);return s.toUpperCase();}//预测型，方法public static void lenthLongerThanThree(Predicate<String> predicate) {boolean longer = predicate.test("HelloWorld");System.out.println("预测型接口测试。字符串 HelloWorld 的长度大于 3 吗？" + longer);}
}

输出结果为：

供给型函数接口测试。数组最大值为：87
消费型接口测试：HelloWorld
映射型接口测试：HELLOWORLD
预测型接口测试。字符串 HelloWorld 的长度大于 3 吗？true

任务2

实现如下需求：统计公司类型为 BIG 的所有未婚员工，同时按年龄排序，并且未婚员工不区分公司，也就是最终结果放在一个列表中（提示：整个需求可以用一行代码完成）

package com.xxm.advanced_camp.mission13_stream;import java.util.*;
import java.util.function.Supplier;
import java.util.stream.Collectors;
import java.util.stream.Stream;public class Task1 {public static void main(String[] args) {List<Company<Employee>> list = new ArrayList<>();List<Employee> employees = Arrays.asList(new Employee("张勇", "男", 28, true, Employee.Type.MANAGER),new Employee("李强", "男", 22, false, Employee.Type.SELLER),new Employee("王武", "男", 32, false, Employee.Type.SELLER),new Employee("梅丽", "女", 26, true, Employee.Type.OFFICER),new Employee("郑帅", "男", 29, false, Employee.Type.OFFICER),new Employee("曾美", "女", 27, true, Employee.Type.SELLER),new Employee("郝俊", "男", 22, true, Employee.Type.SELLER),new Employee("方圆", "女", 24, false, Employee.Type.SELLER));Company<Employee> moubao = new Company<Employee>("某宝", Company.Type.BIG, employees);employees = Arrays.asList(new Employee("吴琼", "女", 27, true, Employee.Type.SELLER),new Employee("陈辰", "女", 20, false, Employee.Type.OFFICER),new Employee("刘能", "男", 25, true, Employee.Type.OFFICER),new Employee("周七", "男", 29, false, Employee.Type.OFFICER),new Employee("汪旺", "男", 21, false, Employee.Type.OFFICER),new Employee("胡涂", "男", 27, false, Employee.Type.OFFICER),new Employee("杨茂", "男", 34, true, Employee.Type.MANAGER),new Employee("朱坚", "男", 30, false, Employee.Type.MANAGER));Company<Employee> mouxin = new Company<>("某东", Company.Type.BIG, employees);employees = Arrays.asList(new Employee("冯过", "男", 35, false, Employee.Type.SELLER),new Employee("何花", "女", 27, false, Employee.Type.MANAGER),new Employee("卫精", "男", 25, true, Employee.Type.OFFICER),new Employee("施工", "男", 28, false, Employee.Type.OFFICER),new Employee("沈月", "女", 24, false, Employee.Type.OFFICER),new Employee("乐欢", "女", 22, false, Employee.Type.OFFICER),new Employee("安全", "男", 33, true, Employee.Type.MANAGER),new Employee("林森", "男", 26, true, Employee.Type.SELLER));Company<Employee> mouhaha = new Company<>("某哈哈", Company.Type.SMALL, employees);list.add(moubao);list.add(mouxin);list.add(mouhaha);List<Employee> result = list.stream().flatMap(company -> company.getEmployees().stream()).filter(employee -> !employee.isMarried()).sorted(Comparator.comparing(Employee::getAge)).collect(Collectors.toList());for (Employee emp : result) {System.out.println(emp.toString());}}
}

超级实习生计划学习打卡——流式计算相关推荐

CSDN超级实习生计划学习打卡—— Ipv6
一.学习目标理解IPv6的表示方法和地址类型二.学习背景在IPv4诞生的时代,是无法预见今日互联网的繁荣程度的,因此很多设计问题在发展的过程中也逐渐暴露出来,例如分类不合理,可用的公网IP地址总 ...
CSDN超级实习生计划——大厂实习直通车，年薪最高可达30W。2022正式开启~
一.CSDN超级实习生计划是什么? 2022届高校毕业生规模预计1076万人,同比增加167万人.这是高校毕业生规模首次超过千万,也是近几年增长人数最多的一年.1076万大学生就业的压力急剧暴增,也将 ...
java学习笔记20（Lambda表达式、函数式编程、流式计算、练习）
文章目录 11.3 学习内容 Lambda表达式 Lambda标准格式格式说明省略规则使用前提函数式接口预定义的函数式接口工作内容任务1 总结&明日计划 11.4 学习内容流式 ...
内推名企实习，就来CSDN超级实习生计划，2022年名企实习内推开始发车
一份拿得出手的大厂实习经验有多重要? 对没有经验的大二.大三学生来说:这是为自身真实能力背书,是拓宽视野,结交人脉的好机会,更是为以后拿到互联网大厂offer奠定基础. 对秋招失利/错过秋招的应届生来 ...
2022年超级实习生计划冲刺IT名企offer，9大高薪技巧助力名企梦
CSDN推出超级实习生训练计划,属于名企内推直通保offer计划,本科毕业年薪可达30W+,除了获得名企实习offer之外,超级实习生们还能提升项目工程化交付能力. 加入超级实习生训练计划你可以获得什 ...
流式计算strom,Strom解决的问题,实现实时计算系统要解决那些问题,离线计算是什么,流式计算什么,离线和实时计算区别,strom应用场景,Strorm架构图和编程模型（来自学习资料）
1.背景-流式计算与storm 2011年在海量数据处理领域,Hadoop是人们津津乐道的技术,Hadoop不仅可以用来存储海量数据,还以用来计算海量数据.因为其高吞吐.高可靠等特点,很多互联网公司都 ...
有人参加过CSDN超级实习生计划吗？靠谱吗？
CSDN近期推出了超级实习生计划,相比市面上同类型实习类产品,超级实习生计划服务群体范围更小一些,主要服务于有志于从事IT行业的大学生们,专做IT赛道实习就业产品.那么至今为止有人参加过CSDN超级实 ...
Steram流式计算学习笔记
Steram流式计算一.概述说到Stream便容易想到 I/O Stream,而实际上,谁规定"流"就一定是"I0流"呢 ?在Java 8中,得益于Lamb ...
付费内推实习是“割韭菜”吗？超级实习生计划也是吗？
近期知名企业发布的2021年反舞弊通报中,有员工利用职权招收实习生并安排虚假远程实,从中获得了实习费用,虽然相关人员已受到想用处罚,但是去一些平台搜索"付费内推实习",价位从100 ...

超级实习生计划学习打卡——流式计算

学习内容

任务2

超级实习生计划学习打卡——流式计算相关推荐

最新文章

热门文章