跳转至

Java Stream

时间：2019/7/16 15:36:38

Java Stream 使用#

流式处理框架

stream：单线程执行。 parallelStream：并行执行，使用时注意线程问题。

常用方法#

map()#

类型转换，stream 中的数据转换为任意其他类型。

1
2
3
List<String> list = Arrays.asList("1", "2", "3");
Stream<StringBuilder> stringBuilderStream = list.stream().map(StringBuilder::new);
Stream<String> stringStream = list.stream().map(String::valueOf);

flatMap()#

类型转换，把 stream 中的每一个元素转成换一个 stream，然后把所有的 stream 合并成一个 stream。

1
2
List<String> strings = Arrays.asList("hello world", "where are you", "i am fine");
Stream<String> unionStream = strings.stream().map(s -> s.split(" +")).flatMap(Stream::of);

reduce#

根据 stream 中的数据进行计算。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
    List<String> strings = Arrays.asList("hello world", "where are you", "i am fine");
    Stream<String> unionStream = strings.stream().map(s -> s.split(" +")).flatMap(Stream::of);

    # 连接流中的元素，第一个元素是 ""
    String unionStr = unionStream.reduce("", (identity, first) -> identity + "_" + first);
    System.out.println(unionStr);

    # 连接流中的元素，第一个元素是流的第一个元素
    unionStream = strings.stream().map(s -> s.split(" +")).flatMap(Stream::of);
    unionStr = unionStream.reduce((first, second) -> first + "_" + second).orElse("");
    System.out.println(unionStr);

    # 比较复杂的实现
    unionStream = strings.stream().map(s -> s.split(" +")).flatMap(Stream::of);
    List<String> result = new ArrayList<>();
    List<String> reduce = unionStream.reduce(result, (r, element) -> {
        r.add(element);
        return r;
    }, (first, second) -> {
        List<String> temp = new ArrayList<>();
        temp.addAll(first);
        temp.addAll(second);
        return temp;
    });

    System.out.println(result);
    System.out.println(reduce);

peek#

访问流中的元素，返回原来的流。当 peek 的下一流程执行的时候 peek 方法才会执行。

skip(long n)#

跳过 n 流中的前 n 个元素。当 n 大于流长度时，返回空流。

limit(long maxSize)#

返回流的前 maxSize 个元素。