【如何让代码变“高级”(二)】-这样操做值得一波666（Java Stream）（这么有趣）

欢迎关注公众号【 Ccww笔记】，原创技术文章第一时间推出

“致"高级"工程师(BUG工程师)
一颗折腾的心
原创不易，点个赞💗，支持支持

往期文章:

• 【如何让代码变“高级”(一)】-Spring组合注解提高代码维度（这么有趣）
• ...

开发中的代码

在开发中的代码是否是很常见这样的代码：

这样的?

for循环取元素取值

List<User> szUserList = new ArrayList<>();
 for (User user : userList) {
   if (user.getAddress().equals("shenzhen")) {
    szUserList.add(user);
   }
 }

或者这样的?

for循环去重

for (int i = 0; i < list.size() - 1; i++) {
            for (int j = list.size() - 1; j > i; j--) {
                if (list.get(j).equals(list.get(i))) {
                    list.remove(j);
                }
            }
        }

Set set = new HashSet();
        List<String> newList = new ArrayList();
        for (Iterator iter = list.iterator(); iter.hasNext();) {
            Object element = iter.next();
            if (set.add(element))
                newList.add(element);
        }
        list.clear();
        list.addAll(newList);
      
  }

对于普通的CV族来讲,这样就差很少了,功能实现了,又能够收拾包袱准备下班了.完美!!!

但对于咱们"高级"CV族来,这不够,这远远的不够,咱们须要保持一颗折腾的心💗,这样的代码彰显不出咱们这段位的价值(青铜😀王者).

因此咱们须要一种方式去提高咱们代码的维度,让咱们的代码变得更"高级", 使代码更加简洁而且更加语义化 .

因为"高级"CV"族保持这样的心态:

平凡的人,平凡的生活,平凡的工做

该有一颗不平凡的心💗

找出一种方式能够很好的升级这种代码问题:

Java 8 新提供给开发者的一组操做集合的 API----Stream 流

咱们如何看待Stream流

那Stream流是如何来提高代码维度?

首先咱们来看看Stream流处理for循环取元素取值:

List<User> szUserList=userList.stream()                             
        .filter(user-> user.getAddress().equals("shenzhen"))    
        .collect(Collectors.toList());

其实, stream流会把须要处理的元素集合看做一种流， 流在管道中传输， 而且能够在管道的节点上进行处理， 好比筛选、排序、聚合等。Stream 流能够极大的提升开发效率，也可使用它写出更加简洁明了的代码。

那么Stream流能够分几种:

• 顺序流 : 按照顺序对集合中的元素进行处理
• 并行流 : 使用多线程同时对集合中多个元素进行处理

在使用并行流的时候就要注意线程安全的问题

元素流在管道中通过中间操做（intermediate operation）的处理，最后由终端操做 (terminal operation) 获得前面处理的结果。

• 中间操做(intermediate operation): 中间操做会产生另外一个流 ,( 流是一种惰性操做，全部对源数据的计算只在终止操做被初始化的时候才会执行), 并且中间操做还分无状态操做和有状态操做两种 .

  • 无状态操做 : 在处理流中的元素时，会对当前的元素进行单独处理。 (例如:过滤操做).
  • 有状态操做 : 某个元素的处理可能依赖于其余元素.( 例如:查找最小值，最大值，和排序 ).
• 终止操做 (terminal operation):消费 Stream 流，而且会产生一个结果 . 若是一个 Stream 流被消费过了，那它就不能被重用的。

Stream流通常的执行过程可归纳为:

1. 源(Stream)
2. 零个或多个中间操做(intermediate operation)
3. 终止操做 （到这一步才会执行整个stream pipeline计算） (terminal operation)

源的建立方式

• 使用Collection下的 stream() 和 parallelStream() 方法
• 使用Stream中的静态方法：of()

List< String> createStream = new ArrayList< String>();
// 顺序流
Stream< String> stream = createStream.stream();
// 并行流
Stream< String> parallelStream = createStream.parallelStream();
// of()方法建立
Stream< String> stringStream = Stream.of(
    createStream.toArray(new String[createStream.size()]));

Intermediate操做

中间操做包括map (mapToInt, flatMap 等)、 filter、 distinct、 sorted、 peek、 limit、 skip、 parallel、 sequential、 unordered等.

经常使用操做解析:

• filter : 筛选符合条件的元素后从新生成一个新的流。
• map : 接收一个函数做为参数，该函数会被应用到每一个元素上，并将其映射成一个新的元素。
• flatMap: 接收一个函数做为参数，将流中的每一个值都换成另外一个流，而后把全部流链接成一个流。
• distinct: 去重操做，将 Stream 流中的元素去重后，返回一个新的流。
• sorted: 产生一个天然顺序排序或者指定排序条件的新流。
• skip:跳过n元素，配合limit(n)可实现分页
• peek: 生成一个包含原Stream的全部元素的新Stream，同时会提供一个消费函数（Consumer实例），新Stream每一个元素被消费的时候都会执行给定的消费函数(通常用于重赋值那些)；
• limit: 对一个Stream进行截断操做，获取其前N个元素，若是原Stream中包含的元素个数小于N，那就获取其全部的元素；

terminal操做

终止操做包括:forEach、 forEachOrdered、 toArray、 reduce、 collect、 min、 max、 count、 anyMatch、 allMatch、 noneMatch、 findFirst、 findAny、 iterator等

经常使用操做解析:

• forEach: 遍历了流中的元素。(终端操做)
• collect: 接收一个Collector实例，将流中元素收集成另一个数据结构
• max:得到流中最大值，比较器能够由本身定义。(终端操做)
• min: 得到流中最小值，比较器能够由本身定义。(终端操做)
• anyMatch : 判断 Stream 流中是否有任何符合要求的元素，若是有则返回 ture,没有返回 false。（终端操做）

该如何操做呢?

Stream操做均可以按照通常步骤进行.

好比上面的去重操做:

distinct操做:

list=list.stream()
           .distinct()
           .collect(Collectors.toList());

NOTE: distinct()使用 hashCode() 和 eqauls() 方法来获取不一样的元素。所以，须要去重的类必须实现 hashCode() 和 equals() 方法

结合filter,distinct,peek,skip,limit,collect例子:

List arrList = userList.stream().filter(user -> user.getName().equals("ccww"))//过滤
                .distinct()//去重
                .peek(user -> user.setAddress("shenzhen"))//从新赋值
                .skip(2)//跳读
                .limit(2)//读取2个元素
                .collect(Collectors.toList());

map的例子:

List arrList1=userList.stream()
                .map(user->{
                     //todo 处理函数
                    user.setAddress(cityService.getCity());
                }).collect(Collectors.toList());
    }

如今咱们主要了解了 Java 8 Stream 流的基础知识及使用，涵盖 Stream 流的分类、接口、相关 API 操做使用, 在实际开发中,必定还会有更多的应用,更多Stream详细内容,会在接下来好好文章中..

各位看官还能够吗？喜欢的话，动动手指点个赞💗，点个关注呗！！谢谢支持！

也欢迎关注公众号【Ccww笔记】，原创技术文章第一时间推出