使用非并发数据结构源流的非干扰要求是否意味着在执行流管道期间我们无法更改数据结构元素的状态(除此之外我们无法更改源数据结构本身)？(问题1)
在关于非干扰的部分中,在流包描述中,它说:"对于大多数数据源,防止干扰意味着确保在流管道的执行期间根本不修改数据源."
这篇文章没有提到修改元素的状态？
例如,假设"形状"是非线程安全的集合(例如ArrayList),下面的代码是否被认为有干扰？(问题2)
shapes.stream()
.filter(s -> s.getColor() == BLUE)
.forEach(s -> s.setColor(RED));
这个例子取自可靠的来源(至少可以说),所以它应该是正确的.但是,如果我改变stream()了parallelStream(),它仍然是安全和正确的吗？(问题3)
另一方面,另一个可靠来源Naftalin Maurice的"掌握Lambdas"清楚地表明,通过管道操作改变元素的状态(值)确实是干扰.从关于不干涉的部分(3.2.3):
"但是流的规则禁止对流源进行任何修改 - 包括,例如,通过任何线程更改元素的值,而不仅仅是管道操作."
如果书中所说的是正确的,是否意味着我们不能使用Stream API来修改元素的状态(使用forEach),并且必须使用常规迭代器(或for-each,或Iterable.forEach)来做到这一点？(问题4)
我是Java 8的初学者.
对于具有一致的Java流行为,非干扰非常重要.想象一下,我们处理大量数据流,并在此过程中更改源.结果将是不可预测的.这与流并行或顺序的处理模式无关.
可以修改源,直到调用语句终端操作.除此之外,在流执行完成之前不应修改源.因此,处理流源中的并发修改对于获得一致的流性能至关重要.
以上引文取自此处.
有人可以做一些简单的例子来阐明为什么改变流源会产生如此大的问题吗？