文档章节

java8之stream流的基本操作

嘴角轻扬30
 嘴角轻扬30
发布于 11/21 21:14
字数 1190
阅读 8
收藏 9

一、stream流简介

Stream流是数据渠道,用于操作数据源(集合、数组等)所生成的元素序列。
Stream的优点:声明性,可复合,可并行。这三个特性使得stream操作更简洁,更灵活,更高效。
Stream的操作有两个特点:可以多个操作链接起来运行,内部迭代。
Stream可分为并行流与串行流,Stream API 可以声明性地通过 parallel() 与sequential() 在并行流与顺序流之间进行切换。
串行流就不必再细说了,并行流主要是为了为了适应目前多核机器的时代,提高系统CPU、内存的利用率,并行流就是把一个内容分成多个数据块,并用不同的线程分别处理每个数据块的流。java1.8并行流使用的是fork/join框架,关于fork/join框架可参考http://ifeve.com/talk-concurrency-forkjoin/学习。

注意点:
1、Stream不会自己存储数据。
2、Stream不会改变原对象,他们会返回一个新的Stream。
3、Stream操作是延迟的,他们会等到需要的结果时才执行。
4、使用并行流并不一定会提高效率,因为jvm对数据进行切片和切换线程也是需要时间的。

二、创建stream流的方式

//1、通过Collection系列提供的stream()(串行) 或parallelStream()(并行)获取
List<String> list = new ArrayList<>();
Stream<String> stream1 = list.stream();//串行流
Stream<String> stream2 = list.parallelStream();//并行流
 //2、通过Arrays中的静态方法stream() 获取数据流
User[] u = new User[2];
Stream<User> stream3 = Arrays.stream(u);
 //3、通过Stream;类中的静态方法of()
Stream<String> stream4 = Stream.of("11","2");

三、筛选和切片

1、filter(predicate)-接收lambda,从流中排除某些元素。
2、limit(n)-截断流,使其元素不超过给定数量。
3、skip(n)-跳过元素,返回一个扔掉了前n个元素的流。若流中元素不足n个,则返回一个空流,与limit(n)互补。
4、distinct-筛选,通过流所生成元素的hashcode()和equals()去重复元素。

/**
   * 打印年龄大于18的前4位用户信息(不重复)
   * 并跳过第1个用户
   */
@Test
  public void test1(){
    list.stream()
    .filter((x)->x.getAge()>18)
    .distinct()
    .limit(4)
    .skip(1).forEach(System.out::println);
  }

四、映射

1、map,接收Lambda,将元素转换成其他形式或提取信息。接收一个函数作为参数,该函数会被应用到每一个元素上,并将其映射成一个新的元素。
2、mapToDouble/mapToInt/mapToLong,接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新DoubleStream/IntStream/LongStream。
3 、flatMap,接收一个函数作为参数,将流中的每个值都换成一个流,然后把流连接成一个流。

@Test
 public void test2(){
   ///map
   list.stream().map(User::getName)
   .forEach(System.out::println);
   //flatMap
   List<List<User>> list1 = new ArrayList<>();
   list1.add(list);
   list1.stream().flatMap(Stream::getNames)
   .forEach(System.out::println);
 }
 public static Stream<String> getNames(List<User> list){
   List<String> list1 = new ArrayList<String>();
   for (User user : list) {
     list1.add(user.getName());
   }
   return list1.stream();
 }

五、排序

1、sorted(),产生一个新流,其中按自然顺序排序。 
2、sorted(Comparator),产生一个新流,其中按比较器顺序排序。

@Test
  public void test3(){
    List<String> list =Arrays.asList("aa","bb","cc","dd");
    list.stream().sorted()
    .forEach(System.out::println);
    //
    list.stream().sorted((x,y) -> {
      if(x.equals(y)){
        return 1;
      }else{
        return -1;
      }
    } ).forEach(System.out::println);
  }

六、查找与匹配

1、allMatch,检查是否匹配所有元素。 
2、anyMatch,检查是否至少匹配一个元素。 
3、noneMatch,检查是否没有匹配所有元素。 
4、findFirst,返回第一个元素。 
5、findAny,返回当前流中的任意元素。 
6、count,返回流中元素的总数。 
7、 max,返回流中最大值。 
8、min,返回流中最小值。 
9、froEach(Consumer c) 内部迭代。

@Test
  public void test4(){
    boolean b = list.stream().
        noneMatch((e) ->
        e.getName().equals("zhao"));
    System.out.println(b);
    Optional<User> op = list.parallelStream()
        .filter((x) -> x.getAge() == 18)
        .findAny();
    System.out.println(op.get());
  }

七、汇总测试

