Java流限制项

Java中的流（Stream）是为处理输入/输出操作而设计的，它提供了一种统一的处理机制，使我们可以方便地对不同类型的数据进行读写操作。然而，在使用流的过程中，我们有一些限制需要注意。

流只能遍历一次

流在遍历过程中会逐个读取元素，直到没有元素为止。在这个过程中，每读取一个元素，该元素就被认为已经被“消耗”了。因此，流只能遍历一次，再次遍历同一个流时就会抛出异常。

List<Integer> list = Arrays.asList(1, 2, 3);
Stream<Integer> stream = list.stream();
stream.forEach(System.out::println); // 正常输出 1, 2, 3
stream.forEach(System.out::println); // 抛出异常

在第一次遍历流时，元素被打印出来，而在第二次遍历相同的流时，由于元素已经被“消耗”，所以会抛出异常。

流可以被短路操作终止

流提供了一些短路操作，可以在满足条件时立即终止流的遍历。这意味着，如果在流的中途满足了某个条件，就可以跳出循环，不必遍历剩下的元素，从而提高程序的效率。

List<String> list = Arrays.asList("a", "b", "c", "d");
list.stream().takeWhile(s -> !s.equals("c")).forEach(System.out::println); // 输出 a, b

在这个例子中，使用 takeWhile 短路操作，只打印列表中前两个元素，因为当遇到第三个元素 "c" 时，满足条件 !s.equals("c")，条件短路，后面的元素就不再遍历了。

流必须关闭

流使用完毕后，必须关闭。如果不及时关闭流，可能会导致资源泄露和性能问题。

List<String> list = Arrays.asList("a", "b", "c", "d");
try (Stream<String> stream = list.stream()) {
  stream.forEach(System.out::println); // 正常输出 a, b, c, d
} // 在 try 块完成后，流会自动关闭

在上述代码中，使用了 try-with-resources 语句块，可以确保流被使用完毕后即时关闭。

流不能在多线程中共享

流是非线程安全的，因此不能在多线程中共享。如果需要并行处理流，可以使用并行流，具体内容可以参考 Java并行流 - Java。

总结

本文介绍了Java流的一些限制，包括只能遍历一次、可以被短路操作终止、必须关闭以及不能在多线程中共享。在使用流时，需要注意这些限制，以避免遇到意外的问题。