Package org.apache.pekko.dispatch

Class VirtualThreadSupport

java.lang.Object

org.apache.pekko.dispatch.VirtualThreadSupport

public class VirtualThreadSupport
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	VirtualThreadSupport.CarrierThreadFactory$

Constructor Summary

Constructors

Constructor	Description
VirtualThreadSupport()

Method Summary

Modifier and Type	Method	Description
static ForkJoinPool	getVirtualThreadDefaultScheduler()	Try to get the default scheduler of virtual thread.
static boolean	isSupported()	Is virtual thread supported
static ExecutorService	newThreadPerTaskExecutor(ThreadFactory threadFactory)	Create a newThreadPerTaskExecutor with the specified thread factory.
static ThreadFactory	newVirtualThreadFactory(String prefix, int start)	Create a virtual thread factory with the default Virtual Thread executor.
static ThreadFactory	newVirtualThreadFactory(String prefix, int start, ExecutorService executor)	Create a virtual thread factory with the default Virtual Thread executor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

VirtualThreadSupport

public VirtualThreadSupport()

Method Details

isSupported

public static boolean isSupported()

Is virtual thread supported

newThreadPerTaskExecutor

public static ExecutorService newThreadPerTaskExecutor(ThreadFactory threadFactory)

Create a newThreadPerTaskExecutor with the specified thread factory.

newVirtualThreadFactory

public static ThreadFactory newVirtualThreadFactory(String prefix,
 int start)

Create a virtual thread factory with the default Virtual Thread executor.

Parameters:

prefix - the prefix of the virtual thread name.

start - the starting number of the virtual thread name, if -1, the number will not be appended.

newVirtualThreadFactory

public static ThreadFactory newVirtualThreadFactory(String prefix,
 int start,
 ExecutorService executor)

Create a virtual thread factory with the default Virtual Thread executor.

Parameters:

prefix - the prefix of the virtual thread name.

start - the starting number of the virtual thread name, if -1, the number will not be appended.

executor - the executor to be used as the scheduler of virtual thread. If null, the default scheduler will be used.

getVirtualThreadDefaultScheduler

public static ForkJoinPool getVirtualThreadDefaultScheduler()

Try to get the default scheduler of virtual thread.