Stream

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

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

Stream流的使用步骤

1.获取Stream流

Collection提供的如下方法	说明
default Stream<E> 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<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提供的常用终结方法	说明
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提供的常用终结方法	说明
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]);