diff --git a/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/completablefuture/NonBlockingExample.java b/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/completablefuture/NonBlockingExample.java
new file mode 100644
index 0000000000..b97f7d0dee
--- /dev/null
+++ b/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/completablefuture/NonBlockingExample.java
@@ -0,0 +1,17 @@
+package com.baeldung.concurrent.completablefuture;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.CompletableFuture;
+
+public class NonBlockingExample {
+
+    private static final Logger logger = LoggerFactory.getLogger(NonBlockingExample.class);
+
+    public static void main(String[] args) {
+        CompletableFuture.supplyAsync(() -> "Baeldung")
+          .thenApply(String::length)
+          .thenAccept(s -> logger.info(String.valueOf(s)));
+    }
+}
diff --git a/core-java-modules/core-java-concurrency-basic-3/src/test/java/com/baeldung/concurrent/completablefuture/BlockingUnitTest.java b/core-java-modules/core-java-concurrency-basic-3/src/test/java/com/baeldung/concurrent/completablefuture/BlockingUnitTest.java
new file mode 100644
index 0000000000..75d8d73c2f
--- /dev/null
+++ b/core-java-modules/core-java-concurrency-basic-3/src/test/java/com/baeldung/concurrent/completablefuture/BlockingUnitTest.java
@@ -0,0 +1,31 @@
+package com.baeldung.concurrent.completablefuture;
+
+import org.junit.jupiter.api.Test;
+
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+class BlockingUnitTest {
+
+    @Test
+    void givenCompletableFuture_whenGet_thenReturnResult()
+      throws ExecutionException, InterruptedException {
+        CompletableFuture<String> completableFuture = CompletableFuture
+          .supplyAsync(() -> "Baeldung")
+          .thenApply(String::toUpperCase);
+
+        assertEquals("BAELDUNG", completableFuture.get());
+    }
+
+    @Test
+    void givenCompletableFuture_whenJoin_thenReturnResult() {
+        CompletableFuture<String> completableFuture = CompletableFuture
+          .supplyAsync(() -> "Blocking")
+          .thenApply(s -> s + " Operation")
+          .thenApply(String::toLowerCase);
+
+        assertEquals("blocking operation", completableFuture.join());
+    }
+}