用Java将[chained] CompletableFutures写入CSV

我HashMap<String, CompletableFuture<HashMap<String, String>>>将一个项目映射到它的属性，例如{ "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映射项到它们的属性，即HashMap<String, CompletableFuture<HashMap<String, String>>> itemsToAttributesMapping;（因此，我遍历了hashmap的键并用新属性更新值，使用来访问旧属性thenApply）。

我首先将数据映射到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导致程序挂起之后添加（异步计算速度很快，不应挂起）。

我也尝试过存储thenAcceptsI运行的结果，然后调用allOf它们，但这会导致奇怪的行为，Solr的属性在几百个项目后就会停止显示。数据库中的属性确实会出现在每个项目中，这使我认为第一个supplyAsync始终有效，但随后thenApply的会将属性添加到HashMap<String, CompletableFuture<HashMap<String, String>>> itemsToAttributesMapping;由supplyAsnc停止工作提供的原始属性中。

对于可能是问题的任何见解将不胜感激。也许我对CompletableFuture的理解是不正确的，尤其是在链接和解决期货方面？也许这是超时问题，或者线程丢失了？我扩展的最后一种方法表明问题可能是thenApplys？