在Java streams中，peek真的只用于调试吗？
我正在阅读有关Java streams的知识，并在学习的过程中发现一些新的东西。我发现的新功能之一是peek()函数。我在peek上读到的几乎所有东西都说它应该用来调试你的流。
如果我有一个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();
})回答 8
Stack Overflow用户
发布于 2015-11-11 01:55:22
这一点的关键是：
不要以意外的方式使用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());Stack Overflow用户
发布于 2015-11-11 01:50:31
您必须了解的重要事情是，流是由终端操作驱动的。终端操作确定是否必须处理所有元素，或者根本不处理任何元素。因此，collect是一个处理每个项目的操作，而findAny可能会在遇到匹配元素时停止处理项目。
当count()可以在不处理项的情况下确定流的大小时，它可能根本不处理任何元素。由于这不是在Java8中进行的优化，但将在Java9中进行，因此当您切换到Java9并拥有依赖于count()处理所有项的代码时，可能会有惊喜。这也与其他依赖于实现的细节有关，例如，即使在Java9中，参考实现也无法预测与limit结合的无限流源的大小，同时没有阻止此类预测的基本限制。
由于peek允许“在从结果流中消费元素时对每个元素执行所提供的操作”，因此它不强制处理元素，但将根据终端操作的需要执行操作。这意味着如果你需要一个特殊的处理，比如想要在所有元素上应用一个动作，你必须非常小心地使用它。如果终端操作保证处理所有项，那么它就可以工作，但即使这样，您也必须确保不会有下一个开发人员更改终端操作(否则您会忘记这一微妙的方面)。
此外，尽管streams保证即使对于并行流也能保持某个操作组合的相遇顺序，但这些保证不适用于peek。当收集到一个列表中时，结果列表将具有有序并行流的正确顺序，但peek操作可能会以任意顺序并发调用。
因此，使用peek可以做的最有用的事情就是找出流元素是否已经被处理，这正是API文档所说的：
此方法主要用于支持调试，您希望在元素流过管道
中的某个点时查看这些元素
Stack Overflow用户
发布于 2016-11-11 20:52:02
也许经验法则应该是，如果您在"debug“场景之外使用peek，那么只有在您确定终止和中间过滤条件是什么时才应该这样做。例如：
return list.stream().map(foo->foo.getBar())
.peek(bar->bar.publish("HELLO"))
.collect(Collectors.toList());在一个操作中，将所有Foo转换为Bars并告诉它们所有的hello，这似乎是一个有效的例子。
看起来比像这样的东西更高效和优雅：
List<Bar> bars = list.stream().map(foo->foo.getBar()).collect(Collectors.toList());
bars.forEach(bar->bar.publish("HELLO"));
return bars;而且，您不会最终重复两次集合。
https://stackoverflow.com/questions/33635717
复制相似问题