diff --git a/libraries/src/main/java/com/baeldung/loom/AsyncThreads.java b/libraries/src/main/java/com/baeldung/loom/AsyncThreads.java deleted file mode 100644 index 1ec448be69..0000000000 --- a/libraries/src/main/java/com/baeldung/loom/AsyncThreads.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.baeldung.loom; - -import java.util.concurrent.CompletableFuture; -import java.util.concurrent.ExecutionException; - -public class AsyncThreads { - - public static void main(String[] args) throws ExecutionException, InterruptedException { - - CompletableFuture cf = CompletableFuture.runAsync(() -> { - - System.out.println("Hello " + Thread.currentThread().getName()); - }); - - cf.thenRun(() -> { - - System.out.println("World " + Thread.currentThread().getName()); - }); - - cf.get(); - } -} diff --git a/libraries/src/main/java/com/baeldung/loom/BlockingThreads.java b/libraries/src/main/java/com/baeldung/loom/BlockingThreads.java deleted file mode 100644 index de11529753..0000000000 --- a/libraries/src/main/java/com/baeldung/loom/BlockingThreads.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.baeldung.loom; - -public class BlockingThreads { - - private static final Object LOCK = new Object(); - - public static void main(String[] args) throws InterruptedException { - - Thread thread1 = new Thread(() -> { - synchronized (LOCK) { - System.out.println("Hello " + Thread.currentThread().getName()); - LOCK.notify(); - } - }); - - - Thread thread2 = new Thread(() -> { - synchronized (LOCK) { - try { - System.out.println("Will wait for thread1 now..."); - LOCK.wait(); - System.out.println("World " + Thread.currentThread().getName()); - } catch (InterruptedException e) { - e.printStackTrace(); - } - } - }); - - thread2.start(); - thread1.start(); - - } -}