JAVA8流的使用
一、筛选和切片
- 用谓词筛选 ==filter(T -> T.getXX())==
- 判断相同 ==distinct()==
- 截断流 ==limit(n)==
- 跳过元素 ==skip(n)==
- 排序 ==sorted(Comparator.comparing(T::getXX))==
- 遍历 ==forEach(XXX)==
二、映射
- 对流中每一个元素应用函数 ==map()==
==> 一般用于提取流中的内容 map(T :: getXX) - 流的扁平化 ==flatMap()==
==> 将一个流中每个值都转换成另外一个流，然后再将转换的所有的流链接成一个流
三、查找与匹配
- 查找至少一个匹配 ==anyMatch()==
- 查找是全匹配 ==allMatch()==
对应的无匹配是 ==noneMatch()== - 查找任意元素 ==findAny()==
- 查找第一个元素 ==findFirst()==
- 查找最小/最大的
==min(Comparator.comparing(T::getXX))==
==max(Comparator.comparing(T::getXX))==
四、归约
- 求和 ==reduce(初始值,Integer :: sum)==
ins2.stream().reduce(0,Integer::sum)
不加初始值 返回Optional类型
- 求最大最小 ==reduce(初始值,Integer :: sum)==
ins.stream().reduce(0,Integer::max)
ins.stream().reduce(0,Integer::min)
不加初始值 返回Optional类型
五、数值流
五A、原始类型流特化
- 映射到数值流
==mapToInt(XX :: getX)==
==mapToDouble(XX :: getX)==
==mapToLong(XX :: getX)==
映射成功后 可以使用sum(),max(),min(),avg() 等方法
转换为对象流 (类似装箱)
==boxed()==默认值
==OptionalInt==
==OptionalDouble==
==OptionalLong==
OptionalInt XX =trans.parallelStream().mapToInt(Transaction::getValue).max()
int max = XX.orElse(N) 拖过没有最大值，则为默认的N
五B、数值范围
IntStream和LongStream 有 方法
==range(m,n)==
==rangeClosed(m,n)==
对比是 后者包含n，前者不包含n
生成勾股数
Stream<double[]> sqrt = IntStream.rangeClosed(1, 100).boxed()
.flatMap(a -> IntStream.rangeClosed(a, 100)
.mapToObj(b -> new double[]{a,b,Math.sqrt(a*a + b*b)})
.filter(t -> t[2] % 1 == 0));
sqrt.limit(10).forEach(t -> System.out.println((int)t[0] + "," + (int)t[1] + "," + (int)t[2]));
六、构建流
//1.由值创建流
Stream<String> s = Stream.of("1","2","3","6");
Stream<String> s2 = Stream.empty(); //创建空流
s.forEach(System.out::println);
//2.由数组创建流
int[] nums = { 11,60,61,12,16,20 };
int sum = Arrays.stream(nums).sum();
//3.由文件生成流
long lines = 0;
try (Stream<String> s3 = Files.lines(Paths.get("data.txt"),
Charset.defaultCharset())) {
lines = s3.flatMap(line -> Arrays.stream(line.split(""))).distinct().count();
} catch (Exception e) {
}
System.out.println(sum + "::" + lines);
//4.函数生成流
//4.1 迭代 iterate(n,lambda) 方法接受初始值，并将lambda作用于每个值
Stream.iterate(0, a -> a+2).limit(10).forEach(System.out::println);
//4.1.1 测试 斐波那契数列
Stream.iterate(new int[]{0, 1}, t -> new int[]{t[1], t[0]+ t[1]})
.limit(10).forEach(t -> System.out.print(t[0]+ " "));
Stream.iterate(new int[]{0, 1}, t -> new int[]{t[1], t[0]+ t[1]})
.limit(10).map(t -> t[0] + " ").forEach(System.out::print);
//4.2 生成 generate 接受一个 Supplier<T> 类型 Lambda值
IntStream.generate(new IntSupplier() {
public int getAsInt(){
return 2;
}
});
IntStream.generate(() -> 2).limit(10).forEach(System.out::print);;
//4.2.2 测试 斐波那契数列
IntStream.generate(new IntSupplier(){
private int a = 0;private int b = 1;
public int getAsInt() {
int oldPrevious = a;
int nextValue = a + b;
a = b;
b = nextValue;
return oldPrevious;}
}).limit(10).forEach(System.out::println);
