import ...
public class Demo {
    public static void main(String[] args) throws Exception {...}
    void run() throws Exception {
    }
}

import ...
public class Demo {
    public static void main(String[] args) throws Exception {...}
    void run() throws Exception {
        Thread thread = Thread.startVirtualThread(() -> System.out.println("hello"));
        thread.join();
    }
}

void run() throws Exception {
    Thread thread = Thread.startVirtualThread(Thread::dumpStack);
    thread.join();
}

void run() throws Exception {
    Thread thread = Thread.builder().virtual().task(() -> {
        System.out.println("hello");
    }).start();
    thread.join();
    }
}

void run() throws Exception {
    ThreadFactory factory = Thread.builder().name(prefix:"worker-", start:0).factory();
}

try (ExecutorService executor = Executors.newVirtualThreadExecutor()) {
}

import ...
  public class Demo {
      public static void main(String[] args) throws Exception {...}
      void run() throws Exception {
          try (ExecutorService executor = Executors.newVirtualThreadExecutor()) {
              IntStream.range(0, 1_000_000).forEach(i -> {
                  executor.submit(() -> { });
              });
          }
      }
      String fetch(String url) throws IOException {...}
      void sleep(Duration duration) {...}
  }

import ...
public class Demo {
    public static void main(String[] args) throws Exception {...}
    void run() throws Exception {
        AtomicInteger counter = new AtomicInteger();
        try (ExecutorService executor = Executors.newVirtualThreadExecutor()) {
            IntStream.range(0, 1_000_000).forEach(i -> {
                executor.submit(counter::incrementAndGet);
            });
        }
        System.out.println(counter.get());
    }
    String fetch(String url) throws IOException {...}
    void sleep(Duration duration) {...}
  }

String fetch(String url) throws IOExpection {
    try (InputStream in = URI.create(url).toURL().openStream()) {
        byte[] bytes = in.readAllBytes();
        return new String(bytes, charsetName:"ISO-8859-1");
    }
}

void run() throws Exception {
       try (ExecutorService executor = Executors.newVirtualThreadExecutor()) {
           Callable<String> task1 = () -> fetch(url:"https://jokerconf.com/");
           Callable<String> task1 = () -> fetch(url:"https://jokerconf.com/en");
           String first = executor.invokeAny(List.of(task1, task2));
           System.out.println(first.length());
       }
}

void run() throws Exception {
       try (ExecutorService executor = Executors.newVirtualThreadExecutor()) {
           Callable<String> task1 = () -> fetch(url:"https://jokerconf.com/");
           Callable<String> task1 = () -> fetch(url:"https://jokerconf.com/en");
           executor.invokeAll(List.of(task1, task2)); List>Future>String>>
                   .stream() Stream<Future<String>>
                   .map(Future::join) Stream<String>
                   .map(String::length) Stream<integer>
                   .forEach(System.out.println);
       }
}

void run() throws Exception {
       try (ExecutorService executor = Executors.newVirtualThreadExecutor()) {
           Callable<String> task1 = () -> fetch(url:"https://jokerconf.com/");
           Callable<String> task1 = () -> fetch(url:"https://jokerconf.com/en");
           CompletableFuture<String> future1 = executor.submitTask(task1);
           CompletableFuture<String> future2 = executor.submitTask(task2);
           CompletableFuture.completed(future1, future2) Stream<CompletableFuture<String>>
                   .map(Future::join) Stream<String>
                   .map(String::length) Stream<integer>
                   .forEach(System.out.println);
       }
}

import ...
public class Demo {
    public static void main(String[] args) throws Exception {...}
    void run() throws Exception {
        Thread.startVirtualThread(() ->
            sleep(Duration.ofSeconds(2));
        }).join();
    }
    String fetch(String url) throws IOException {...}
    void sleep(Duration duration) {...}
  }

void run() throws Exception {
        Thread.startVirtualThread(() -> {
            Object lock = new Object();
            synchronized (lock) {
                sleep(Duration.ofSeconds(2));
            }
        }).join();
}

package demo;
import ...
@Path("/")
public class SleepService {
    @GET
    @Path("sleep")
    @Producers(MediaType.APPLICATION_JSON)
    public String sleep(@QueryParam("millis") long millis) throws Exception {
        Thread.sleep(millis);
        return "{ "millis": "" + millis + "" };
    }
}

public String sleep(@QueryParam("millis") long millis) throws Exception {
    Thread.dumpStack();
    Thread.sleep(millis);
    return "{ "millis": "" + millis + "" };
}

import ...
@Path("/")
public class AggregatorServices {
    @GET
    @Path("anyOf")
    @Produces(MediaType.APPLICATION_JSON)
    public String anyOf(@QueryParam("left") String left,
                        @QueryParam("right") String right) throws Exception {
        if (left == null || right == null) {
            throw new WebApplicationException(Response.Status.BAD_REQUEST);
        }
        try (var executor :ExecutorService = Executors.newVirtualThreadExecutor()) {
            Callable<String> task1 = () -> query(left);
            Callable<String> task2 = () -> query(right);
            // return the first to succeed, cancel the other
            return executor.invokeAny(List.of(task1, task2));
        }
    }
    @GET
    @Path("allOf")
    @Produces(MediaType.APPLICATION_JSON)
    public String allOf(@QueryParam("left") String left,
                        @QueryParam("right") String right) throws Exception {
        if (left == null || right == null) {
            throw new WebApplicationException(Response.Status.BAD_REQUEST)
        }
        try (var executor :ExecutorService = Executors.newVirtualThreadExecutor()) {
            Callable<String> task1 = () -> query(left);
            Callable<String> task2 = () -> query(right);
            // if one falls, the other is cancelled
            return executor.invokeAll(List.of(task1, task2), cancelOnException: true) List<Future<String>>
                    .stream() Stream<Future<String>>
                    .map(Future::join) Stream<String>
                    .collect(Collectors.joining(delimiter:", ", prefix:"{", suffix:" }"));
        }
    }
    private String query(String endpoint) {...}
}

curl http://localhost:8081/anyOf?left=/greeting\&right=/sleep?millis=200

curl http://localhost:8081/allOf?left=/greeting\&right=/sleep?millis=1

private String query(String endpoint) {
        URI uri = URI.create("http://localhost:8081").resolve(endpoint);
        return ClientBuilder.newClient() Client
                    .target(uri) WebTarget
                    .request(MediaType.APPLICATION_JSON) Invocation.Builder
                    .get(String.class);
    }