Core functionality for the Reactor Netty library 2.0.0-M3 · reactor.netty5.resources.LoopResources

Modifier and Type	Field and Description
public static final int	DEFAULT_IO_SELECT_COUNT Default selector thread count, fallback to -1 (no selector thread)
public static final int	DEFAULT_IO_WORKER_COUNT Default worker thread count, fallback to available processor (but with a minimum value of 4)
public static final boolean	DEFAULT_NATIVE Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available
public static final long	DEFAULT_SHUTDOWN_QUIET_PERIOD Default quiet period that guarantees that the disposal of the underlying LoopResources will not happen, fallback to 2 seconds.
public static final long	DEFAULT_SHUTDOWN_TIMEOUT Default maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period, fallback to 15 seconds.

Method Summary

Modifier and Type	Method and Description
public static EventLoopGroup	Returns: a decorated `EventLoopGroup` that will colocate executions on the same thread stack colocate(EventLoopGroup the `EventLoopGroup` to decorate group) Create a delegating `EventLoopGroup` which reuse local event loop if already working inside one.
public static LoopResources	Returns: a new `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories create(String the event loop thread name prefix prefix) Create a simple `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories
public static LoopResources	Returns: a new `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories create(String the event loop thread name prefix prefix, int number of worker threads workerCount, boolean should the thread be released on jvm shutdown daemon) Create a simple `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories
public static LoopResources	Returns: a new `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories create(String the event loop thread name prefix prefix, int number of selector threads selectCount, int number of worker threads workerCount, boolean should the thread be released on jvm shutdown daemon) Create a simple `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories
public default boolean	Returns: true if `EventLoopGroup` should not be shutdown daemon() return true if `EventLoopGroup` should not be shutdown
public default void	dispose() Implements reactor.core.Disposable.dispose. Dispose the underlying LoopResources.
public default Mono<Void>	Returns: a Mono representing the completion of the LoopResources disposal. disposeLater() Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
public default Mono<Void>	Returns: a Mono representing the completion of the LoopResources disposal. disposeLater(Duration the quiet period as described above quietPeriod, Duration the maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period timeout) Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
public static boolean	Returns: true if environment supports native connections hasNativeSupport() Return true if environment supports native connections
public default < the `Channel` implementation CHANNEL extends Channel> CHANNEL	Returns: a `Channel` instance onChannel(Class<CHANNEL> the channel type channelType, EventLoop the `EventLoop` to assign eventLoop, ProtocolFamily the configured `ProtocolFamily` to run with protocolFamily) Callback for a `Channel` selection.
public default EventLoopGroup	Returns: a new `EventLoopGroup` onClient(boolean should use native group if current environment supports it useNative) Callback for client `EventLoopGroup` creation.
public EventLoopGroup	Returns: a new `EventLoopGroup` onServer(boolean should use native group if current environment supports it useNative) Callback for server `EventLoopGroup` creation, this is the `EventLoopGroup` for the child channel.
public default < the `ServerChannel` implementation SERVERCHANNEL extends ServerChannel> SERVERCHANNEL	Returns: a `ServerChannel` instance onServerChannel(Class<SERVERCHANNEL> the channel type channelType, EventLoop the `EventLoop` to assign eventLoop, EventLoopGroup the `EventLoop` to assign for child `Channel` childEventLoopGroup, ProtocolFamily the configured `ProtocolFamily` to run with protocolFamily) Callback for a `Channel` selection.
public default EventLoopGroup	Returns: a new `EventLoopGroup` onServerSelect(boolean should use native group if current environment supports it useNative) Callback for server select `EventLoopGroup` creation, this is the `EventLoopGroup` for the acceptor channel.

Inherited from reactor.core.Disposable:: isDisposed

DEFAULT_IO_SELECT_COUNT	back to summary
public static final int DEFAULT_IO_SELECT_COUNT Default selector thread count, fallback to -1 (no selector thread)

DEFAULT_IO_WORKER_COUNT	back to summary
public static final int DEFAULT_IO_WORKER_COUNT Default worker thread count, fallback to available processor (but with a minimum value of 4)

DEFAULT_NATIVE	back to summary
public static final boolean DEFAULT_NATIVE Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available

DEFAULT_SHUTDOWN_QUIET_PERIOD	back to summary
public static final long DEFAULT_SHUTDOWN_QUIET_PERIOD Default quiet period that guarantees that the disposal of the underlying LoopResources will not happen, fallback to 2 seconds.

DEFAULT_SHUTDOWN_TIMEOUT	back to summary
public static final long DEFAULT_SHUTDOWN_TIMEOUT Default maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period, fallback to 15 seconds.

Method Detail

colocate back to summary

