Terminal:一个流只能有一个 terminal 操作,当这个操作执行后,流就被使用“光”了,无法再被操作。 所以这必定是流的最后一个操作。 Terminal操作的执行,才会真正开始流的遍历,并且会生成一个结果,或者一个 side effect。
Stream使用这里我们依旧使用一个简单示例来看看吧。
在开发中,我们有时需要对一些数据进行过滤,如果是传统的方式,我们需要对这批数据进行遍历过滤,会显得比较繁琐,如果使用steam流方式的话,那么可以很方便的进行处理。
首先通过普通的方式进行过滤:
List<String> list = Arrays.asList("张三", "李四", "王五", "xuwujing"); System.out.println("过滤之前:" + list); List<String> result = new ArrayList<>(); for (String str : list) { if (!"李四".equals(str)) { result.add(str); } } System.out.println("过滤之后:" + result);使用Steam方式进行过滤:
List<String> result2 = list.stream().filter(str -> !"李四".equals(str)).collect(Collectors.toList()); System.out.println("stream 过滤之后:" + result2);输出结果:
过滤之前:[张三, 李四, 王五, xuwujing] 过滤之后:[张三, 王五, xuwujing] stream 过滤之后:[张三, 王五, xuwujing]是不是很简洁和方便呢。
其实Stream流还有更多的使用方法,filter只是其中的一角而已。那么在这里我们就来学习了解下这些用法吧。
1.构造Stream流的方式
Stream stream = Stream.of("a", "b", "c"); String[] strArray = new String[] { "a", "b", "c" }; stream = Stream.of(strArray); stream = Arrays.stream(strArray); List<String> list = Arrays.asList(strArray); stream = list.stream();2.Stream流的之间的转换
注意:一个Stream流只可以使用一次,这段代码为了简洁而重复使用了数次,因此会抛出 stream has already been operated upon or closed 异常。
try { Stream<String> stream2 = Stream.of("a", "b", "c"); // 转换成 Array String[] strArray1 = stream2.toArray(String[]::new); // 转换成 Collection List<String> list1 = stream2.collect(Collectors.toList()); List<String> list2 = stream2.collect(Collectors.toCollection(ArrayList::new)); Set set1 = stream2.collect(Collectors.toSet()); Stack stack1 = stream2.collect(Collectors.toCollection(Stack::new)); // 转换成 String String str = stream.collect(Collectors.joining()).toString(); } catch (Exception e) { e.printStackTrace(); }3.Stream流的map使用
map方法用于映射每个元素到对应的结果,一对一。
示例一:转换大写
List<String> list3 = Arrays.asList("zhangSan", "liSi", "wangWu"); System.out.println("转换之前的数据:" + list3); List<String> list4 = list3.stream().map(String::toUpperCase).collect(Collectors.toList()); System.out.println("转换之后的数据:" + list4); // 转换之后的数据:[ZHANGSAN, LISI,WANGWU]示例二:转换数据类型
List<String> list31 = Arrays.asList("1", "2", "3"); System.out.println("转换之前的数据:" + list31); List<Integer> list41 = list31.stream().map(Integer::valueOf).collect(Collectors.toList()); System.out.println("转换之后的数据:" + list41); // [1, 2, 3]示例三:获取平方
List<Integer> list5 = Arrays.asList(new Integer[] { 1, 2, 3, 4, 5 }); List<Integer> list6 = list5.stream().map(n -> n * n).collect(Collectors.toList()); System.out.println("平方的数据:" + list6); // [1, 4, 9, 16, 25]4.Stream流的filter使用
filter方法用于通过设置的条件过滤出元素。
示例二:通过与 findAny 得到 if/else 的值
List<String> list = Arrays.asList("张三", "李四", "王五", "xuwujing"); String result3 = list.stream().filter(str -> "李四".equals(str)).findAny().orElse("找不到!"); String result4 = list.stream().filter(str -> "李二".equals(str)).findAny().orElse("找不到!"); System.out.println("stream 过滤之后 2:" + result3); System.out.println("stream 过滤之后 3:" + result4); //stream 过滤之后 2:李四 //stream 过滤之后 3:找不到!示例三:通过与 mapToInt 计算和
List<User> lists = new ArrayList<User>(); lists.add(new User(6, "张三")); lists.add(new User(2, "李四")); lists.add(new User(3, "王五")); lists.add(new User(1, "张三")); // 计算这个list中出现 "张三" id的值 int sum = lists.stream().filter(u -> "张三".equals(u.getName())).mapToInt(u -> u.getId()).sum(); System.out.println("计算结果:" + sum); // 75.Stream流的flatMap使用
flatMap 方法用于映射每个元素到对应的结果,一对多。