Searched refs:cfs (Results 1 – 3 of 3) sorted by relevance
151 List<CompletableFuture<T>> cfs = Stream.generate(() -> CompletableFuture.supplyAsync(s)). in testRandomResultSupplierConcurrently() local157 …CompletableFuture<Void> all = CompletableFuture.allOf(cfs.stream().toArray(CompletableFuture[]::ne… in testRandomResultSupplierConcurrently()161 long rc = cfs.stream().map(CompletableFuture::join).distinct().count(); in testRandomResultSupplierConcurrently()
1484 static CompletableFuture<Void> andTree(CompletableFuture<?>[] cfs, in andTree() argument1492 if ((a = (lo == mid ? cfs[lo] : in andTree()1493 andTree(cfs, lo, mid))) == null || in andTree()1494 (b = (lo == hi ? a : (hi == mid+1) ? cfs[hi] : in andTree()1495 andTree(cfs, mid+1, hi))) == null) in andTree()2406 public static CompletableFuture<Void> allOf(CompletableFuture<?>... cfs) { in allOf() argument2407 return andTree(cfs, 0, cfs.length - 1); in allOf()2425 public static CompletableFuture<Object> anyOf(CompletableFuture<?>... cfs) { in anyOf() argument2427 if ((n = cfs.length) <= 1) in anyOf()2430 : uniCopyStage(cfs[0]); in anyOf()[all …]
146 …eFuture<java.lang.Void> allOf(java.util.concurrent.CompletableFuture<?>... cfs) { throw new Runtim… in allOf() argument148 …uture<java.lang.Object> anyOf(java.util.concurrent.CompletableFuture<?>... cfs) { throw new Runtim… in anyOf() argument