@Test
  public void test5(){
    //转List
    List<String> list1 =list.stream()
        .map(User::getName)
        .collect(Collectors.toList()) ;
    list1.forEach(System.out::println);
    //转HashSet
    HashSet<String> set = list.stream().
        map(User::getName)
        .collect(Collectors.toCollection(HashSet::new));
    set.forEach(System.out::println);
    //总数
    Long count = list.stream()
        .collect(Collectors.counting());
    System.out.println(count);
    //平均年龄
    double avAge = list.stream()
        .collect(Collectors.averagingInt(User::getAge));
    System.out.println(avAge); 
    //总年龄
    int toAge = list.stream()
        .collect(Collectors.summingInt(User::getAge));
    System.out.println(toAge);
    //最大值
    Optional<User> u = list.stream()
        .collect(Collectors.maxBy((e1,e2) 
            -> Integer.compare(e1.getAge(),e2.getAge() )));
    System.out.println(u);
    //平均年龄
    IntSummaryStatistics collect = list.stream()
        .collect(Collectors.summarizingInt(User::getAge));
    System.out.println(collect.getAverage());
    //分组
    Map<Integer, List<User>> l= list.stream()
        .collect(Collectors.groupingBy(User::getAge));
    System.out.println(l);
    //多级分组
    Map<Integer,Map<String,List<User>> > ls= list.stream()
        .collect(Collectors.groupingBy(
            User::getAge,Collectors.groupingBy(User::getSex)));
    System.out.println(ls);
    //分区
    Map<Boolean,List<User>> map= list.stream()
        .collect(Collectors.partitioningBy((x) 
            -> x.getAge()>18));
    System.out.println(map);
    //连接字符串
    String str = list.stream().map(User::getName)
        .collect(Collectors.joining(",","-","-"));
    System.out.println(str);
  }  

 

© 著作权归作者所有

共有 人打赏支持
嘴角轻扬30
粉丝 1
博文 31
码字总数 23625
作品 0
苏州
程序员
私信 提问
跟上Java8 - Stream API快速入门

跟上Java8 - Stream API快速入门 王爵的技术博客2017-07-1821 阅读 streamfilterJava8 在前面我们简单介绍了 表达式,Java8旨在帮助程序员写出更好的代码, 其对核心类库的改进也是关键的一部...

王爵的技术博客
2017/07/18
0
0
Java8之Stream流(终篇)流与迭代器

在本系列文章发布的时候,有很多同学反映,Stream流的调试和forEach()的调试都不是特别友好,那本篇给出一个折中的调试方法,虽然不能完美解决调试的问题,但是基本上能解决绝大部分的调试问...

揭光智
07/25
0
0
Java8新特性系列(Stream)

上期我们分析了Java8中的引用,本期我们将分析Java8中的另一个重要的新特性:流Stream。 Stream是什么? 在Java8源代码中,是这么定义Stream的: A sequence of elements supporting sequen...

码上论剑
02/03
0
0
Java8 - 使用Stream API

Java8 - 使用Stream API Stream 是什么? Stream represents a sequence of objects from a source, which supports aggregate operations(多种操作). Following are the characteristics......

秋风醉了
09/12
0
0
Java8函数式编程的宏观总结

1.java8优势 通过将行为进行抽象,java8提供了批量处理数据的并行类库,使得代码可以在多核CPU上高效运行。 2.函数式编程的核心 使用不可变值和函数,函数对一个值进行处理,映射成另一个值。...

caoxiaohong1005
03/18
0
0

没有更多内容

加载失败,请刷新页面

加载更多

我的Linux系统九阴真经

我的Linux系统九阴真经 在今天,互联网的迅猛发展,科技技术也日新月异,各种编程技术也如雨后春笋一样,冒出尖来了。各种创业公司也百花齐放百家争鸣,特别是针对服务行业,新型互联网服务行...

linuxCool
9分钟前
0
0
Python程序员需要知道的30个技巧

1 直接交换两个数字位置 1x, y = 10, 202print(x, y)3x, y = y, x4print(x, y)5#1 (10, 20)6#2 (20, 10) 2 比较运算符的链接 1n = 102result = 1 < n < 203print(result)4# True5result = 1 ......

糖宝lsh
10分钟前
0
0
[LintCode] Linked List Cycle(带环链表)

描述 给定一个链表,判断它是否有环。 样例 给出 -21->10->4->5, tail connects to node index 1,返回 true。 这里解释下,题目的意思,在英文原题中,tail connects to node index 1 表示的...

honeymose
21分钟前
3
0
Android :报错Your project path contains non-ASCII characters.

报错内容如下 Your project path contains non-ASCII characters. This will most likely cause the build to fail on Windows. Please move your project to a different directory. See ht......

lanyu96
32分钟前
3
0
Nginx平滑添加模块

Nginx已经编译安装并运行了一段时间, 然后某一天, 发现需要用到某个模块但当初没有编译, 这个时候怎么办呢? 卸载重新安装肯定可以的, 如果Nginx版本没有变更的话, 则有一个相对平滑的方法来添...

老菜鸟0217
37分钟前
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部