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]);