eine Abfrage nach Abschluss der mehrere asynchrone Abfragen

Question

Ich verwende VertX mongoclient mit diesem Code:

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"); 
    }); 

Ich möchte einige neue Kollektionen Nachdem alle alten Kollektionen erstellen haben abgeworfen worden
Aber wie wir wissen, Ablegen von Sammlungen, die asynchron ausgeführt werden Wie kann ich herausfinden, wann alle alten Sammlungen gelöscht wurden?

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

Dies ist eine gemeinsame asynchronous coordination Problem. Sehen Sie sich den Abschnitt Concurrent composition in der Vert.x-Dokumentation an.

Answer 3

Ich würde empfehlen, CompletableFutures zu verwenden. Sie können die allOf Methode aufrufen.