public static CompletableFutureallOf(CompletableFuture... cfs); public static CompletableFuture
allOf：等待所有任务完成
anyOf：只要有一个任务完成
public static void main(String[] args) {
List futures = Arrays.asList(CompletableFuture.completedFuture("hello"),
CompletableFuture.completedFuture(" world!"),
CompletableFuture.completedFuture(" hello"),
CompletableFuture.completedFuture("java!"));
final CompletableFuture allCompleted = CompletableFuture.allOf(futures.toArray(new CompletableFuture[]{}));
allCompleted.thenRun(() -> {
futures.stream().forEach(future -> {
try {
System.out.println("get future at:"+System.currentTimeMillis()+", result:"+future.get());
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
});
});
}
测试结果：
get future at:1568892339473, result:hello get future at:1568892339473, result: world! get future at:1568892339473, result: hello get future at:1568892339473, result:java!
几乎同时完成任务！
