Java8 Stream 系列(二)Stream应当注意的点

上一篇文章写了流的基本知识,大约知道了流是用来处理序列集合的武功秘籍。
集合关注的是数据存储本身,流关注的数据计算和处理。本篇文章来说明一下适用流时应当注意的几点

0x00 流不修改数据源

很多人认为流会直接操作源数据,有意识或者无意识的认为流中对数据的修改,可以在源序列集合中体现,甚至将源对象直接返回给调用处,然后想了半天为什么流操作为什么没有起作用,java8的流太难用了。
下面是一段验证代码

public class StreamTest1 {
    @Test
    public void testNotChange() {
        System.out.println(sourceNotChange());
    }

    public List<String> sourceNotChange() {
        List<String> names = Arrays.asList("zing","wang","zhen","max");
        System.out.println("\nthe source data-------------------");
        System.out.println(names);
        System.out.println("\nthe stream data-------------------");
        names.stream().map(i->{i = i+"_2 "; return i;}).forEach(System.out::print);
        System.out.println("\n");
        return names;
    }
}
运行结果

可以看到,如果将names直接return的话,数据是没有任何修改的。如果想将修改之后的对象返回,需要重新创建对象,代码如下:


public class StreamTest2 {
    @Test
    public void testNewObj() {
        System.out.println(changeToNewObj());
    }

    public List<String> changeToNewObj() {
        List<String> names = Arrays.asList("zing", "wang", "zhen", "max");
        System.out.println("\nthe source data-------------------");
        System.out.println(names);
        System.out.println("\nthe stream data-------------------");
        List<String> newNames = names.stream().map(i -> { i = i + "_2 "; return i; }).collect(Collectors.toList());
        System.out.println(newNames);
        System.out.println("\n");
        return newNames;
    }
}
运行结果

1x00 Stream对象只能使用一次

文章《Java8 Stream系列(一)从入坑到沉迷》已经验证
这里列出来提醒下,示例代码如下:

        Stream<Integer> trans = Stream.of(11, 9, 2);
        trans.forEach(i -> System.out.println(i));
        trans.reduce(0, Integer::sum);

2x00 流是惰性的

流只有在终止操作(Terminal operation)的时候才会进行计算
看API的朋友应该知道,有些方法返回的是Stream对象,如


IntStream API

有些操作无返回,或者是是非Stream的返回。

IntStream API

一般来说,除了初始创建流的,返回流对象的大部分是业务中间操作,业务中间操作(intermediate operations)只会暂是保留,不会执行,只有遇到求值终止操作(terminal operation) 时,才会一起执行。
下面两段代码,展示了流的惰性的。

public class StreamTest3 {
    @Test
    public void testNewObj() {
        IntStream.range(1, 10)
                .limit(5)
                .filter(i -> i > 0)
                .sorted()
                .skip(1)
                .map(i -> {
                    System.out.println("正在处理" + i);
                    return i;
                });
    }
}

运行结果
public class StreamTest3 {
    @Test
    public void testNewObj() {
        IntStream.range(1, 10)
                .limit(5)
                .filter(i -> i > 0)
                .sorted()
                .skip(1)
                .map(i -> {
                    System.out.println("正在处理" + i);
                    return i;
                })
                .forEach(i->{});
    }
}
运行结果

3x00 无限流

以上代码大部分是基于数组或List,所以都是有限流,下面演示一下无限流

public class StreamTest4 {
    @Test
    public void infintyStream(){
        Stream.iterate(1,i->i++)
                .forEach(num->System.out.println(String.valueOf(num)));
    }
}
运行结果,停不下来了!!!

无限流会造成程序无限运行,根本听不下来,应该规避无限流,只需要在iterate之后添加一个 limit() 即可

public class StreamTest5 {
    @Test
    public void infintyStream(){
        Stream.iterate(1,i->i++)
                .limit(18)
                .forEach(num->System.out.println(String.valueOf(num)));
    }
}

陷阱:下面也是一个无限流,请思考一下,为什么明明没有输出了,流却没有停下来

