函数式编程 - 无限流


集合是内存中的数据结构,它具有集合中存在的所有元素,我们有外部迭代来迭代集合,而流是一种固定的数据结构,其中元素根据需要计算,并且流具有内置迭代来迭代每个元素。以下示例展示了如何从数组创建 Stream。

int[] numbers = {1, 2, 3, 4};
IntStream numbersFromArray = Arrays.stream(numbers);

上面的流具有固定大小,由四个数字组成的数组构建,并且不会返回第四个元素之后的元素。但是我们可以使用 Stream.iterate() 或 Stream.generate() 方法创建一个 Stream,该方法可以将 lamdba 表达式传递给 Stream。使用 lamdba 表达式,我们可以传递一个条件,一旦满足即可给出所需的元素。考虑这种情况,我们需要一个 3 倍数的数字列表。

示例 - 无限流

import java.util.stream.Stream;

public class FunctionTester {    
   public static void main(String[] args) {
      //create a stream of numbers which are multiple of 3 
      Stream<Integer> numbers = Stream.iterate(0, n -> n + 3);

      numbers
         .limit(10)
         .forEach(System.out::println);
   }   
}

输出

0
3
6
9
12
15
18
21
24
27

为了对无限流进行操作,我们使用 Stream 接口的 limit() 方法来限制当数字的计数达到 10 时的迭代。