我是 Java 8 的初学者。
无干扰对于保持一致的 Java 流行为很重要。 想象一下，我们正在处理大量数据，并且在此过程中 源变了。结果将是不可预测的。这是 不考虑流并行的处理模式或 顺序。
源可以修改，直到语句终端操作为 调用。除此之外，源不应该被修改，直到流 执行完成。所以处理流中的并发修改 源对于获得一致的流性能至关重要。
以上引文摘自here。
有人可以做一些简单的例子来解释为什么改变流源会产生如此大的问题吗？
【问题讨论】：
标签： java java-8 java-stream
预言机example 在这里是不言自明的。第一个是这样的：
List<String> l = new ArrayList<>(Arrays.asList("one", "two"));
Stream<String> sl = l.stream();
l.add("three");
String s = l.collect(Collectors.joining(" "));
如果你改变l，在之前再添加一个元素你调用终端操作（Collectors.joining）你没问题；但请注意，Stream 由三个元素组成，而不是两个；在您通过l.stream() 创建流时。
另一方面，这样做：
List<String> list = new ArrayList<>();
list.add("test");
list.forEach(x -> list.add(x));
将抛出ConcurrentModificationException，因为您无法更改源。
现在假设您有一个可以处理并发添加的底层源：
ConcurrentHashMap<String, Integer> cMap = new ConcurrentHashMap<>();
cMap.put("one", 1);
cMap.forEach((key, value) -> cMap.put(key + key, value + value));
System.out.println(cMap);
这里的输出应该是什么？当我运行它时：
{oneoneoneoneoneoneoneone=8, one=1, oneone=2, oneoneoneone=4}
把key改成zx（cMap.put("zx", 1)），现在的结果是：
{zxzx=2, zx=1}
结果不一致。
【讨论】：
list.forEach(x -> list.add(x)); 的歧义，如果它没有抛出ConcurrentModificationException，但通过与ConcurrentHashMap 进行比较来证明它是一个好主意……
forEach 不会在容量增加时注意到新状态。您可以尝试ConcurrentHashMap<Integer, Integer> cMap = new ConcurrentHashMap<>(1000, 1f); cMap.put(1, 1); cMap.forEach((key, value) -> cMap.put(key + 1, 0)); 并使用初始容量。当容量增加时，您会看到迭代停止（四舍五入到 2 的下一次幂）。
spread 函数的效果，例如： ConcurrentHashMap<Integer, Integer> cMap = new ConcurrentHashMap<>(200_000_000, 1f); cMap.put(1, 1); cMap.forEach((key, value) -> cMap.put(++value^(value>>>16), value)); 在我的机器上运行了几分钟，已经消耗了几个 GB，不知道它是否或何时会退出......
for ((Map.Entry<K, V> entry : map.entrySet()) action.accept(entry.getKey(), entry.getValue());，这意味着行为应该as weakly consistent as the entryset iterator。