public class StreamTest6 {
    @Test
    public void infintyStream(){
        Stream.iterate(1, i -> (i + 1) % 2)
                .distinct()
                .limit(10)
                .forEach(num -> System.out.println(String.valueOf(num)));
    }
}

4x00 流具有短路操作的特性

流具有短路运算的特性,和&&,||一样,当逻辑条件达到操作目标,则流不会继续迭代元素,继续操作, 举个栗子


import org.junit.Test;

import java.util.Arrays;
import java.util.List;

public class StreamTest2 {
    @Test
    public void shortCircuitingStream(){
        List<String> datas = Arrays.asList("aaa","bb","CCCC","aaa bb CCCC","bb CCCC","bbb");
        datas.stream()
                .mapToInt(String::length)
                .filter(i->i==3)
                .findFirst()
                .ifPresent(System.out::println);
    }
}
上图打印的结果是3

我们更改一下方法引用

public class StreamTest2 {
    @Test
    public void shortCircuitingStream(){
        List<String> datas = Arrays.asList("aaa","bb","CCCC","aaa bb CCCC","bb CCCC","bbb");
        datas.stream()
                .mapToInt(i->{
                    System.out.println(i);
                    return i.length();
                })
                .filter(i->i==3)
                .findFirst()
                .ifPresent(System.out::println);
    }
}
并没有打印其他元素

结果很明显,没有打印其他的元素。也就是说,流的中间操作只是存储对元素的操作,并不会对元素进行迭代。

在终止操作之后,流会以短路的方式,对元素进行计算与修改。

我是分割线

5x00 流的特性:

5x01 本质是函数式的, Stream不存储值

函数式的描述性语言,
如过滤:filter,限制:limit,循环:forEach,遍历:map等,描述地非常清晰;

流也不会对值进行存储,只有在遇到终止操作的时候,才会对数据系列进行一次性操作。上文已经说过中间操作不会对数据进行操作,直到遇到终止操作。

5x02 内部迭代和外部迭代

for和for Each是外部迭代,外部迭代会将序列中的元素一一取出,再对数据进行显式操作。
for循环大家一定不陌生,这里就不代码举例了

流是内部迭代,在java中,除了留,其他的迭代全部是外部迭代。
流表面看似每个操作都会对数据进行一次循环,实际上并不是,流在内部迭代的时候,会尽量优化执行,并不是每次操作都会触发对数据序列的遍历

5x03 Stream针对数据的处理和计算

Stream和Iterator的的共同点是只能使用一次,不同点是:Stream是不存储值的,因为Stream针对数据的处理和计算,所以当流中需要创建存储的对象的时候,应该考虑一下,到底应不应该使用流。因为流不是万能的,也不一定是效率最高的。

前篇: Java8 Stream系列(一)从入坑到沉迷

by:Zing
转载请注明出处:https://micorochio.github.io/2018/02/16/the-stream-in-java8-02/

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,817评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,329评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,354评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,498评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,600评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,829评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,979评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,722评论 0 266
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,189评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,519评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,654评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,329评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,940评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,762评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,993评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,382评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,543评论 2 349

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,633评论 18 139
  • Java8 in action 没有共享的可变数据,将方法和函数即代码传递给其他方法的能力就是我们平常所说的函数式...
    铁牛很铁阅读 1,223评论 1 2
  • 了解Stream ​ Java8中有两个最为重要的改变,一个是Lambda表达式,另一个就是Stream AP...
    龙历旗阅读 3,306评论 3 4
  • 一、 过了学生时代,愈发爱听老歌。 毕了业便天南海北的几个旧友终于在年底聚合。故乡的冬阳正好,像一杯热气腾腾的奶茶...
    西柚tcher阅读 2,367评论 1 16
  • 今天又发生了一件大事:我妈要开始学习英语啦~由于昨晚我也不知道她看了神马公众号,推荐了懂你英语,突然就给我说她想学...
    大白兔_X阅读 163评论 0 1