java – 有没有办法压缩两个流？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – 有没有办法压缩两个流？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1001字，纯文字阅读大概需要2分钟。

内容图文

这个问题来自于another question的答案,其中建议map和reduce同时计算一个和.

在那个问题中有一个复杂的计算(e),但现在我想知道如何通过将计算分成两部分来进行更多的并行化,以便complexCalculation(e)= part1(e)* part2(e).我想知道是否有可能同时计算集合上的part1和part2(再次使用map())然后压缩两个结果流,以便两个流的第i个元素与函数*组合,以便生成的流等于可以通过在该集合上映射complexCalculation(e)获得的流.在代码中,这看起来像：

Stream map1 = bigCollection.parallelStream().map(e -> part1(e));
Stream map2 = bigCollection.parallelStream().map(e -> part2(e));
// preferably map1 and map2 are computed concurrently...
Stream result = map1.zip(map2, (e1, e2) -> e1 * e2);

result.equals(bigCollection.map(e -> complexCalculation(e))); //should be true

所以我的问题是：是否存在一些功能,比如我试图在这里描述的zip功能？

解决方法:

parallelStream()保证在提交的顺序中完成.这意味着您不能假设两个parallelStream可以像这样压缩在一起.

您的原始bigCollection.map(e – > complexCalculation(e))可能会更快,除非您的集合实际上小于您拥有的CPU数量.

内容总结

以上是互联网集市为您收集整理的java – 有没有办法压缩两个流？全部内容，希望文章能够帮你解决java – 有没有办法压缩两个流？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端