CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
return "Hello, World!";
});
future.thenAccept(result -> {
});
future.exceptionally(ex -> {
return null;
});
ExecutorService executor = Executors.newFixedThreadPool(10);
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
return "Hello, World!";
}, executor);
executor.shutdown();
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
return "Hello,";
});
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {
return " World!";
});
CompletableFuture<String> combinedFuture = future1.thenCombine(future2, (result1, result2) -> result1 + result2);
combinedFuture.thenAccept(result -> {
});
