本文记录一些java8的stream和jdk9的reactive stream中的一些知识点。
不定期更新。
map和flatMap
| map | flatMap | |
|---|---|---|
| 输出元素个数 | 1个 | 0~N个 |
| 输出类型 | 原类型 | list |
| 适用场景 | 转换数据 | 对数据操作 |
在spring webflux中，与Mono和Flux有关的操作，优先选择flatMap。
举个例子，下面有map和flatMap分别处理这个string[]的list：
List<String[]> eggs = new ArrayList<>();
// 第一箱鸡蛋
eggs.add(new String[]{"鸡蛋_1", "鸡蛋_1", "鸡蛋_1", "鸡蛋_1", "鸡蛋_1"});
// 第二箱鸡蛋
eggs.add(new String[]{"鸡蛋_2", "鸡蛋_2", "鸡蛋_2", "鸡蛋_2", "鸡蛋_2"});
//打印出两个stream
eggs.stream()
.map(x -> Arrays.stream(x)).forEach(x-> System.out.println(x));
//打印出每一个鸡蛋的名称
eggs.stream()
.flatMap(x -> Arrays.stream(x)).forEach(x-> System.out.println(x));
输出的结果：
java.util.stream.ReferencePipeline$Head@28a0fd6c
java.util.stream.ReferencePipeline$Head@2b62442c
鸡蛋_1
鸡蛋_1
鸡蛋_1
鸡蛋_1
鸡蛋_1
鸡蛋_2
鸡蛋_2
鸡蛋_2
鸡蛋_2
鸡蛋_2
stream和parallelStream
stream称为流，parallelStream是并行流。在使用parallelStream时，要注意所涉及的变量都是无状态的，不要有类级别的属性变量。否则会出现结果不正确，而stream的效率是很低的。比如是循环的话，一般的优先级排序：parallelStream>foreach>stream。
当然，某些情况下，遍历的内容不大，或者说为了追求理解能力而想使用流式编程，此时的stream的优先级提高。
