Java8中Stream详解

Posted Vincent-yuan

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java8中Stream详解相关的知识,希望对你有一定的参考价值。

Java8提供了Stream(流)处理集合的关键抽象概念,它可以对集合进行的操作,可以执行非常复杂的查找、过滤和映射数据等操作。Stream API 借助于同样新出现的Lambda表达式,极大的提高编程效率和程序可读性。

1.Java Stream vs Collection

我们列出流相比于Collection的不同的特征:

  • 不是数据结构
  • 需要用lambdas表达式
  • 不能用下标访问
  • 可以容易的被聚合为数组或者列表
  • 懒访问支持
  • 可并行

英文表述如下:

  • Not a data structure
  • Designed for lambdas
  • Do not support indexed access
  • Can easily be aggregated as arrays or lists
  • Lazy access supported
  • Parallelizable

2.创建流

2.1 Stream.of()
Stream<Integer> stream = Stream.of(1,2,3,4,5,6,7,8,9);
stream.forEach(p -> System.out.println(p));
2.2. Stream.of(array)
 Stream<Integer> stream = Stream.of( new Integer[]{1,2,3,4,5,6,7,8,9} );
 stream.forEach(p -> System.out.println(p));
2.3. List.stream()
         List<Integer> list = new ArrayList<Integer>();
         for(int i = 1; i< 10; i++){
             list.add(i);
         }
         Stream<Integer> stream = list.stream();
         stream.forEach(p -> System.out.println(p));
2.4. Stream.generate() or Stream.iterate()
         Stream<Integer> randomNumbers = Stream
             .generate(() -> (new Random()).nextInt(100));

         randomNumbers.limit(20)
              .forEach(System.out::println);
2.5. Stream of String chars or tokens
        IntStream stream = "12345_abcdefg".chars();
        stream.forEach(p -> System.out.println(p));
        
    //OR
        
        Stream<String> stream = Stream.of("A$B$C".split("\\\\$"));
        stream.forEach(p -> System.out.println(p));

3. Stream Collectors

在执行过中间操作之后,我们会用stream的Collector方法收集处理的元素到集合中。

3.1 收集流元素到列表(List)
         List<Integer> list = new ArrayList<Integer>();
         for(int i = 1; i< 10; i++){
             list.add(i);
         }
         Stream<Integer> stream = list.stream();
         List<Integer> evenNumbersList = stream.filter(i -> i%2 == 0)
                                                .collect(Collectors.toList());
         System.out.print(evenNumbersList);
3.2 收集流元素到数组(Array)
Stream<Integer> stream = list.stream();
         Integer[] evenNumbersArr = stream.filter(i -> i%2 == 0).toArray(Integer[]::new);

你也可以收集流到Set, Map 等中。

4.流操作

先准备一个列表数据

List<String> memberNames = new ArrayList<>();
memberNames.add("Amitabh");
memberNames.add("Shekhar");
memberNames.add("Aman");
memberNames.add("Rahul");
memberNames.add("Shahrukh");
memberNames.add("Salman");
memberNames.add("Yana");
memberNames.add("Lokesh");
4.1 中间操作

中间操作返回一个流,所以我们可以在一行关联多个方法。

4.1.1. Stream.filter()

memberNames.stream().filter((s) -> s.startsWith("A"))
                    .forEach(System.out::println);

输出;

Amitabh
Aman

4.1.2. Stream.map()

map中间操作通过给出函数转换流中的每个元素为另一个对象

 memberNames.stream().filter((s) -> s.startsWith("A"))
                     .map(String::toUpperCase)
                     .forEach(System.out::println);    
4.2. 终端操作

4.2.1. Stream.forEach()

memberNames.forEach(System.out::println);

4.2.2. Stream.collect()

List<String> memNamesInUppercase = memberNames.stream().sorted()
                            .map(String::toUpperCase)
                            .collect(Collectors.toList());
        
System.out.print(memNamesInUppercase);

4.2.3. Stream.match()

所有的matching操作都是终端从挨揍,并且返回boolean 结果

boolean matchedResult = memberNames.stream()
        .anyMatch((s) -> s.startsWith("A"));
System.out.println(matchedResult);

matchedResult = memberNames.stream()
        .allMatch((s) -> s.startsWith("A"));
System.out.println(matchedResult);

matchedResult = memberNames.stream()
        .noneMatch((s) -> s.startsWith("A"));
System.out.println(matchedResult);

4.2.4. Stream.count()

long totalMatched = memberNames.stream()
    .filter((s) -> s.startsWith("A"))
    .count();

4.2.5. Stream.reduce()

reduce()方法根据给出的函数执行流上元素的减少操作,结果是Optional接收这个reduced value。

we are reducing all the strings by concatenating them using a separator #.

Optional<String> reduced = memberNames.stream()
        .reduce((s1,s2) -> s1 + "#" + s2);

reduced.ifPresent(System.out::println);

输出:

Amitabh#Shekhar#Aman#Rahul#Shahrukh#Salman#Yana#Lokesh

5. Stream 流中的短路操作

5.1. Stream.anyMatch()
boolean matched = memberNames.stream()
        .anyMatch((s) -> s.startsWith("A"));
5.2. Stream.findFirst()
String firstMatchedName = memberNames.stream()
            .filter((s) -> s.startsWith("L"))
            .findFirst()
                        .get();

6.Java Steam中的并发操作

List<Integer> list = new ArrayList<Integer>();
         for(int i = 1; i< 10; i++){
             list.add(i);
         }
         
        //Here creating a parallel stream
         Stream<Integer> stream = list.parallelStream();    

         Integer[] evenNumbersArr = stream.filter(i -> i%2 == 0).toArray(Integer[]::new);
         System.out.print(evenNumbersArr);

参考网址:

https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html

https://blog.csdn.net/pan_junbiao/article/details/105913518

https://howtodoinjava.com/java8/java-streams-by-examples/

https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html

以上是关于Java8中Stream详解的主要内容,如果未能解决你的问题,请参考以下文章

java8新特性_Stream详解

Java8中Stream详解

Java8 Stream 流详解

Java8中聚合操作collectreduce方法详解

Java8中聚合操作collectreduce方法详解

Java8 Stream用法详解