JEP 444: Virtual Threads

README.md

@@ -8,6 +8,7 @@ This repository contains Java examples that are designed to track and document t
 * [Java 21](java-21) (September, 2023)
   * [JEP 430](https://openjdk.org/jeps/430): String Templates
   * [JEP 431](https://openjdk.org/jeps/431): Sequenced Collections
+  * [JEP 444](https://openjdk.org/jeps/444): Virtual Threads
 
 * [Java 16](java-16/) (March, 2021)
   * [JEP 395](https://openjdk.java.net/jeps/395): Records

java-21/src/main/java/com/ibrahimatay/JEP444VirtualThreads.java

@@ -0,0 +1,54 @@
+package com.ibrahimatay;
+
+import java.util.concurrent.Executors;
+import java.util.stream.IntStream;
+
+/*
+* JEP 444: Virtual Threads
+* https://openjdk.org/jeps/444
+* */
+public class JEP444VirtualThreads {
+    public static void main(String[] args) {
+        Runnable fn = () -> {
+            IntStream.range(0, 100_000).forEach(i-> {
+                System.out.println(i);
+                try {
+                    Thread.sleep(100);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
+            });
+        };
+
+        // Platform Threads
+        new Thread(fn).start();
+
+        Thread.ofPlatform().start(fn);
+        Thread.ofPlatform().daemon().name("my-custom-thread").unstarted(fn);
+
+        // Virtual Threads
+
+        Thread.startVirtualThread(() -> {
+            IntStream.range(0, 100_000).forEach(i-> {
+                System.out.println(i);
+                try {
+                    Thread.sleep(100);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
+            });
+        });
+
+        var executorService = Executors.newVirtualThreadPerTaskExecutor();
+        executorService.submit(() -> {
+            IntStream.range(0, 100_000).forEach(i-> {
+                System.out.println(i);
+                try {
+                    Thread.sleep(100);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
+            });
+        });
+    }
+}