Virtual Thread Demo

ClassicThread.java

import java.util.ArrayList;
import java.util.List;

public class ClassicThread {


    void handleRequest() {

        try {


            // do some work with Request

            System.out.println("Handling request on Thread " + Thread.currentThread().threadId() + "  started");
            Thread.sleep(3000);
            System.out.println("Handling request on Thread " + Thread.currentThread().threadId() + "  completed");


        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }

    }


    public static void main(String[] args) {


        System.out.println("Hello, World!, Classic Thread Demo");

        startClassicalThreads(5000);


    }


    public static void startClassicalThreads(int n) {

        try {
            List<Thread> threads = new ArrayList<>();

            for (int i = 0; i < n; i++) {


                // create a thread
                Thread thread = new Thread(() -> {
                    new ClassicThread().handleRequest();
                });
                // start the thread
                thread.start();
                // add the thread to the list
                threads.add(thread);
                System.out.println("Thread " + thread.threadId()+ " started");
            }
            // wait for all the threads to finish

            for (Thread thread : threads) {

                thread.join();

            }

            System.out.println("All "+n+" threads completed successfully");
        } catch (Throwable e) {
            System.err.println("Error in completing threads");
            throw new RuntimeException(e);
        }
    }
}

VirtualThread.java

import java.util.ArrayList;
import java.util.List;

public class VirtualThread {


    void handleRequest() {

        try {


            // do some work with Request

            System.out.println("Handling request on Thread " + Thread.currentThread().threadId() + "  started");
            Thread.sleep(3000);
            System.out.println("Handling request on Thread " + Thread.currentThread().threadId() + "  completed");


        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }

    }


    public static void main(String[] args) {


        System.out.println("Hello, World!, Virtual Thread Demo");

        startVirtualThreads(500000);


    }


    public static void startVirtualThreads(int n) {

        try {
            List<Thread> threads = new ArrayList<>();

            for (int i = 0; i < n; i++) {


                // create a thread
                Thread thread = Thread.ofVirtual().unstarted(() -> {
                    new VirtualThread().handleRequest();
                });
                // start the thread
                thread.start();
                // add the thread to the list
                threads.add(thread);
                System.out.println("Thread " + thread.threadId()+ " started");
            }
            // wait for all the threads to finish

            for (Thread thread : threads) {

                thread.join();

            }

            System.out.println("All "+n+" threads completed successfully");
        } catch (Throwable e) {
            System.err.println("Error in completing threads");
            throw new RuntimeException(e);
        }
    }
}