unstructured-completablefuture

UnstructuredConcurrency.java

public static void main(String[] args) throws InterruptedException {
        CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            System.out.println("I'm task 1 running on " + Thread.currentThread().getName());
        });

        CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            System.out.println("I'm task 2 running on " + Thread.currentThread().getName());
        });

        CompletableFuture<Void> future3 = CompletableFuture.runAsync(() -> {
            System.out.println("I'm task 3 running on " + Thread.currentThread().getName());
            throw new RuntimeException("Something went wrong!");
        });

        CompletableFuture.allOf(future1, future2, future3)
                        .join();
        System.out.println("All tasks started!");
        Thread.sleep(3000);
    }