Wait for List of CompletableFuture

Question

How to wait for list of futures for 15 minutes( if not completed) and not each future? Below code will wait for each future for 15 minutes.But thats's not what i want

for (CompleteableFuture<String> m : futureList) {
        m.get(15, TimeUnit.MINUTES) ;
}

Syso( " Send email") ;

Maybe you could keep track of how much time passed and only wait for the remaining time in subsequent iterations? — Amongalen, Apr 28 '20 at 12:44
If switching to Guava is an option to you then you could use `com.google.common.util.concurrent.Futures#allAsList(ListenableFuture...)` — michid, Apr 28 '20 at 12:54
Yes actually i am getting List>> myKafkaFutures But allAsList doesn't have option of passing Time — Pale Blue Dot, Apr 28 '20 at 14:39

score 1 · Answer 1 · answered Apr 28 '20 at 12:57

1

Use CompletableFuture.allOf() like so:

       CompletableFuture.allOf(futureList).get(15, TimeUnit.MINUTES);

answered Apr 28 '20 at 12:57

michid

10,536
3
32
59

Note that `allOf()` takes an array. If `futureList` is a `List` or `Collection` it'll need to be converted. – John Kugelman Apr 28 '20 at 12:59

Wait for List of CompletableFuture

1 Answers1