colocate	back to summary
public static EventLoopGroup colocate(EventLoopGroup group) Create a delegating `EventLoopGroup` which reuse local event loop if already working inside one. Parameters group:EventLoopGroup the `EventLoopGroup` to decorate Returns:EventLoopGroup a decorated `EventLoopGroup` that will colocate executions on the same thread stack

public static EventLoopGroup colocate(EventLoopGroup group)

Create a delegating EventLoopGroup which reuse local event loop if already working inside one.

Parameters

group:EventLoopGroup: the EventLoopGroup to decorate

Returns:EventLoopGroup

a decorated EventLoopGroup that will colocate executions on the same thread stack

create back to summary

create	back to summary
public static LoopResources create(String prefix) Create a simple `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories Parameters prefix:String the event loop thread name prefix Returns:LoopResources a new `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories

public static LoopResources create(String prefix)

Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories

Parameters

prefix:String: the event loop thread name prefix

Returns:LoopResources

a new LoopResources to provide automatically for EventLoopGroup and Channel factories

create back to summary

create	back to summary
public static LoopResources create(String prefix, int workerCount, boolean daemon) Create a simple `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories Parameters prefix:String the event loop thread name prefix workerCount:int number of worker threads daemon:boolean should the thread be released on jvm shutdown Returns:LoopResources a new `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories

public static LoopResources create(String prefix, int workerCount, boolean daemon)

Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories

Parameters

prefix:String: the event loop thread name prefix
workerCount:int: number of worker threads
daemon:boolean: should the thread be released on jvm shutdown

Returns:LoopResources

a new LoopResources to provide automatically for EventLoopGroup and Channel factories

create back to summary

create	back to summary
public static LoopResources create(String prefix, int selectCount, int workerCount, boolean daemon) Create a simple `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories Parameters prefix:String the event loop thread name prefix selectCount:int number of selector threads workerCount:int number of worker threads daemon:boolean should the thread be released on jvm shutdown Returns:LoopResources a new `LoopResources` to provide automatically for `EventLoopGroup` and `Channel` factories

public static LoopResources create(String prefix, int selectCount, int workerCount, boolean daemon)

Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories

Parameters

prefix:String: the event loop thread name prefix
selectCount:int: number of selector threads
workerCount:int: number of worker threads
daemon:boolean: should the thread be released on jvm shutdown

Returns:LoopResources

a new LoopResources to provide automatically for EventLoopGroup and Channel factories

daemon back to summary

daemon	back to summary
public default boolean daemon() return true if `EventLoopGroup` should not be shutdown Returns:boolean true if `EventLoopGroup` should not be shutdown

public default boolean daemon()

return true if EventLoopGroup should not be shutdown

Returns:boolean: true if EventLoopGroup should not be shutdown

dispose back to summary

dispose	back to summary
public default void dispose() Implements reactor.core.Disposable.dispose. Dispose the underlying LoopResources. This method is NOT blocking. It is implemented as fire-and-forget. Use `disposeLater()` when you need to observe the final status of the operation, combined with `Mono#block()` if you need to synchronously wait for the underlying resources to be disposed. Annotations @Override @SuppressWarnings:FunctionalInterfaceMethodChanged

public default void dispose()

Implements reactor.core.Disposable.dispose.

Dispose the underlying LoopResources. This method is NOT blocking. It is implemented as fire-and-forget. Use disposeLater() when you need to observe the final status of the operation, combined with Mono#block() if you need to synchronously wait for the underlying resources to be disposed.

Annotations

@Override
@SuppressWarnings:FunctionalInterfaceMethodChanged

disposeLater back to summary

disposeLater	back to summary
public default Mono<Void> disposeLater() Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to. The quiet period will be `2s` and the timeout will be `15s` Returns:Mono<Void> a Mono representing the completion of the LoopResources disposal.

public default Mono<Void> disposeLater()

Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to. The quiet period will be 2s and the timeout will be 15s

Returns:Mono<Void>: a Mono representing the completion of the LoopResources disposal.

disposeLater back to summary

disposeLater	back to summary
public default Mono<Void> disposeLater(Duration quietPeriod, Duration timeout) Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to. It is guaranteed that the disposal of the underlying LoopResources will not happen before `quietPeriod` is over. If a task is submitted during the `quietPeriod`, it is guaranteed to be accepted and the `quietPeriod` will start over. Parameters quietPeriod:Duration the quiet period as described above timeout:Duration the maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period Returns:Mono<Void> a Mono representing the completion of the LoopResources disposal. Since 0.9.3

public default Mono<Void> disposeLater(Duration quietPeriod, Duration timeout)

Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to. It is guaranteed that the disposal of the underlying LoopResources will not happen before quietPeriod is over. If a task is submitted during the quietPeriod, it is guaranteed to be accepted and the quietPeriod will start over.

