Package net.binis.codegen.async.executor

Class Executors

java.lang.Object

net.binis.codegen.async.executor.Executors

public abstract class Executors
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	Executors.DefaultThreadFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected static final RejectedExecutionHandler	defaultHandler
protected static final Method	newVirtualThreadPerTaskExecutor

Constructor Summary

Constructors

Constructor	Description
Executors()

Method Summary

Modifier and Type	Method	Description
static Executor	defaultExecutor(String flow)
static Executor	fixedThreadPool(String flow, int nThreads)
static Executor	fixedThreadPool(String flow, int nThreads, int queueSize)
static Executor	newVirtualThreadPerTaskExecutor()
static Executor	silentExecutor(String flow)
static Executor	singleThreadedExecutor(String flow)
static Executor	singleThreadedExecutor(String flow, int queueSize)
static Executor	syncExecutor()
static Executor	syncSilentExecutor()
static Executor	wrappedExecutor(String flow, Executor task)

Methods inherited from class java.lang.Object

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

Field Details

defaultHandler

protected static final RejectedExecutionHandler defaultHandler

newVirtualThreadPerTaskExecutor

protected static final Method newVirtualThreadPerTaskExecutor

Constructor Details

Executors

public Executors()

Method Details

wrappedExecutor

public static Executor wrappedExecutor(String flow,
 Executor task)

defaultExecutor

public static Executor defaultExecutor(String flow)

fixedThreadPool

public static Executor fixedThreadPool(String flow,
 int nThreads)

fixedThreadPool

public static Executor fixedThreadPool(String flow,
 int nThreads,
 int queueSize)

newVirtualThreadPerTaskExecutor

public static Executor newVirtualThreadPerTaskExecutor()

singleThreadedExecutor

public static Executor singleThreadedExecutor(String flow)

singleThreadedExecutor

public static Executor singleThreadedExecutor(String flow,
 int queueSize)

silentExecutor

public static Executor silentExecutor(String flow)

syncExecutor

public static Executor syncExecutor()

syncSilentExecutor

public static Executor syncSilentExecutor()