From 2e2f3bc4a95f83b91188b5ea7ee75e7913d3fe03 Mon Sep 17 00:00:00 2001
From: Chirag Dewan <chirag.dewan@ericsson.com>
Date: Tue, 15 Jan 2019 17:14:03 +0530
Subject: [PATCH] BAEL-2408 Java Project Loom

---
 .../java/com/baeldung/loom/AsyncThreads.java  | 22 +++++++++++++
 .../com/baeldung/loom/BlockingThreads.java    | 33 +++++++++++++++++++
 2 files changed, 55 insertions(+)
 create mode 100644 libraries/src/main/java/com/baeldung/loom/AsyncThreads.java
 create mode 100644 libraries/src/main/java/com/baeldung/loom/BlockingThreads.java

diff --git a/libraries/src/main/java/com/baeldung/loom/AsyncThreads.java b/libraries/src/main/java/com/baeldung/loom/AsyncThreads.java
new file mode 100644
index 0000000000..1ec448be69
--- /dev/null
+++ b/libraries/src/main/java/com/baeldung/loom/AsyncThreads.java
@@ -0,0 +1,22 @@
+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<Void> 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
new file mode 100644
index 0000000000..de11529753
--- /dev/null
+++ b/libraries/src/main/java/com/baeldung/loom/BlockingThreads.java
@@ -0,0 +1,33 @@
+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();
+
+    }
+}