使用Stream流输出斐波那契数列:
Stream.iterate(new int[]{0, 1}, t -> new int[]{t[1],t[0] + t[1]}) .limit(10) .map(t -> t[0]) .forEach(System.out::println);
使用IntSupplier生成流:
但很重要的一点是,在并行代码中使用有状态的供应源是不安全的,这是一个副作用的例子
IntSupplier fib = new IntSupplier(){ private int previous = 0; private int current = 1; public int getAsInt(){ int oldPrevious = this.previous; int nextValue = this.previous + this.current; this.previous = this.current; this.current = nextValue; return oldPrevious; } }; IntStream.generate(fib).limit(10).forEach(System.out::println);
前面的代码创建了一个 IntSupplier 的实例。此对象有可变的状态:它在两个实例变量中记录了前一个斐波纳契项和当前的斐波纳契项。 getAsInt 在调用时会改变对象的状态,由此在每次调用时产生新的值。相比之下,使用 iterate 的方法则是纯粹不变的:它没有修改现有状态,但在每次迭代时会创建新的元组。你应该始终采用不变的方法,以便并行处理流,并保持结果正确。请注意,因为你处理的是一个无限流,所以必须使用 limit 操作来显式限制它的大小;否则,终端操作(这里是 forEach )将永远计算下去。同样,你不能对无限流做排序或归约,因为所有元素都需要处理,而这永远也完不成!