使用流有条件地填充地图-Java8

Question

我试图翻译这个（简化）代码使用Java-8流：

Map<String, String> files = new ConcurrentHashMap<String, String>();

while(((line = reader.readLine()) != null) {
      if(content != null)
        files.put("not null"+line, "not null"+line);
      else
        files.put("its null"+line, "its null"+line);
    }
reader.close();

以下是我尝试过的：

files = reader.lines().parallel().collect((content != null)?
                (Collectors.toConcurrentMap(line->"notnull"+line, line->line+"notnull")) :                                              
                (Collectors.toConcurrentMap(line->line+"null", line->line+"null")));

但以上给出了所有行的“循环推理”消息-

我注意到了一些类似的问题。但他们建议使用接口（Map）而不是其实现。但是这里的文件被声明为映射。

更新：添加更多上下文，content是保存目录名称的字符串。files是保存多个文件路径的映射。进入file映射需要哪些文件路径取决于Content目录名称是否填充。




Answer 1

只是一个旁注。我对此表示怀疑。parallel（）在这种情况下很有用。如果您使用标准Java API读取文件，那么下面的迭代器仍将按顺序读取文件。唯一将并行执行的事情是转换行。出于好奇，我刚在我的电脑上试用了一下，没有它，速度大约快了10%。并行（）。

如果处理速度比读取流的输入慢一个数量级，那么并行化是有意义的，这里的情况并非如此。

Answer 2

你可以这样做

reader.lines().parallel()
    .map(line -> content == null ?
            new String[]{"notnull"+line, line+"notnull"} :
            new String[]{line+"null", line+"null"})
    .collect(Collectors.toConcurrentMap(pair -> pair[0], pair -> pair[1]));

首先，将该行映射到存储在数组（或某种类型的pair对象）中的（键、值）对，然后在收集器中再次将其拆分为键和值。

Answer 3

解决此问题的另一种方法是为收集器引入中间变量：

Collector<String, ?, ConcurrentMap<String, String>> collector = (content != null) ?
        (Collectors.toConcurrentMap(line->"notnull"+line, line->line+"notnull")) :
        (Collectors.toConcurrentMap(line->line+"null", line->line+"null"));
Map<String, String> files = reader.lines().parallel().collect(collector);       

此解决方案（与@JanXMarek提出的解决方案不同）不分配中间数组，也不检查每个输入行的内容。

循环推理是类型推理过程中的一种情况，当要确定内部子表达式的类型时，必须确定外部子表达式的类型，但如果不知道内部子表达式的类型，则无法确定外部子表达式的类型。Java-8中的类型推断可以在<代码>流的情况下推断