jdk8lamdba惰性求值2

上一篇:

晓风轻：jdk8 lambda的惰性求值​ zhuanlan.zhihu.com

我们知道jdk8的stream流方法里面，有中间方法和最终（终点/终端）方法。只要不调用最终方法，中间所有的方法都不会实际执行。刚刚接触的时候，觉得这个效果好牛逼啊，学习了lambda之后想自己实现一下，想不到这么简单就实现了，就是不知道1. 官方是如何实现的，2. 是否有bug 3.是否有更加好的实现方法？？ @李佳明

package jdk8.lazy;
import java.util.function.IntUnaryOperator;
import java.util.function.Supplier;
import java.util.stream.IntStream;
/** * 自己尝试实现方法惰性求值 * * @author 晓风轻 * @github https://github.com/xwjie/jdk8/blob/master/src/src/jdk8/lazy/LazyDemo2.java * @date 2018.3.8 * */
class MyClass {
private final int result;
public MyClass(int t) {
this.result = t;
}
public MyClass some(IntUnaryOperator f) {
return new MyClass(f.applyAsInt(this.result));
}
public int value() {
return this.result;
}
}
/** * 带惰性求值的类，不调用终点方法value的，中间的方法都不会执行 * */
class MyClassLazy {
private Supplier<Integer> resultSupplier;
public MyClassLazy(int t) {
this(() -> t);
}
public MyClassLazy(Supplier<Integer> t) {
this.resultSupplier = t;
}
/** * intermediate Method，中间方法 * * @param f * @return */
public MyClassLazy some(IntUnaryOperator f) {
return new MyClassLazy(() -> f.applyAsInt(this.resultSupplier.get()));
}
/** * terminal Method 结束方法 * @return */
public int value() {
return this.resultSupplier.get();
}
}
public class LazyDemo2 {
public static void main(String[] args) {
// map是中间函数，后面没有结束函数的时候不会调用 IntStream.range(0, 2).map(LazyDemo2::doubleNumber);
System.out.println("----------上面的日志不会打印------");
// 最后的map函数是结束函数的时候，中间的日志才会打印 IntStream.range(0, 2).map(LazyDemo2::doubleNumber).count();
System.out.println("\t------------测试普通的方法--------");
// 没有做惰性求值 testClass();
System.out.println("\n\t------------测试实现了惰性的方法--------");
// 实现了惰性求值 testLazyClass();
}
private static void testClass() {
MyClass c = new MyClass(10);
System.out.println("---------------------下面的日志我希望不需要打印的，但【实际上】打印了");
// 没有调用终点方法，期待中间的日志不打印 c.some(LazyDemo2::doubleNumber).some(LazyDemo2::doubleNumber);
System.out.println("---------------------");
// 执行中间方法 int value = c.some(LazyDemo2::doubleNumber).some(LazyDemo2::doubleNumber).value();
System.out.println("计算结果:" + value);
}
private static void testLazyClass() {
MyClassLazy c = new MyClassLazy(10);
System.out.println("---------------------下面的日志由于没有调用终点方法，【没有】打印");
// 没有调用终点方法，期待中间的日志不打印 c.some(LazyDemo2::doubleNumber).some(LazyDemo2::doubleNumber);
System.out.println("---------------------");
// 执行中间方法 int value = c.some(LazyDemo2::doubleNumber).some(LazyDemo2::doubleNumber).value();
System.out.println("计算结果:" + value);
}
static int doubleNumber(int i) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("乘以2");
return i * 2;
}
}


GitHub：

https://github.com/xwjie/jdk8/blob/master/src/src/jdk8/lazy/LazyDemo2.java