蒸汽操作修改实际列表

Question

我在某处读到过，流操作总是在终端操作时返回一个新集合，并且不会更改已应用流操作的原始集合。

但在我的情况下，原始列表已被修改。

 return subscriptions.stream()
            .filter(alertPrefSubscriptionsBO -> (alertPrefSubscriptionsBO.getType() == AlertPrefContactTypeEnum.PRIMARY_CONTACT || alertPrefSubscriptionsBO.getType() == AlertPrefContactTypeEnum.SECONDARY_CONTACT))
            .map(alertPrefSubscriptionsBO -> {
                if (alertPrefSubscriptionsBO.getType() == AlertPrefContactTypeEnum.PRIMARY_CONTACT) {
                    alertPrefSubscriptionsBO.setType(AlertPrefContactTypeEnum.PRIMARY);
                } else
                    alertPrefSubscriptionsBO.setType(AlertPrefContactTypeEnum.SECONDARY);

                return alertPrefSubscriptionsBO;
            })
            .collect(groupingBy(AlertPrefSubscriptionsBO::isActiveStatus, groupingBy(AlertPrefSubscriptionsBO::getAlertLabel, Collectors.mapping((AlertPrefSubscriptionsBO o) -> o.getType()
                    .getContactId(), toSet())
            )));

修改此操作后，订阅列表仅包含AlertPrefContactTypeEnum。PRIMARY和AlertPrefContactTypeEnum。次要对象。我的意思是列表的大小保持不变，但值发生了变化。

Answer 1

这是因为您违反了映射（函数）的约定

参数：映射器-应用于每个元素的无干扰、无状态函数

你违反了“无国籍”部分：

无状态行为

如果流操作的行为参数是有状态的，则流管道结果可能不确定或不正确。有状态lambda（或实现适当功能接口的其他对象）的结果取决于流管道执行期间可能更改的任何状态。有状态lambda的一个示例是中的参数

Set<Integer> seen = Collections.synchronizedSet(new HashSet<>());
stream.parallel().map(e -> { if (seen.add(e)) return 0; else return e; })...

在这里，如果并行执行映射操作，则由于线程调度的差异，相同输入的结果可能因运行而异，而对于无状态lambda表达式，结果总是相同的。

还要注意的是，试图从行为参数访问可变状态，在安全性和性能方面给您带来了一个错误的选择；如果不同步对该状态的访问，则存在数据竞争，因此代码被破坏，但如果同步对该状态的访问，则存在争用风险，从而破坏了您希望从中受益的并行性。最好的方法是完全避免流操作的有状态行为参数；通常有一种方法可以重构流管道以避免状态性。

实现该映射操作的正确方法是复制alertPrefSubscriptionsBO并为副本提供新类型。

遵循java使用的样式。时间类，例如用xxx（…）查看所有的 ZonedDateTime的方法，您可以将alertPrefSubscriptionsBO对象设置为不可变的，或者将其视为不可变的，并且具有用于获取属性已更改的副本的方法，例如使用类型为（…）的方法

.map(bo -> bo.withType(bo.getType() == PRIMARY_CONTACT ? PRIMARY : SECONDARY))