我应该使用共享可变变量更新Java8流

Question

只是在列表下面迭代

List<String> list1 = Arrays.asList("A1","A2","A3","A4","A5","A6","A7","A8","B1","B2","B3");
List<String> list2 = new ArrayList<>();

Consumer<String> c = t -> list2.add(t.startsWith("A") ? t : "EMPTY");

list1.stream().forEach(c);
list1.parallelStream().forEach(c);
list1.forEach(c);

以上三个迭代有什么区别

Answer 1

在使用流时，您应该以这样的方式编写代码：如果切换到并行流，它不会产生错误的结果。

想象一下，如果您在代码中对同一个共享内存(list2)进行读写操作，并将您的进程分布到几个线程中(使用并行流)。那你就完了。因此，你有几个选择。

使共享内存（list2）线程安全。例如，通过使用AtomicReferences

List<String> list2 = new ArrayList<>();
AtomicReference<List<String>> listSafe = new AtomicReference<>();
listSafe.getAndUpdate(strings -> {strings.add("newvalue"); return strings;}); 

或者，您可以使用纯函数式方法（没有副作用的代码），例如@Eran解决方案。

Answer 2

从功能上来说，对于简单的情况它们几乎是相同的，但是一般来说，有一些隐藏的差异:

< li >让我们首先引用< code>forEach的Javadoc中关于可迭代用例的陈述:

为Iterable的每个元素执行给定的操作，直到处理完所有元素或该操作引发异常。

此外，我们还可以迭代一个集合并对每个元素执行给定的操作——只需传递一个实现 Consumer 接口的类

void forEach(Consumer<? super T> action)

https://docs . Oracle . com/javase/8/docs/API/Java/lang/iterable . html # forEach-Java . util . function . consumer-

https://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html#fail-fast

更多信息:

< li >有什么区别。foreach和。流()。foreach？ < Li > collection . stream()与。forEach()和Collection.forEach()？

Answer 3

无论使用并行流还是顺序流，当目标是生成列表时，都不应使用 forEach。将地图与收集一起使用：

List<String> list2 = 
    list2.stream()
         .map(item -> item.startsWith("A") ? item : "EMPTY")
         .collect(Collectors.toList());