Java 8 Streams中产生副作用的危险是什么？

从Javadoc：

还要注意，尝试从行为参数访问可变状态会给您带来安全性和性能方面的错误选择；
如果您不同步对该状态的访问，则将导致数据争用，因此代码将被破坏，但是如果您确实同步对该状态的访问，则可能会导致争用破坏您要从中受益的并行性
。最好的方法是避免使用有状态的行为参数来完全流式处理操作。通常有一种方法可以重组流管道以避免状态化。

这里的问题是，如果您访问可变状态，则会在两个方面松动：

安全，因为您需要
```
Stream
```
尽量减少同步的同步
性能，因为所需的同步使您付出了代价（在您的示例中，如果使用
```
ConcurrentHashMap
```
，则要付出代价）。

现在，在您的示例中，这里有几点：

如果要使用
```
Stream
```
多线程流，则需要使用
```
parralelStream()
```
in
```
myThings.parralelStream()
```
；就目前而言，所
```
forEach
```
提供的方法
```
java.util.Collection
```
很简单
```
for each
```
。
您
```
HashMap
```
用作
```
static
```
成员并对其进行突变。
```
HashMap
```
不是线程安全的；您需要使用
```
ConcurrentHashMap
```
。

在lambda中，对于a

Stream

，您不得更改流的源：

myThings.stream().forEach(thing -> myThings.remove(thing));

这可能有效（但我怀疑会抛出

ConcurrentModificationException

），但这可能不起作用：

myThings.parallelStream().forEach(thing -> myThings.remove(thing));

那是因为

ArrayList

不是线程安全的。

如果您使用同步视图（

Collections.synchronizedList

），则将获得性能，因为您在每次访问时都进行了同步。

在您的示例中，您宁愿使用：

sortOrderCache = myThings.stream()   .collect(Collectors.groupingBy(     Thing::getId, Thing::getSortOrder);preNameCache= myThings.stream() .collect(Collectors.groupingBy(   Thing::getId, Thing::getCodeName);

装订器（此处为

groupingBy

）完成您正在做的工作，并且可能会被顺序调用（我的意思是，Stream可能会拆分为多个线程，装订器可能会被调用多次（在不同的线程中），然后可能需要合并。

顺便说一句，您最终可能会删除

preNameCache

sortOrderCache

并仅存储id-> Thing映射。

Java 8 Streams中产生副作用的危险是什么？

面试问答相关栏目本月热门文章