Project Loom examples and updated presentation (#35)

Author: marcosDLCS

README.adoc

@@ -1,7 +1,6 @@
 = Asynchronous & reactive programming in Java
 Marcos de la Calle Samaniego, @marcosDLCS <marcos.dlcs@gmail.com>
-v0.0.16, 2020-12-05
-:toc:
+v0.0.16, 2020-12-06
 
 ++++
 <p align="center">
@@ -32,9 +31,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.14-SNAPSHOT
-| https://drive.google.com/file/d/10_VuEaIZ5M0RTJU-D_MO5yB_nNOvFqV3/view?usp=sharing[pptx, window=_blank] or https://drive.google.com/file/d/1NNjiHppqJEZLECzwcN-WSSWs_2bNrsr5/view?usp=sharing[pdf, window=_blank]
-|2020-12-04
+|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
 |🇪🇸
 
 |Asynchronous and reactive programming in Java

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

@@ -6,14 +6,11 @@ public static void main(String[] args) throws InterruptedException {
 
         System.out.println("Hello @ " + Thread.currentThread().getName());
 
-        Thread myVt = Thread.builder()
-                .virtual()
-                .name("my-virtual-thread")
-                .task(() -> System.out.println("Hello Loom! @ " + Thread.currentThread().getName()))
-                .build();
-        myVt.start();
+        final Thread myVt = Thread.startVirtualThread(
+                () -> System.out.println("Hello Loom! @ "
+                        + Thread.currentThread().getName()));
+        myVt.join();
 
-        Thread.sleep(1000);
         System.out.println("Goodbye @ " + Thread.currentThread().getName());
     }
 }

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

@@ -0,0 +1,20 @@
+package es.codeurjc.arpj;
+
+public class LoomThreadBuilder {
+
+    public static void main(String[] args) throws InterruptedException {
+
+        System.out.println("Hello @ " + Thread.currentThread().getName());
+
+        Thread myVt = Thread.builder()
+                .virtual()
+                .name("my-virtual-thread")
+                .task(() -> System.out.println("Hello Loom! @ "
+                        + Thread.currentThread().getName()))
+                .build();
+        myVt.start();
+
+        Thread.sleep(1000);
+        System.out.println("Goodbye @ " + Thread.currentThread().getName());
+    }
+}

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

@@ -0,0 +1,42 @@
+package es.codeurjc.arpj;
+
+import java.security.SecureRandom;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
+
+public class ThreeMillionTasks {
+
+    private static final SecureRandom RANDOM = new SecureRandom();
+
+    public static void main(String[] args) {
+
+        ThreadFactory factory = Thread.builder().virtual()
+                .name("my-vt-factory").factory();
+
+        final ExecutorService executorService =
+                Executors.newThreadExecutor(factory);
+
+        for (int i = 0; i < 3_000_000; i++) {
+            int index = i;
+            executorService.submit(() -> {
+                try {
+                    task(index);
+                } catch (final InterruptedException e) {
+                    e.printStackTrace();
+                }
+            });
+        }
+        executorService.close();
+    }
+
+
+    private static void task(final int taskNumber)
+            throws InterruptedException {
+
+        System.out.println("Sleeping task " + taskNumber + "... !!! @ "
+                + Thread.currentThread().getName());
+
+        Thread.sleep(RANDOM.nextInt(10) * 500L);
+    }
+}