Stream 流

用户头像
HeGuang
关注
发布于: 2020 年 08 月 22 日
Stream 流

什么是流

从支持数据处理操作的源生成的元素序列

流与集合的区别

  • 时间和空间

从流和集合的定位来看,集合面向的是存储,而流面向的是计算,比如说要构建一个质数集合,那理论上来说是构建不出来的,因为质数是无穷大的,不可穷举,而构建一个质数流是可行的,因为只要在使用的时候实时计算出这个质数就可以了,从这个角度来说,本质上说还是时间和空间的区别

  • 只能遍历一次

集合可以遍历多次,而流是一个空间上的概念,再次遍历会出现异常

List<String> names=Arrays.asList("Tom","Jim","Joe");
names.forEach(System.out::println);
names.forEach(System.out::println);
Stream<Integer> s = Stream.of(1, 2, 3, 4, 5);
s.forEach(System.out::println);
s.forEach(System.out::println);//报异常
######sout#############
Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed



  • 外部迭代和内部迭代

//集合处理方式
List<String> names1=new ArrayList<>();
for (Dish d:menu) {
names1.add(d.getName());
}
//流处理方式
List<String> names2=menu.stream().map(Dish::getName).collect(toList());



两者的处理方式很直观。集合使用foreach外部迭代,而流是内部迭代的方式。也就是流帮你处理了。

流的组成



流的组成



流操作分类



如何理解?比如有状态操作,dictinct 去重,一定是等到所有数据就位后,在所有数据的基础上进行去重,而像 filter 只要对单个的数据(对象)进行操作就好了,并不需要等所有数据;短路操作,比如 findFirst,只要找到第一个元素直接返回结果,不管后面还有多少元素,而像 foreach 循环,每个数据都要执行一次,非短路对吧。



流的使用





flatMap 使用:将多维嵌套列表转换为单维列表,或者将多个列表合成一个列表



List<String> first= Arrays.asList("one", "two", "three", "four");
List<String> second= Arrays.asList("A", "B", "C", "D");
Stream.of(first,second).flatMap(Collection::stream).forEach(System.out::print);



List<String> list1 = Arrays.asList("aa", "bb", "cc");
List<String> list2 = Arrays.asList("11", "22", "33");
List<List<String>> list = Arrays.asList(list1,list2);
List<String> collect = list.stream().flatMap(item -> item.stream()).collect(Collectors.toList());
System.out.println(collect);



Stream 流的构建



//由数值直接构建流
Stream<Integer> integerStream = Stream.of(1, 2, 3, 4, 5);
integerStream.forEach(System.out::println);
//数组构建流
IntStream stream = Arrays.stream(new int[]{1, 2, 3, 4, 5});
stream.forEach(System.out::println);
//通过文件构建流
Stream<String> lines = Files.lines(Paths.get("D:\\NewIOClient.java"));
lines.forEach(System.out::println);
//函数生成流,如果不加限制,会无限生成
Stream<Integer> iterate = Stream.iterate(0, n -> n + 2).limit(3);
iterate.forEach(System.out::println);
Stream<Double> generate = Stream.generate(Math::random);
generate.limit(10).forEach(System.out::println);



预定义收集器



collect(Collectors.toList)、collect(Collectors.toSet)、collect(Collectors.toMap) 这些不说了,更多的功能请看Collectors 类

// Map<分组条件,结果集合>
Map<Object, List<User>> map = list.stream.collect(Collectors.groupingBy(user->user.getSex()));
// 分区
Map<Boolean, List<User>> map = list.stream.collect(Collectors.partitionBy(user->user.getAge()>100));



发布于: 2020 年 08 月 22 日 阅读数: 38
用户头像

HeGuang

关注

不要问我捷径在哪里,捷径只在深夜的孤独中 2018.09.28 加入

还未添加个人简介

评论

发布
暂无评论
Stream 流