Package org.atmosphere.util

Class ExecutorsFactory

java.lang.Object

org.atmosphere.util.ExecutorsFactory

public class ExecutorsFactory
extends Object

Factory to create ExecutorService for Atmosphere components. Uses Virtual Threads (JDK 21+) by default for unlimited scalability.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ExecutorsFactory.AtmosphereThreadFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ASYNC_WRITE_THREAD_POOL
static final String	BROADCASTER_THREAD_POOL
static final int	DEFAULT_ASYNC_THREAD
static final int	DEFAULT_KEEP_ALIVE
static final int	DEFAULT_MESSAGE_THREAD
static final String	SCHEDULER_THREAD_POOL

Constructor Summary

Constructors

Constructor	Description
ExecutorsFactory()

Method Summary

Modifier and Type	Method	Description
static ExecutorService	getAsyncOperationExecutor(AtmosphereConfig config, String name)	Create an ExecutorService for async I/O operations.
static ExecutorService	getMessageDispatcher(AtmosphereConfig config, String name)	Create an ExecutorService to be used for dispatching messages.
static ScheduledExecutorService	getScheduler(AtmosphereConfig config)	Create a ScheduledExecutorService for scheduled tasks.
static void	reset(AtmosphereConfig config)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_ASYNC_THREAD

public static final int DEFAULT_ASYNC_THREAD

See Also:

• Constant Field Values

DEFAULT_MESSAGE_THREAD

public static final int DEFAULT_MESSAGE_THREAD

See Also:

• Constant Field Values

DEFAULT_KEEP_ALIVE

public static final int DEFAULT_KEEP_ALIVE

See Also:

• Constant Field Values

ASYNC_WRITE_THREAD_POOL

public static final String ASYNC_WRITE_THREAD_POOL

See Also:

• Constant Field Values

SCHEDULER_THREAD_POOL

public static final String SCHEDULER_THREAD_POOL

See Also:

• Constant Field Values

BROADCASTER_THREAD_POOL

public static final String BROADCASTER_THREAD_POOL

See Also:

• Constant Field Values

Constructor Details

ExecutorsFactory

public ExecutorsFactory()

Method Details

getMessageDispatcher

public static ExecutorService getMessageDispatcher(AtmosphereConfig config,
 String name)

Create an ExecutorService to be used for dispatching messages. Uses Virtual Threads by default for unlimited scalability.

getAsyncOperationExecutor

public static ExecutorService getAsyncOperationExecutor(AtmosphereConfig config,
 String name)

Create an ExecutorService for async I/O operations. Uses Virtual Threads by default - perfect for I/O-bound work.

getScheduler

public static ScheduledExecutorService getScheduler(AtmosphereConfig config)

Create a ScheduledExecutorService for scheduled tasks.

reset

public static void reset(AtmosphereConfig config)