Stream是Java 8提出了的一种新的对集合对象功能的增强。它集合Lambda表达式,对集合提供了一些非常便利,高效的操作,使得代码具有非常高的可读性,优雅性!!举个例子来说,它就像一个流水线操作,对输入流水线的东西(水果)进行一系列加工处理,最后获取到我们需要的某种特殊的水果(没有洗过的苹果)。
Stream提供了对集合的便捷化处理方式
声明式编程的思想
代码更加优雅,简洁,不信往下看→_→
来个例子来看看Stream风格上海从今年7月1号开始,进行了史无前例的垃圾分类,先看个图图,下图是上海最近流行的挎包(捂脸笑哭),怕不怕,哈哈。
闲话不多说,进入正题,现在需要将一堆垃圾List<Garbage> garbages分类处理。
使用了Stream的代码风格
//有一堆没分类的垃圾 List<Garbage> garbage = new ArrayList<>(); //通过 Java 8 提供的流优雅的处理下,瞧好喽 List<Garbage> 干垃圾 = garbage.stream() //1. 垃圾倒出来,放到流水线 .filter(x -> "挑出有害垃圾") //2. 挑出有害垃圾 .filter(x -> "挑出可回收垃圾") //3. 挑出可回收垃圾 .filter(x -> "挑出有害垃圾") //4. 挑出有害垃圾 .collect(Collectors.toList()); //5. 把剩下的干垃圾装到干垃圾桶 /** 上面是不是非常优雅呢 **/ 二. Stream 的操作流程Stream的所有操作分为三个阶段,【创建】>> 【中间操作】>> 【终端操作】
1. Stream 的【创建】
方式一
list.stream()
//通过List集合创建 List<String> list = Arrays.asList("1", "2", "3"); //list.stream() Stream<String> stream = list.stream();
方式二
Stream.of()
//直接通过指定的元素创建 Stream<String> stream = Stream.of("1", "2", "3"); //通过数组Array String[] arrays = {"a", "b", "c"}; Stream<String> stream = Stream.of(arrays); //和上面区别不大 Stream<String> stream1 = Arrays.stream(arrays);其他
数值流的操作
对于基本数值型,目前有三种对应的包装类型 Stream:
下面式常用的中间操作
Stream Operation | Goal | Input
:--:|:--:|:--:
filter | filter 方法用于通过设置的条件过滤出元素。 | 条件(返回布尔值)Predicate
map | map 方法用于映射每个元素到对应的结果 | 可以是一个功能 Function
limit | limit 方法用于获取指定数量的流 | int值
sorted | sorted 方法用于对流进行排序 | Comparator
distinct | 去除重复 | --
parallel | parallelStream 是流并行处理程序的代替方法 | --
... | ... | ...
filter 统计空字符串的个数
List<String>strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl"); // 获取空字符串的数量 int count = strings.stream().filter(string -> string.isEmpty()).count()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());limit使用 limit 方法打印出 10 条数据
Random random = new Random(); random.ints().limit(10).forEach(System.out::println);sorted使用 sorted 方法对输出的 10 个随机数进行排序
Random random = new Random(); random.ints().limit(10).sorted().forEach(System.out::println);distinct使用 distinct 对元素进行去重
List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5); numbers.stream().distinct().forEach(System.out::println);parallel 使用 parallelStream 来输出空字符串的数量
List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl"); // 获取空字符串的数量 int count = strings.parallelStream().filter(string -> string.isEmpty()).count(); 3. 【终端操作】 Stream Operation Goal Input Or OutputforEach 遍历元素 其他操作
count 统计元素个数 --
collect 聚合操作 --
forEach遍历打印
Stream.of("a", "b", "c").forEach(System.out::println);count统计'a'的数量
long count = Stream.of("a", "b", "c", "a").filter(x -> "a".equals(x)).count();//2collect聚合
// 1. 聚合转成List List<String> list1 = stream.collect(Collectors.toList()); List<String> list2 = stream.collect(Collectors.toCollection(ArrayList::new)); // 2. 聚合转成Set Set set1 = stream.collect(Collectors.toSet()); Stack stack1 = stream.collect(Collectors.toCollection(Stack::new)); // 3. 聚合转成String String str = stream.collect(Collectors.joining()).toString(); // 4. ···其他 三. 简单说下声明式编程