在 Java 流中 peek 真的只用于调试吗？

Question

我正在阅读有关 Java 流的内容，并在阅读过程中发现新事物。我发现的新事物之一是 peek() 函数。我在 peek 上读到的几乎所有内容都说它应该用于调试您的 Streams。

如果我有一个 Stream，其中每个帐户都有一个用户名、密码字段以及一个 login() 和 loggedIn() 方法会怎么样。

我也有

Consumer<Account> login = account -> account.login();

和

Predicate<Account> loggedIn = account -> account.loggedIn();

为什么会这么糟糕？

 List<Account> accounts; //assume it's been setup
List<Account> loggedInAccount =
accounts.stream()
    .peek(login)
    .filter(loggedIn)
    .collect(Collectors.toList());

现在，据我所知，这完全符合预期。它;

• 获取帐户列表
• 尝试登录每个帐户
• 过滤掉任何未登录的帐户
• 将登录帐户收集到新列表中

这样做的缺点是什么？我有什么理由不应该继续吗？最后，如果不是这个解决方案那又是什么？

原始版本使用 .filter() 方法如下；

 .filter(account -> {
        account.login();
        return account.loggedIn();
    })

原文由 Adam.J 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

从中得出的关键结论是：

不要以无意的方式使用 API，即使它可以实现您的近期目标。 这种方法将来可能会失效，未来的维护者也不清楚。

---

将其分解为多个操作并没有什么坏处，因为它们是不同的操作。以不明确和意外的方式使用 API 是 有害的，如果在未来的 Java 版本中修改了这种特定行为，则可能会产生后果。

在此操作上使用 forEach 将使维护者清楚地知道 accounts 的每个元素都有 预期 的副作用，并且您正在执行一些可以改变它的操作。

从某种意义上说，它也更传统 peek 是一个中间操作，在终端操作运行之前不会对整个集合进行操作，但是 forEach 确实是一个终端操作。这样，您可以围绕代码的行为和流程提出强有力的论据，而不是询问有关 peek 是否与 forEach 在此上下文中的行为相同的问题。

 accounts.forEach(a -> a.login());
List<Account> loggedInAccounts = accounts.stream()
                                         .filter(Account::loggedIn)
                                         .collect(Collectors.toList());

原文由 Makoto 发布，翻译遵循 CC BY-SA 3.0 许可协议

Answer 2

您必须了解的重要一点是，流是由 终端操作 驱动的。终端操作确定是否必须处理所有元素或根本不处理任何元素。所以 collect 是一个处理每个项目的操作，而 findAny 可能会在遇到匹配元素时停止处理项目。

并且 count() 可以在不处理项目的情况下确定流的大小时根本不处理任何元素。由于这不是在 Java 8 中进行的优化，而是在 Java 9 中进行的，因此当您切换到 Java 9 并让代码依赖于 count() 处理所有项目时，可能会有惊喜。这也与其他依赖于实现的细节有关，例如，即使在 Java 9 中，参考实现也无法预测与 limit 结合的无限流源的大小，虽然没有基本的限制来阻止这种情况预言。

由于 peek 允许“在 从结果流中消耗元素时 对每个元素执行提供的操作”，它不强制处理元素，但将根据终端操作的需要执行操作。这意味着如果您需要特定的处理，您必须非常小心地使用它，例如，想要对所有元素应用一个动作。如果保证终端操作处理所有项目，它就可以工作，但即使那样，您也必须确保下一个开发人员不会更改终端操作（否则您会忘记那个微妙的方面）。

此外，虽然流保证即使对于并行流也能维持特定操作组合的相遇顺序，但这些保证不适用于 peek 。当收集到列表中时，生成的列表将具有有序并行流的正确顺序，但 peek 操作可能会以任意顺序并发调用。

因此，您可以使用 peek 做的最有用的事情是查明流元素是否已被处理，这正是 API 文档所说的：

此方法的存在主要是为了支持调试，您希望在元素流过管道中的某个点时查看元素

原文由 Holger 发布，翻译遵循 CC BY-SA 4.0 许可协议