我有一个 HashMap<String, CompletableFuture<HashMap<String, String>>> 将项目Map到其属性，例如。 { "pizza" -> { "calories" -> "120", "fat" -> "12" } } ，其中从不同的数据源检索属性。
例如，我们得到 "fat" 属性，而我们得到 "calories" 来自solr的属性。
当我最初找回 "fat" 从数据库，我用 supplyAsync 为了不阻塞主线程，例如：

public CompletableFuture<HashMap<String, String>> getFat(String name, boolean) {
    return CompletableFuture.supplyAsync(new Supplier<HashMap<String, String>>() {
      @Override
      public HashMap<String, String> get() {
        HashMap<String, String> attributes = new HashMap<>();

        ... do work ...

        attributes.put(name, attributes);
        return attributes;
      }
   })
 }

然后，我通过对solr的异步调用将其链接起来，这样最终会有一个异步hashmap将项Map到它们的属性，即 HashMap<String, CompletableFuture<HashMap<String, String>>> itemsToAttributesMapping; （因此，我循环遍历hashmap的键，并使用新属性更新值，使用 thenApply ).
最后，我将数据Map到csv，这就是问题所在：

File file = new File(home + "/Downloads/rmsSkuValidationResults.csv");

       try{
          FileWriter outputfile = new FileWriter(file);
          CSVWriter writer = new CSVWriter(outputfile);

            for(String itemKey : itemsToAttributesMapping.keySet()) {
                itemsToAttributesMapping.get(itemKey).thenAccept(attributes -> {

                String[] row = { attributes.get("calories"),
                            attributes.get("fat")

                        ... more attributes ...

                        };
                writer.writeNext(row);
                });
            }

         writer.close();
      }
      catch(Exception e){
        e.printStackTrace();
      }

按原样，打印到csv文件对于大约800-1100个项目可以正常工作，但之后停止写入，程序终止。
我尝试了以上的变体，包括使用 get 而不是 thenAccept ，或添加 join 之后 thenAccept 导致程序挂起（异步计算很快，不应该挂起）。
我还尝试存储 thenAccepts 我跑，然后打电话 allOf 但这会导致奇怪的行为，即solr的属性在几百个项目之后不再显示。数据库中的属性确实会显示在每个项目上，这让我首先想到 supplyAsync 总是有效的，但是随后 thenApply 将属性添加到原始 HashMap<String, CompletableFuture<HashMap<String, String>>> itemsToAttributesMapping; 由供应商提供 supplyAsnc 停止工作。
如果您能深入了解问题所在，我们将不胜感激。也许我对完全未来的理解是错误的，特别是在链接和解析未来方面？这可能是超时问题，或者线程正在丢失？最后一个我扩展的方法表明，也许问题是 thenApply 什么？