无限流和过滤器

Question

import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class StreamExample {
    public static void main(String[] args) {
        List<Integer> numbers = Stream.iterate(0, x -> x+3)
                                        .filter(x -> x>10 && x<100).peek(System.out::println)
                                        .collect(Collectors.toList());
        numbers.forEach(System.out::println);
    }
}

将此流收集到列表中

正如我所看到的，infinity循环有一些问题，所以peek（）打印范围内的数字(12，99)，这是可以的，但之后它再次打印范围内的数字(11，98)，等等，你能解释一下我在哪里犯了错误吗？

Answer 1

编译器和运行库都不知道filter将过滤掉100以上的所有数字。因此，运行库继续生成无限个整数并对其应用筛选器。

您有多种方法来解决此问题：

使用limit将无限流截断为有限流。不过，这使得下面的过滤器有点不必要（如果设置严格的限制，只有x>10测试仍然相关）。

public static void main(String[] args) {
    List<Integer> numbers = Stream.iterate(0, x -> x+3)
                                    .limit(34)
                                    .filter(x -> x>10 && x<100).peek(System.out::println)
                                    .collect(Collectors.toList());
    numbers.forEach(System.out::println);
}

public static void main(String[] args) {
    List<Integer> numbers = IntStream.range(0, 34)
                                    .map(x -> 3*x)
                                    .collect(Collectors.toList());
    numbers.forEach(System.out::println);
}