Java流阶段是连续的吗？

Question

我有一个关于中间阶段顺序状态的问题--是一个阶段的操作应用于所有输入流（项），还是所有阶段/操作应用于每个流项？

我知道这个问题可能不容易理解，所以我举一个例子。关于以下流处理：

List<String> strings = Arrays.asList("Are Java streams intermediate stages sequential?".split(" "));
strings.stream()
           .filter(word -> word.length() > 4)
           .peek(word -> System.out.println("f: " + word))
           .map(word -> word.length())
           .peek(length -> System.out.println("m: " + length))
           .forEach(length -> System.out.println("-> " + length + "\n"));

f: streams
f: intermediate
f: stages
f: sequential?

m: 7
m: 12
m: 6
m: 11

-> 7
-> 12
-> 6
-> 11

f: streams
m: 7
-> 7

f: intermediate
m: 12
-> 12

f: stages
m: 6
-> 6

f: sequential?
m: 11
-> 11

如果这个问题不够清楚，我可以进一步详细说明。

Answer 1

这种行为可以优化代码。如果每个中间操作都要在进行下一个中间操作之前处理流的所有元素，那么就没有优化的机会。

因此，为了回答您的问题，每个元素沿着流管道一次一个地垂直移动（后面讨论的一些有状态操作除外），因此可以在可能的情况下进行优化。

根据您提供的示例，每个元素将沿着流管道逐个垂直移动，因为没有包含有状态的操作。

List<String> stringsList = Arrays.asList("1","12","123","1234","12345","123456","1234567");
int result = stringsList.stream()
                        .filter(s -> s.length() > 4)
                        .mapToInt(Integer::valueOf)
                        .findFirst().orElse(0);

阅读：Java 8流教程