public static void main(String[] args) {

ExecutorService executorService = Executors.newFixedThreadPool(2);

IntStream.rangeClosed(1, 10)

.forEach(num -> {

CompletableFuture<Integer> oddCompletableFuture = CompletableFuture.completedFuture(num)

.thenApplyAsync(x -> {

if (x % 2 != 0) {

System.out.println("Thread Name " + Thread.currentThread().getName() + " : " + x);

}

return num;

}, executorService);

oddCompletableFuture.join();

CompletableFuture<Integer> evenCompletableFuture = CompletableFuture.completedFuture(num)

.thenApplyAsync(x -> {

if (x % 2 == 0) {

System.out.println("Thread Name " + Thread.currentThread().getName() + " : " + x);

}

return num;

}, executorService);

evenCompletableFuture.join();

});

executorService.shutdown();

}