Stream流学习记录

一、 概述

stream流是Java8中处理集合的关键抽象概念，他可以指定你希望对集合进行的操作，可以执行非常复杂的查找、过滤和映射操作。使用StreamAPI对集合数据进行操作，就类似于使用SQL执行数据库查询，也可以使用StreamAPI来并行执行操作。

简言之：StreamAPI提供了一种高效且易于使用的处理数据的方式。

特点:

• 不是数据结构，不会保存数据
• 不会修改原来的数据源，它会将操作后的数据保存到另一个对象中
• 惰性求值，流在重建处理过程中，只是对操作进行了记录，并不会立即执行，需要等到执行终止操作的时候才会进行时机的计算

二、操作分类

• 无状态：指元素的处理不受之前元素的影响
• 有状态：指该操作只有拿到所有元素之后才能继续下去
• 非短路操作：指必须处理所有元素才能得到最终结果
• 短路操作：指遇到某些符合条件的元素就可以得到最终结果，如A||B，只要A为true，则无需判断B的结果

三、具体用法

1. 流的常用创建方法
   1.1 使用Collection下的stream()和parallelStream()方法

  List<AnalysisOrderCaseGroupDO> list = page.getList();
  List<Long> caseGroupIds = list.stream().map(AnalysisOrderCaseGroupDO::getId)
            .collect(Collectors.toList());
1
2
3

 dataList.parallelStream().forEach(d -> geometryBaseService.doSimplify(d, zoom));
1

1.2 使用Arrays中的stream()方法，将数组转化成流

Integer[] nums = new Integer[10];
Stream<Integer> stream = Array.stream(nums);
1
2

这里有一个在枚举中使用的例子：

public enum ModeEnum{
	//文件操作方式
	READ_ONLY(1, "只读"）,
	EDITABLE(2, "可编辑"),
	;

	Integer code;
	String desc;
	
	public static String descOf(Integer code){
	 	if(code == null ){
	 		return "";
	 	}
	 	return Arrays.Stream(ModeEnum.values())
	 		.filter(o -> Objects.equals(o.getCode(), code))
	 		.findAny().map(ModeEnum::getDesc).orElse("");
	}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

1.3 使用Stream中的静态方法：of()、iterator() 、generate()

一个小案例：

public class StreamOfTest {
    public static void main(String[] args) {
        String  idStr = "12, 22, 33,44";
        List<Long> ids = Stream.of(idStr.split(","))
                .map(String::trim)
                .map(Long::valueOf)
                .collect(Collectors.toList());
        System.out.println(ids);

		Stream<Integer> stream2 = Stream.iterate(0, (x) -> x + 2).limit(6);
        stream2.forEach(System.out::println);

        Stream<Double> stream3 = Stream.generate(Math::random).limit(2);
        stream3.forEach(System.out::println);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

1.4 使用BufferReader.lines()方法，将每行内容转化成流