当前位置：首页 > news >正文

Stream

news 来源：原创 2024/9/22 4:23:32

Stream 也叫Stream流，是Jdk8开始新增的一套API (java.util.stream.*)，可以用于操作集合或者数组的数据。

优势： Stream流大量的结合了Lambda的语法风格来编程，提供了一种更加强大，更加简单的方式操作集合或者数组中的数据，代码更简洁，可读性更好。

Stream流的使用步骤

1.获取Stream流

获取集合的 Stream 流

Collection提供的如下方法	说明
default Stream<E> stream()	获取当前集合对象的Stream流

获取数组的 Stream 流

Arrays类提供的如下方法	说明
public static <T> Stream<T> stream(T[] array)	获取当前数组的Stream流

Stream类提供的如下方法	说明
public static<T> Stream<T> of(T... values)	获取当前接收数据的Stream流

2.Stream流常见的中间方法

中间方法指的是调用完成后会返回新的 Stream 流，可以继续使用 ( 支持链式编程 ) 。

Stream提供的常用中间方法	说明
Stream<T> filter(Predicate<? super T> predicate)	用于对流中的数据进行过滤。
Stream<T> sorted()	对元素进行升序排序
Stream<T> sorted(Comparator<? super T> comparator)	按照指定规则排序
Stream<T> limit(long maxSize)	获取前几个元素
Stream<T> skip(long n)	跳过前几个元素
Stream<T> distinct()	去除流中重复的元素。
<R> Stream<R> map(Function<? super T,? extends R> mapper)	对元素进行加工，并返回对应的新流
static <T> Stream<T> concat(Stream a, Stream b)	合并a和b两个流为一个流

students.stream().filter(s -> s.getHeight() > 168).map(Student::getName).distinct().forEach(System.out::println);

Stream st1 = Stream.of("a1", "b1");
Stream st2 = Stream.of("a1", "b2", "c");
Stream allSt = Stream.concat(st1, st2);
allSt.forEach(System.out::println);

3.Stream流常见的终结方法

终结方法指的是调用完成后，不会返回新 Stream 了，没法继续使用流了。

Stream提供的常用终结方法	说明
void forEach(Consumer action)	对此流运算后的元素执行遍历
long count()	统计此流运算后的元素个数
Optional<T> max(Comparator<? super T> comparator)	获取此流运算后的最大值元素
Optional<T> min(Comparator<? super T> comparator)	获取此流运算后的最小值元素

//统计此流运算后的元素个数
long size = students.stream().filter(s -> s.getHeight() > 168).count();
System.out.println(size);//获取此流运算后的最大值元素
Student s = students.stream().max((o1, o2) -> Double.compare(o1.getHeight(), o2.getHeight())).get();
System.out.println(s);//获取此流运算后的最小值元素
Student s = students.stream().min((o1, o2) -> Double.compare(o1.getHeight(), o2.getHeight())).get();
System.out.println(s);

收集Stream流 ：就是把Stream流操作后的结果转回到集合或者数组中去返回。

Stream流：方便操作集合 / 数组的手段；

集合 / 数组：才是开发中的目的。

Stream提供的常用终结方法	说明
R collect(Collector collector)	把流处理后的结果收集到一个指定的集合中去
Object[] toArray()	把流处理后的结果收集到一个数组中去

Collectors工具类提供了具体的收集方式	说明
public static <T> Collector toList()	把元素收集到List集合中
public static <T> Collector toSet()	把元素收集到Set集合中
public static Collector toMap(Function keyMapper , Function valueMapper)	把元素收集到Map集合中

流只能收集一次；

List<Student> students1 = students.stream().filter(a -> a.getHeight() > 170).collect(Collectors.toList());Set<Student> students1 = students.stream().filter(a -> a.getHeight() > 170).collect(Collectors.toSet());Map<String, Double> map = students.stream().filter(a -> a.getHeight() >170).distinct().collect(Collectors.toMap(a -> a.getName(), a -> a.getHeight());

Object[] arr = students.stream().filter(a -> a.getHeight() > 170).toArray();Student[] arr1 = students.stream().filter(a -> a.getHeight() > 170).toArray(len -> new Student[len]);