天天看点

java8新特性-Stream

简介:Java 8 API添加了一个新的抽象称为流Stream,可以让你以一种声明的方式处理数据。它支持顺序和并行聚合操作的一系列元素,大多数流都由集合,数组或生成函数支持,把这些要处理的元素集合看作一种流, 流在管道中传输, 并且可以在管道的节点上进行处理, 比如筛选, 排序,聚合等。流管线可以顺序执行,也可以在并行中执行。 此执行模式是流的属性。 流被创建为具有顺序或并行执行的初始选择。 (例如, Collection.stream()创建一个顺序流,并且Collection.parallelStream()创建一个并行的)。

优点:极大提高Java程序员的生产力,让程序员写出高效率、干净、简洁的代码。

示例介绍:

  1. 集合接口有两个方法来生成流
List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");
List<String> filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());
int count = (int) stringArr.parallelStream().filter(string -> string.isEmpty()).count();
           
  1. forEach-迭代流中的每个数据
Random random = new Random();
random.ints().limit(10).forEach(System.out::println);
           
  1. map-用于映射每个元素到对应的结果:
//使用 map 输出了元素对应的平方数:
List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
// 获取对应的平方数并去重
List<Integer> squaresList = numbers.stream().map( i -> i*i).distinct().collect(Collectors.toList());
System.out.println(squaresList);
           
  1. filter-用于通过设置的条件过滤出元素
List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");
//去除集合里的空元素
List<String> filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());
System.out.println(filtered);
           
  1. limit-用于获取指定数量的流
Random random = new Random();
random.ints().limit(10).forEach(System.out::println);
           
  1. sorted-用于对流进行排序
List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
numbers.stream().sorted().forEach(System.out::println);
           
  1. Collectors 类实现了很多归约操作,例如将流转换成集合或返回字符串
List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");
System.out.println(strings);
List<String> filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());
System.out.println(filtered);
String mergedString = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.joining(", "));
System.out.println("合并字符串: " + mergedString);
           
  1. 一些产生统计结果的收集器也非常有用,它们主要用于int、double、long等基本类型上,它们可以用来产生类似如下的统计结果
List<Integer> lists = Arrays.asList(3, 2, 2, 3, 7, 3, 5);
IntSummaryStatistics summaryStatistics = lists.stream().mapToInt(s -> s ).summaryStatistics();
System.out.println("列表中最大的数 : " + summaryStatistics.getMax());
System.out.println("列表中最小的数 : " + summaryStatistics.getMin());
System.out.println("所有数之和 : " + summaryStatistics.getSum());
System.out.println("平均数 : " + summaryStatistics.getAverage());