を実行し、私はこのコードでVERTXのmongoclientを使用しています複数の非同期クエリ

Question

完了後のクエリ：私たちが知っているように、すべての古いコレクションが
しかしを削除された後、いくつかの新しいコレクションを作成したい

mongoClient.getCollections(res -> { 
     if (res.succeeded()) { 
      if (res.result().size() > 0) { 
       for (String collection : res.result()) { 
        mongoClient.dropCollection(collection, resDrop -> { 
         if (resDrop.succeeded()) { 
          LOGGER.warn(collection + "was dropped"); 
         } 
        }); 
       } 
      } else LOGGER.warn("database was dropped"); 
     } else LOGGER.warn("database was dropped"); 
    }); 

、非同期的に実行されるコレクションの削除 古いコレクションがすべて削除されたときはどうすればわかりますか？

Answer 1

mongoClient.getCollections(res -> { 
     if (res.succeeded()) { 
      if (res.result().size() > 0) { 
       **List<Future> futureList = new ArrayList<>();** 
       for (String collection : res.result()) { 
        mongoClient.dropCollection(collection, resDrop -> { 
         if (resDrop.succeeded()) { 
          **Future future = Future.future(); 
          futureList.add(future); 
          future.complete();** 
          LOGGER.warn(collection + "was dropped"); 
         }else{ 
          future.fail(ar.cause()); 
         } 

        }); 
       } 

       **CompositeFuture.all(futureList).setHandler(ar -> { 
        if (ar.succeeded()) { 
         LOGGER.info("All collections was dropped"); 
        } else { 
         LOGGER.warn("One or all collections was not dropped"); 
        } 
       });** 
      } else LOGGER.warn("database was dropped"); 
     } else LOGGER.warn("database was dropped"); 
    }); 

Answer 2

これは一般的なasynchronous coordinationの問題です。 Vert.xのドキュメントのConcurrent compositionのセクションをご覧ください。

Answer 3

CompletableFuturesを使用することをお勧めします。 allOfメソッドを呼び出すことができます。