Add some examples about Project Loom. Updated presentation (1.0.0-M1) (#36)

* Add some examples about Project Loom. Updated presentation (1.0.0-M1)

* Restore table-of-contents

Author: marcosDLCS

README.adoc

@@ -1,6 +1,7 @@
 = Asynchronous & reactive programming in Java
 Marcos de la Calle Samaniego, @marcosDLCS <marcos.dlcs@gmail.com>
-v0.0.16, 2020-12-06
+v1.0.0, 2020-12-07
+:toc:
 
 ++++
 <p align="center">
@@ -31,9 +32,9 @@ The project also provides, as documentation, a presentation about asynchronous a
 |Name |Version |Download |Updated at | Lang
 
 |Programación asíncrona y reactiva en Java 
-|0.0.15-SNAPSHOT
-| https://drive.google.com/file/d/1tKLL--rBfonlss4V3wWtxiok1eGiU9le/view?usp=sharing[pptx, window=_blank] or https://drive.google.com/file/d/1CA6qHuB_3BLbD9eX2ibbAhkKR159CYAv/view?usp=sharing[pdf, window=_blank]
-|2020-12-06
+|1.0.0-M1
+| https://drive.google.com/file/d/1fUeRK2f4S3cV50-atfIrqswEHoeu4HGc/view?usp=sharing[pptx, window=_blank] or https://drive.google.com/file/d/1tb4gk7pkC-hMosvAjXBN9YEG0VsBLOi_/view?usp=sharing[pdf, window=_blank]
+|2020-12-07
 |🇪🇸
 
 |Asynchronous and reactive programming in Java

examples/06-project-loom/loom/src/main/java/es/codeurjc/arpj/CancellationDeadline.java

@@ -0,0 +1,49 @@
+package es.codeurjc.arpj;
+
+import java.time.Instant;
+import java.util.concurrent.Executors;
+import java.util.concurrent.atomic.AtomicInteger;
+
+public class CancellationDeadline {
+
+    public static void main(String[] args) {
+
+        final AtomicInteger success = new AtomicInteger();
+        final AtomicInteger fail    = new AtomicInteger();
+
+        try (final var executorService = Executors.newVirtualThreadExecutor()
+                .withDeadline(Instant.now().plusSeconds(1))) {
+
+            for (int i = 0; i < 500; i++) {
+
+                final var index = i;
+                executorService.submit(() -> {
+                    try {
+                        print(index);
+                        success.incrementAndGet();
+                    } catch (final InterruptedException e) {
+                        System.out.println("Interrupted exception !!!");
+                        fail.incrementAndGet();
+                    }
+                });
+            }
+
+            System.out.println("\nAll tasks have been submitted!!!\n");
+        }
+
+        System.out.println("\nEverything has finished!!!\n");
+        System.out.println("Success: " + success.get());
+        System.out.println("Fail   : " + fail.get());
+    }
+
+    private static void print(final int taskNumber)
+            throws InterruptedException {
+
+        if (taskNumber % 2 == 0) {
+            Thread.sleep(965);
+        }
+
+        System.out.println("Normal task  [my-task] - " + taskNumber + "... !!! @ "
+                + Thread.currentThread().getName());
+    }
+}

examples/06-project-loom/loom/src/main/java/es/codeurjc/arpj/StructuredConcurrency.java

@@ -0,0 +1,67 @@
+package es.codeurjc.arpj;
+
+import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
+
+public class StructuredConcurrency {
+
+    public static void main(String[] args) {
+
+        ThreadFactory factory = Thread.builder().virtual()
+                .name("my-vt-factory-1").factory();
+
+        try (final var executorService = Executors.newThreadExecutor(factory)) {
+
+            for (int i = 0; i < 500; i++) {
+
+                final var index = i;
+
+                if (index % 2 == 0) {
+                    executorService.submit(() -> taskTwo(index));
+                } else {
+                    executorService.submit(() -> taskOne(index));
+                }
+            }
+
+            System.out.println("\nAll tasks have been submitted!!!\n");
+        }
+
+        System.out.println("\nEverything has finished!!!\n");
+    }
+
+    private static void taskOne(final int taskNumber) {
+
+        ThreadFactory factory = Thread.builder().virtual()
+                .name("my-factory-task-one").factory();
+
+        try (final var executorService = Executors.newThreadExecutor(factory)) {
+
+            executorService.submit(() -> print("t-one", taskNumber));
+        }
+    }
+
+    private static void taskTwo(final int taskNumber) {
+
+        ThreadFactory factory = Thread.builder().virtual()
+                .name("my-factory-task-two").factory();
+
+        try (final var executorService = Executors.newThreadExecutor(factory)) {
+
+            executorService.submit(() -> print("t-two", taskNumber));
+        }
+    }
+
+    private static void print(final String task, final int taskNumber) {
+
+        if (taskNumber % 2 == 0) {
+            try {
+                Thread.sleep(50);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+
+        System.out.println("Normal task  [" + task + "] - " + taskNumber + "... !!! @ "
+                + Thread.currentThread().getName());
+    }
+}