01.Stream API有何优势
假设有一个整形链表如下:
List<Integer> list = Arrays.asList(9, 3, 5, 6, 7, 10086, -5);
找出链表中值>=5的值,一般操作为:
List<Integer> res=new ArrayList<>();
for (int i=0;i<list.size();i++){
if(list.get(i)>=5) res.add(list.get(i));
}
Stream API操作为:
List<Integer> res = list.stream().filter(x -> x >= 5).collect(Collectors.toList());
02.Stream API详解
2.1了解Stream
Stream 是处理集合的关键抽象概念,它可以对集合进行复杂的查找、过滤和映射数据等操作。(类似于使用 SQL 执行的数据库查询)
Stream的操作步骤
- 创建Stream
- 中间操作
- 终止操作
注意事项
- Stream 不存储元素。
- Stream 不会改变源对象,而是回一个持有结果的新Stream。
- Stream 操作会等到需要结果的时候才执行。
2.2Stream API介绍
创建Stram
1.通过集合创建流
- 顺序流 : default Stream stream()
- 并行流 : default Stream parallelStream()
List<Integer> list = Arrays.asList(9, 3, 5, 6, 7, 10086, -5);
Stream<Integer> stream = list.stream();
Stream<Integer> integerStream = list.parallelStream();
2.通过数组创建
- public static Stream stream(T[] array)
Integer[] arr={9,3,5,6,7,10086,-5};
Stream<Integer> arrStream = Arrays.stream(arr);
3.通过stream创建
Integer[] arr={9,3,5,6,7,10086,-5};
Stream<Integer> arrStream2 = Stream.of(arr);
中间操作
方法 | 作用 |
---|
filter(Predicate p) | 接收 Lambda , 从流中排除某些元素 | distinct() | 通过流所生成元素的 hashCode() 和 equals() 去除重复元素 | limit(long maxSize) | 获取前maxSize数量的数据 | skip(long n) | 返回一个扔掉了前 n 个元素的流 | map(Function f) | 接收一个函数作为参数,该函数会被应用到每个元素上,并将其映射成一个新的元素。 | flatMap(Function f) | 接收一个函数作为参数,将流中的每个值都换成另一个流,然后把所有流连接成一个流 | sorted() | 按自然顺序排序 | sorted(Comparator com) | 按比较器顺序排序 |
代码演示:
List<Integer> list = Arrays.asList(9, 3, 5, 6, 7, 10086, -5,9);
list.stream().filter(x->x>5).forEach(x -> System.out.print(x+" "));
list.stream().filter(x->x>5).distinct().forEach(x -> System.out.print(x+" "));
list.stream().filter(x->x>5).skip(1).forEach(x -> System.out.print(x+" "));
list.stream().filter(x->x>5).limit(1).forEach(x -> System.out.print(x+" "));
list.stream().sorted((o1,o2)-> o2-o1).forEach(x -> System.out.print(x+" "));
list.stream().map(x->x+10).forEach(x -> System.out.print(x+" "));
List<Integer> list2=new ArrayList<>();
list2.add(-1000);
lists.add(list);
lists.add(list2);
List<List<Integer>> lists=new ArrayList<>();
List<Integer> collect = lists.stream().flatMap(new Function<List<Integer>, Stream<Integer>>() {
public Stream<Integer> apply(List<Integer> tmp) {
Stream<Integer> stream1 = tmp.stream().map(x -> x + 10);
return stream1;
}
}).collect(Collectors.toList());
System.out.println(collect);
终止操作
方法 | 返回 | 描述 |
---|
allMatch(Predicate p) | boolean | 检查是否匹配所有元素 | anyMatch(Predicate p) | boolean | 检查是否至少匹配一个元素 | noneMatch(Predicate p) | boolean | 检查是否没有匹配所有元素 | findFirst() | Optional | 返回第一个元素 | findAny() | Optional | 返回当前流中的任意元素 | collect(Collector<? super T, A, R> collector) | <R, A> R | 将流转换为其他形式。接收一个 Collector接口的实现,用于给Stream中元素做汇总的方法 | count() | long | 返回流中元素总数 | max(Comparator c) | Optional | 返回流中最大值 | min(Comparator c) | Optional | 返回流中最小值 | forEach(Consumer c) | void | 内部迭代(使用 Collection 接口需要用户去做迭代,称为外部迭代 | reduce(BinaryOperator b) | Optional | 可以将流中元素反复结合起来,得到一个值 | reduce(T identity, BinaryOperator b) | T | 可以将流中元素反复结合起来,得到一个值 |
List<Integer> list = Arrays.asList(9, 3, 5, 6, 5, 10086, -5);
System.out.println(list.stream().allMatch(e->e>12));
System.out.println(list.stream().anyMatch(e->e>12));
System.out.println(list.stream().noneMatch(e->e>=10086));
System.out.println(list.stream().noneMatch(e->e>10086));
System.out.println(list.stream().findFirst());
System.out.println(list.stream().findAny());
System.out.println(list.stream().count());
System.out.println(list.stream().max(Comparable::compareTo));
System.out.println(list.stream().collect(Collectors.toSet()));
List<Integer> list2 = Arrays.asList(9, 3,2,6);
Integer reduce = list2.stream().reduce(100, (x1, x2) -> x1 * x2);
System.out.println(reduce);
03.Stream API案例
public class Order {
private int id;
private String name;
private double price;
private int amount;
public Order(int id, String name, double price, int amount) {
this.id = id;
this.name = name;
this.price = price;
this.amount = amount;
}
}
数据
List<Order> list = new ArrayList<>();
list.add(new Order(1001, "a", 34,10));
list.add(new Order(1002, "b", 12,5));
list.add(new Order(1003, "cccc", 33,8));
list.add(new Order(1004, "d", 26,6));
list.add(new Order(1005, "eee", 65,0));
list.add(new Order(1006, "fff", 42,6));
list.add(new Order(1007, "gggggg", 26,3));
list.add(new Order(1008, "hhhhh", 35,7));
需求:查看价格大于30的订单,并将订单数据按订单数量从大到小排序
List<Order> collect = list.stream().filter(x -> x.getPrice() > 30).
sorted((o1, o2) -> o2.getAmount() - o1.getAmount()).collect(Collectors.toList());
|