序列流与共享状态

Question

javadoc forjava.util.stream意味着流管道中的“行为操作”通常必须是无状态的。然而，它所展示的如何不编写管道的示例似乎都涉及并行流。

这在多大程度上适用于顺序流？

List<SomeClass> list = ...;
Map<SomeClass, String> map = new HashMap<>();
list.stream()
    .filter(x -> [some boolean expression])
    .forEach(x -> {
         if (map.containsKey(x) {
             throw new UserDefinedException("duplicates detected in input");
         } else {
             map.put(x, aStringFunction(x));
         }
     });

我的问题是：我紧张是对的，还是上面的代码值得信任？

假设filter()中的表达式使用了某种共享状态。当使用顺序流时，我们能相信它会正常工作吗？

Answer 1

根据定义，顺序流执行调用者线程中的所有内容，因此，如果您将来不打算并行化您的流，您可以安全地使用共享状态，而无需额外的同步和并发安全集合。所以当前的代码是安全的。然而请注意，它只是看起来很脏。