《stream》专题

问题内容： Java 8中的Streams是否有等效于getLineNumber（）的东西？ 我想在文本文件中搜索单词，然后将行号返回为Integer。这是我的搜索方法： 问题答案： 我不认为这是因为，流并非旨在提供对元素的访问，而不是像集合那样。 一种解决方法是读取列表中的文件，然后使用生成相应的索引，然后可以从中应用过滤器： 由于您冒着将整个文件的内容加载到列表中，可能只保留一些元素的风险，所

问题内容： 我刚刚开始玩Java 8和Lambda Expression，我很好奇是否可以通过返回特定值（例如null）从Lambda表达式内部停止Stream生成。Stream.generate（）是否可能？ 不幸的是，此代码不会终止，因此仅返回就不会退出流。 问题答案： 对于Lamdas，这是不可能的，您无法从表达式内部控制流。甚至API文档都说Stream.generate生成无限流。 但是

问题内容： 我想创建一个构建增量数字数组的函数。 例如，我想要获得类似的东西： 该函数将接收两个参数：数组的起始编号（包括起始编号）和最终长度： 我知道如何使用for循环： 我要使用Java 8 Stream API，而不是使用for循环。有人知道如何使用Stream API做到这一点吗？ 问题答案： 已经有一个内置方法： 以1为增量返回从开始（包括）到结束（不包括）的顺序。 如果要包含end元素

问题内容： 我有一个对象流，我想找到一个具有某些属性最大值的对象，该属性的计算成本很高。 作为一个简单的具体示例，假设我们有一个字符串列表，并且希望找到给定功能的最酷的字符串。 以下应该工作： 现在，这有两个问题。首先，假设计算起来很昂贵，这可能不是很有效。我想该方法将需要重复使用比较器，该比较器将依次重复调用，最后每个字符串将被多次调用。 其次，必须提供比较器会导致代码有些冗余。我更喜欢这样的语

问题内容： 在并行流上使用操作时，OCP考试手册指出，论点必须遵守某些原则。这些原则如下： 必须定义身份，以便对于流u中的所有元素，combiner.apply（identity，u）等于u。 累加器运算符op必须是关联且无状态的，等于。 组合器运算符还必须是关联且无状态的，并且必须与该身份兼容，以使得对于和 都等于。 本书提供了两个示例来说明这些原理，请参见下面的代码： 关联的示例： 这本书怎么

问题内容： 由于增加了头的记录（ProducerRecord＆ConsumerRecord）在卡夫卡0.11，是有可能处理与卡夫卡流的话题时，得到这些标题？当调用类似on的方法时，它提供记录的和的参数，但是我看不到访问的方法。如果我们可以刚好超过s ，那就太好了。 例如 这样的事情会工作： 问题答案： 自Streams API 2.0版以来，可以访问记录头。（有关详细信息，请参见KIP-244。）

问题内容： 我正在尝试将for循环转换为功能代码。我需要展望一种价值，也要展望一种价值。可以使用流吗？以下代码将罗马文本转换为数字值。不确定带有两个/三个参数的reduce方法是否可以在这里提供帮助。 问题答案： 不，至少在流中使用流是不可能的。流API从处理元素的顺序中抽象出来：流可以并行或以相反顺序处理。因此，流抽象中不存在“下一个元素”和“上一个元素”。 您应该使用最适合此工作的API：如果

问题内容： 在Java 8中，该类没有任何包装的方法。 相反，我从中获取，然后像这样从中获取： 还有其他在我缺少的操作上生成操作的方式吗？ 问题答案： 我的类似问题被标记为重复，但这是我用来避免某些样板的辅助方法：

问题内容： 考虑以下代码片段 Java的为什么能保证在收集情况的正确类型（改变一个编译时错误的一般类型的收集到如双引线），但不是在阵列情况下（编译罚款，尽管中给出了一个，而不是一个，而是抛出如果如上所述使用不正确）？ 如果我更改流的类型而不更改调用中给定的值，那么生成编译时错误的最佳方法是什么？ 问题答案： 该方法的签名如下所示。请注意，类型参数和完全无关。 在ReferencePipeline.

问题内容： 我想澄清一下，我正在寻找一种使用Streams计算标准偏差的方法（我目前有一种工作方法可以计算并返回SD，但不使用Streams）。 我正在使用的数据集紧密匹配，如Link中所示。如该链接所示，能够对我的数据进行分组并获得平均值，但无法弄清楚如何获取SD。 码 我还检查了DoubleSummaryStatistics上的链接，但似乎对SD没有帮助。 问题答案： 您可以将自定义收集器用于

问题内容： 我有两种方法来从Android内部存储中的文件进行加密保存和解密加载对象。 加密和保存过程已完成，没有任何问题，但是当我要加载对象时， 我搜索的次数越来越多，但没有找到解决问题的方法。所有其他解决方案都是为了延长插座寿命或类似的。 我的代码如下： 保存方法：（工作正常） 加载方法：（无法从中加载对象） 公开的保存和加载方法： 问题答案： 您正在犯至少两个主要错误。 您必须使用与加密相同

问题内容： 假设我们有这个流 我想在地图中保存几对相邻的字符串，其中第一个以“ err”开头。 我想到的就是这样 但是我对它并不完全满意，主要有两个原因 我在“滥用” 功能。在Stream API中，每个函数都有其明确的定义明确的目的：应该计算最大值，应该根据条件进行过滤，应该产生递增的累加值，依此类推。 这样做会使我无法使用Streams强大的机制：如果我想将搜索范围限制在前两个结果中，该怎么办

问题内容： 我有两个（或更多）对象。我想将它们与Java 8 Stream API合并，以使通用密钥的值应为最大值。 如何使该测试方法绿色？ 我已经打了，并有一阵子没有任何成功。 （并且来自Google Guava。） 问题答案：

问题内容： 让我们简单地输入数字1..20： 现在，让我们创建一个并行流，结合以不同的方式和收集的结果： 过滤步骤在这里基本上不执行任何操作，但是给流引擎增加了更多难度：现在它不知道输出的确切大小，因此一些优化被关闭了。我得到以下结果： 结果完全正确，一切正常。在第一种情况下，我要求跳过前两个元素，然后以没有特定的顺序收集到列表。在第二种情况下，我要求跳过第一个元素，然后变成无序并跳过另一个元素（

问题内容： Javadoc 表示（重点是我）： 该操作的行为明确地是不确定的。 对于并行流管道，此操作不能保证遵守流的遇到顺序 ，因为这样做会牺牲并行性的好处。对于任何给定的元素，可以在库选择的任何时间和线程中执行操作。如果操作访问共享状态，则它负责提供所需的同步。 Java 9 Early Access Javadoc中提供了相同的文本。 第一句话（“明确地不确定”）表明（但未明确说明）此方法未