ARTICLE DETAIL

资讯详情

深耕网站建设、视觉设计与SEO优化的一线实战洞察。

Stream 流

Stream 流

配合Lambda表达式,简化集合和数组的操作

文章目录

    • 一、获取Stream流对象
      • 集合
      • 数组
      • 零散的数据
    • 二、中间方法
      • filter()
      • limit(Long maxSize)
      • skip(Long n)
      • distinct()
      • concat(Stream a, Stream b)
    • 三、终结方法
      • forEach()
      • count()
    • 四、收集操作
      • collect(Collector collector)

一、获取Stream流对象

集合

Collection接口中的方法:stream()

单列:直接调用stream()
多列:间接获取,map.entrySet()

ArrayList<String> list = new ArrayList<>();
list.add("aaa");
list.add("bbb");
list.add("ccc");list.stream().forEach(s -> System.out.println(s));
Map<String, Integer> map = new HashMap<>();
map.put("aaa", 10);
map.put("bbb", 20);
map.put("ccc", 30);Set<Map.Entry<String, Integer>> set = map.entrySet();
set.stream().forEach(s -> System.out.println(s));
/*
aaa=10
ccc=30
bbb=20
*/

数组

Arrays数组工具中的静态方法:stream(T[] array)

int[] arr2 = {11, 22, 33};
double[] arr3 = {11.1, 22.2, 33.3};Arrays.stream(arr2).forEach(s -> System.out.println(s));
Arrays.stream(arr3).forEach(s -> System.out.println(s));

零散的数据

Steam类中的静态方法:of(T … values)

Stream.of(1, 2, 3, "abc").forEach(s -> System.out.println(s));

二、中间方法

filter()

ArrayList<String> list = new ArrayList<>();
list.add("林青霞");
list.add("张曼玉");
list.add("王祖贤");
list.add("柳岩");
list.add("张敏");
list.add("张无忌");list.stream().filter(s -> s.startsWith("张")).forEach(s -> System.out.println(s));

s.startsWith(“张”) 返回的是布尔值

limit(Long maxSize)

获取前几个元素

list.stream().limit(3).forEach(s -> System.out.println(s));

skip(Long n)

跳过前几个元素

list.stream().skip(3).forEach(s -> System.out.println(s));

distinct()

去除流中重复的元素(依赖hashCode 和equals方法,即泛型若是Student,需要重写这两个方法)

list.stream().distinct().forEach(s -> System.out.println(s));

concat(Stream a, Stream b)

Stream的静态方法,合并流a和流b为一个流

Stream<String> stream1 = list.stream().limit(4);
Stream<String> stream2 = list.stream().skip(2);
Stream.concat(stream1, stream2).forEach(s -> System.out.println(s));

注意:forEach是终结方法,流水线会被关闭,之后不能再使用,不能再调用中间方法;流1和流2合并了,就不能再使用流1。

三、终结方法

forEach()

count()

四、收集操作

把流操作后的结果,转到新集合

注意:Steam流操作,不会修改原集合!

ArrayList<Integer> list = new ArrayList<>();
Collections.addAll(list, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
list.stream().filter(s -> s % 2 == 0).forEach(s -> System.out.print(s));System.out.println(list);//246810[1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

collect(Collector collector)

收集Stream流,指定收器Collector,收集到新集合

Collectors工具类提供了具体的收集方式:
toList():收集到List集合中
toSet():收集到Set集合中
toMap(Function keyMapper, Function valueMapper):收集到Map集合中

List<Integer> list = new ArrayList<>();
Collections.addAll(list, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
List<Integer> collect = list.stream().filter(s -> s % 2 == 0).collect(Collectors.toList());System.out.println(collect);//[2, 4, 6, 8, 10]
System.out.println(list);//[1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
ArrayList<String> list = new ArrayList<>();
list.add("张三,23");
list.add("李四,24");
list.add("王五,25");Map<String, Integer> collect = list.stream().filter(s -> Integer.parseInt(s.split(",")[1]) >= 24).collect(Collectors.toMap(s -> s.split(",")[0], s -> Integer.parseInt(s.split(",")[1])));System.out.println(collect);//{李四=24, 王五=25}
返回列表