2614 |
|
*/ |
2615 |
|
public void testAllOf_normal() throws Exception { |
2616 |
|
for (int k = 1; k < 20; ++k) { |
2617 |
< |
CompletableFuture<Integer>[] fs = (CompletableFuture<Integer>[]) new CompletableFuture[k]; |
2617 |
> |
CompletableFuture<Integer>[] fs |
2618 |
> |
= (CompletableFuture<Integer>[]) new CompletableFuture[k]; |
2619 |
|
for (int i = 0; i < k; ++i) |
2620 |
|
fs[i] = new CompletableFuture<>(); |
2621 |
|
CompletableFuture<Void> f = CompletableFuture.allOf(fs); |
2623 |
|
checkIncomplete(f); |
2624 |
|
checkIncomplete(CompletableFuture.allOf(fs)); |
2625 |
|
fs[i].complete(one); |
2626 |
+ |
} |
2627 |
+ |
checkCompletedNormally(f, null); |
2628 |
+ |
checkCompletedNormally(CompletableFuture.allOf(fs), null); |
2629 |
+ |
} |
2630 |
+ |
} |
2631 |
+ |
|
2632 |
+ |
public void testAllOf_backwards() throws Exception { |
2633 |
+ |
for (int k = 1; k < 20; ++k) { |
2634 |
+ |
CompletableFuture<Integer>[] fs |
2635 |
+ |
= (CompletableFuture<Integer>[]) new CompletableFuture[k]; |
2636 |
+ |
for (int i = 0; i < k; ++i) |
2637 |
+ |
fs[i] = new CompletableFuture<>(); |
2638 |
+ |
CompletableFuture<Void> f = CompletableFuture.allOf(fs); |
2639 |
+ |
for (int i = k - 1; i >= 0; i--) { |
2640 |
+ |
checkIncomplete(f); |
2641 |
+ |
checkIncomplete(CompletableFuture.allOf(fs)); |
2642 |
+ |
fs[i].complete(one); |
2643 |
|
} |
2644 |
|
checkCompletedNormally(f, null); |
2645 |
|
checkCompletedNormally(CompletableFuture.allOf(fs), null); |