zoukankan      html  css  js  c++  java
  • jdk8 流操作

    二、流

    2.1 流介绍

    流是Java API的新成员,它允许你以声明性方式处理数据集合(通过查询语句来表达,而不是临时编写一个实现)。就现在来说,你可以把它们看成遍历数据集的高级迭代器。此外,流还可以透明地并行处理,你无需写任何多线程代码了!

    2.2 使用流

    类别方法名方法签名作用
    筛选切片 filter Stream<T> filter(Predicate<? super T> predicate) 过滤操作,根据Predicate判断结果保留为真的数据,返回结果仍然是流
      distinct Stream<T> distinct() 去重操作,筛选出不重复的结果,返回结果仍然是流
           
      limit Stream<T> limit(long maxSize) 截取限制操作,只取前 maxSize条数据,返回结果仍然是流
           
      skip Stream<T> skip(long n) 跳过操作,跳过n条数据,取后面的数据,返回结果仍然是流
           
    映射 map <R> Stream<R> map(Function<? super T, ? extends R> mapper) 转化操作,根据参数T,转化成R类型,返回结果仍然是流
      flatMap <R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper) 转化操作,根据参数T,转化成R类型流,这里会生成多个R类型流,返回结果仍然是流
           
    匹配 anyMatch boolean anyMatch(Predicate<? super T> predicate) 判断是否有一条匹配,根据Predicate判断结果中是否有一条匹配成功
      allMatch boolean allMatch(Predicate<? super T> predicate) 判断是否全都匹配,根据Predicate判断结果中是否全部匹配成功
           
      noneMatch boolean noneMatch(Predicate<? super T> predicate) 判断是否一条都不匹配,根据Predicate判断结果中是否所有的都不匹配
           
    查找 findAny Optional<T> findAny() 查找操作, 查询当前流中的任意元素并返回Optional
      findFirst Optional<T> findFirst() 查找操作, 查询当前流中的第一个元素并返回Optional
           
    归约 reduce T reduce(T identity, BinaryOperator<T> accumulator); 归约操作,同样两个类型的数据进行操作后返回相同类型的结果。比如两个整数相加、相乘等。
      max Optional<T> max(Comparator<? super T> comparator) 求最大值,根据Comparator计算的比较结果得到最大值
           
      min Optional<T> min(Comparator<? super T> comparator) 求最小值,根据Comparator计算的比较结果得到最小值
           
    汇总统计 collect <R, A> R collect(Collector<? super T, A, R> collector) 汇总操作,汇总对应的处理结果。这里经常与
      count long count() 统计流中数据数量
           
    遍历 foreach void forEach(Consumer<? super T> action) 遍历操作,遍历执行Consumer 对应的操作

    上面是Stream API的一些常用操作,按场景结合lambda表达式调用对应方法即可。至于Stream的生成方式,Stream的of方法或者Collection接口实现类的stream方法都可以获得对应的流对象,再进一步根据需要做对应处理。

    另外上述方法如果返回是Stream对象时是可以链式调用的,这个时候这个操作只是声明或者配方,不产生新的集合,这种类型的方法是惰性求值方法;有些方法返回结果非Stream类型,则是及早求值方法。

  • 相关阅读:
    java实现倒计时
    javaweb启动时启动socket服务端
    二进制数与十六进制数之间如何互相转换
    分组查询最新时间的数据
    javaweb利用钉钉机器人向钉钉群推送消息(解决中文乱码)
    java利用钉钉机器人向钉钉群推送消息
    Java原生操作数据库(不使用框架)
    Mybatis 插入与批量插入以及多参数批量删除
    在spring中直接在类中注入dao
    web自动化测试实战之批量执行测试用例
  • 原文地址:https://www.cnblogs.com/panxuejun/p/8673266.html
Copyright © 2011-2022 走看看