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

2018-02-27 11:42:56来源:https://micorochio.github.io/2018/02/16/the-stream-in-java8-作者:Zing人点击

分享


上一篇文章写了流的基本知识,大约知道了流是用来处理序列集合的武功秘籍。


集合关注的是数据存储本身,流关注的数据计算和处理。本篇文章来说明一下适用流时应当注意的几点


##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对象,如



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



一般来说,除了初始创建流的, 返回流对象的大部分是业务中间操作 ,业务中间操作 (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 流的特性:
4x01 本质是函数式的, Stream不存储值

函数式的描述性语言,


如过滤:filter,限制:limit,循环:forEach,遍历:map等,描述地非常清晰;


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


4x02 内部迭代和外部迭代

for和for Each是外部迭代,外部迭代会将序列中的元素一一取出,再对数据进行显式操作。


for循环大家一定不陌生,这里就不代码举例了


流是内部迭代,在java中,除了留,其他的迭代全部是外部迭代。


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


微信扫一扫

第七城市微信公众平台