Package org.apache.pekko.dispatch

Class VirtualThreadSupport$

java.lang.Object

org.apache.pekko.dispatch.VirtualThreadSupport$

public class VirtualThreadSupport$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final VirtualThreadSupport$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
VirtualThreadSupport$()

Method Summary

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

Field Details

MODULE$

public static final VirtualThreadSupport$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

VirtualThreadSupport$

public VirtualThreadSupport$()

Method Details

isSupported

public boolean isSupported()

Is virtual thread supported

newThreadPerTaskExecutor

public ExecutorService newThreadPerTaskExecutor(ThreadFactory threadFactory)

Create a newThreadPerTaskExecutor with the specified thread factory.

newVirtualThreadFactory

public 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 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 ForkJoinPool getVirtualThreadDefaultScheduler()

Try to get the default scheduler of virtual thread.