Parameters

quietPeriod:Duration: the quiet period as described above
timeout:Duration: the maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period

Returns:Mono<Void>

a Mono representing the completion of the LoopResources disposal.

Since

0.9.3

hasNativeSupport	back to summary
public static boolean hasNativeSupport() Return true if environment supports native connections Returns:boolean true if environment supports native connections

hasNativeSupport

back to summary

public static boolean hasNativeSupport()

Return true if environment supports native connections

Returns:boolean: true if environment supports native connections

onChannel back to summary

onChannel	back to summary
public default <CHANNEL extends Channel> CHANNEL onChannel(Class<CHANNEL> channelType, EventLoop eventLoop, ProtocolFamily protocolFamily) Callback for a `Channel` selection. Parameters <CHANNEL> the `Channel` implementation channelType:Class<CHANNEL> the channel type eventLoop:EventLoop the `EventLoop` to assign protocolFamily:ProtocolFamily the configured `ProtocolFamily` to run with Returns:CHANNEL a `Channel` instance

public default <CHANNEL extends Channel> CHANNEL onChannel(Class<CHANNEL> channelType, EventLoop eventLoop, ProtocolFamily protocolFamily)

Callback for a Channel selection.

Parameters

<CHANNEL>: the Channel implementation
channelType:Class<CHANNEL>: the channel type
eventLoop:EventLoop: the EventLoop to assign
protocolFamily:ProtocolFamily: the configured ProtocolFamily to run with

Returns:CHANNEL

a Channel instance

onClient back to summary

onClient	back to summary
public default EventLoopGroup onClient(boolean useNative) Callback for client `EventLoopGroup` creation. Parameters useNative:boolean should use native group if current environment supports it Returns:EventLoopGroup a new `EventLoopGroup`

public default EventLoopGroup onClient(boolean useNative)

Callback for client EventLoopGroup creation.

Parameters

useNative:boolean: should use native group if current environment supports it

Returns:EventLoopGroup

a new EventLoopGroup

onServer back to summary

onServer	back to summary
public EventLoopGroup onServer(boolean useNative) Callback for server `EventLoopGroup` creation, this is the `EventLoopGroup` for the child channel. Parameters useNative:boolean should use native group if current environment supports it Returns:EventLoopGroup a new `EventLoopGroup`

public EventLoopGroup onServer(boolean useNative)

Callback for server EventLoopGroup creation, this is the EventLoopGroup for the child channel.

Parameters

useNative:boolean: should use native group if current environment supports it

Returns:EventLoopGroup

a new EventLoopGroup

onServerChannel back to summary

onServerChannel	back to summary
public default <SERVERCHANNEL extends ServerChannel> SERVERCHANNEL onServerChannel(Class<SERVERCHANNEL> channelType, EventLoop eventLoop, EventLoopGroup childEventLoopGroup, ProtocolFamily protocolFamily) Callback for a `Channel` selection. Parameters <SERVERCHANNEL> the `ServerChannel` implementation channelType:Class<SERVERCHANNEL> the channel type eventLoop:EventLoop the `EventLoop` to assign childEventLoopGroup:EventLoopGroup the `EventLoop` to assign for child `Channel` protocolFamily:ProtocolFamily the configured `ProtocolFamily` to run with Returns:SERVERCHANNEL a `ServerChannel` instance

public default <SERVERCHANNEL extends ServerChannel> SERVERCHANNEL onServerChannel(Class<SERVERCHANNEL> channelType, EventLoop eventLoop, EventLoopGroup childEventLoopGroup, ProtocolFamily protocolFamily)

Callback for a Channel selection.

Parameters

<SERVERCHANNEL>: the ServerChannel implementation
channelType:Class<SERVERCHANNEL>: the channel type
eventLoop:EventLoop: the EventLoop to assign
childEventLoopGroup:EventLoopGroup: the EventLoop to assign for child Channel
protocolFamily:ProtocolFamily: the configured ProtocolFamily to run with

Returns:SERVERCHANNEL

a ServerChannel instance

onServerSelect back to summary

onServerSelect	back to summary
public default EventLoopGroup onServerSelect(boolean useNative) Callback for server select `EventLoopGroup` creation, this is the `EventLoopGroup` for the acceptor channel. Parameters useNative:boolean should use native group if current environment supports it Returns:EventLoopGroup a new `EventLoopGroup`

public default EventLoopGroup onServerSelect(boolean useNative)

Callback for server select EventLoopGroup creation, this is the EventLoopGroup for the acceptor channel.

Parameters

useNative:boolean: should use native group if current environment supports it

Returns:EventLoopGroup

a new EventLoopGroup

public Interface LoopResources

Field Summary

Method Summary

Field Detail

Method Detail