reactor.netty.udp

Class UdpResources

java.lang.Object

reactor.netty.udp.UdpResources

All Implemented Interfaces:

Disposable, LoopResources

public class UdpResources
extends Object
implements LoopResources

Hold the default UDP resources

Author:

Violeta Georgieva

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Disposable

Disposable.Composite, Disposable.Swap

Field Summary

Fields inherited from interface reactor.netty.resources.LoopResources

DEFAULT_IO_SELECT_COUNT, DEFAULT_IO_WORKER_COUNT, DEFAULT_NATIVE, DEFAULT_SHUTDOWN_QUIET_PERIOD, DEFAULT_SHUTDOWN_TIMEOUT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	UdpResources(LoopResources defaultLoops)

Method Summary

Modifier and Type	Method and Description
protected void	_dispose() Dispose underlying resources
protected Mono<Void>	_disposeLater() Deprecated. as of 0.9.3. Use _disposeLater(Duration, Duration)
protected Mono<Void>	_disposeLater(java.time.Duration quietPeriod, java.time.Duration timeout) Dispose underlying resources in a listenable fashion.
boolean	daemon() return true if EventLoopGroup should not be shutdown
static UdpResources	get() Return the global UDP resources for pooling
protected static UdpResources	getOrCreate(LoopResources loops, java.util.function.Function<LoopResources,UdpResources> onNew, String name) Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
boolean	isDisposed()
<CHANNEL extends Channel> CHANNEL	onChannel(Class<CHANNEL> channelType, EventLoopGroup group) Callback for a Channel selection.
Class<? extends Channel>	onChannel(EventLoopGroup group) Callback for client or generic channel factory selection.
<CHANNEL extends Channel> Class<? extends CHANNEL>	onChannelClass(Class<CHANNEL> channelType, EventLoopGroup group) Callback for a Channel class selection.
EventLoopGroup	onClient(boolean useNative) Callback for client EventLoopGroup creation.
Class<? extends DatagramChannel>	onDatagramChannel(EventLoopGroup group) Callback for UDP channel factory selection.
EventLoopGroup	onServer(boolean useNative) Callback for server EventLoopGroup creation, this is the EventLoopGroup for the child channel.
Class<? extends ServerChannel>	onServerChannel(EventLoopGroup group) Callback for server channel factory selection.
EventLoopGroup	onServerSelect(boolean useNative) Callback for server select EventLoopGroup creation, this is the EventLoopGroup for the acceptor channel.
boolean	preferNative() Return true if should default to native EventLoopGroup and Channel
static UdpResources	reset() Reset UDP resources to default and return its instance
static UdpResources	set(LoopResources loops) Update event loops resources and return the global UDP resources.
static void	shutdown() Shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
static Mono<Void>	shutdownLater() Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
static Mono<Void>	shutdownLater(java.time.Duration quietPeriod, java.time.Duration timeout) Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.netty.resources.LoopResources

colocate, create, create, create, dispose, disposeLater, disposeLater, hasNativeSupport

Constructor Detail

UdpResources

protected UdpResources(LoopResources defaultLoops)

Method Detail

get

public static UdpResources get()

Return the global UDP resources for pooling

Returns:

the global UDP resources for pooling

set

public static UdpResources set(LoopResources loops)

Update event loops resources and return the global UDP resources. Note: The previous LoopResources will be disposed.

Parameters:

loops - a new LoopResources to replace the current

Returns:

the global UDP resources

reset

public static UdpResources reset()

Reset UDP resources to default and return its instance

Returns:

the global UDP resources

shutdown

public static void shutdown()

Shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones. This method is NOT blocking. It is implemented as fire-and-forget. Use shutdownLater() 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.

shutdownLater

public static Mono<Void> shutdownLater()

Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones. This only occurs when the returned Mono is subscribed to. The quiet period will be 2s and the timeout will be 15s

Returns:

a Mono triggering the shutdown() when subscribed to.

shutdownLater

public static Mono<Void> shutdownLater(java.time.Duration quietPeriod,
                                       java.time.Duration timeout)

Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones. This only occurs when the returned Mono is 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 - the quiet period as described above

timeout - 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:

a Mono triggering the shutdown() when subscribed to.

Since:

0.9.3

_dispose

protected void _dispose()

Dispose underlying resources

_disposeLater

@Deprecated
protected Mono<Void> _disposeLater()

Deprecated. as of 0.9.3. Use _disposeLater(Duration, Duration)

Dispose underlying resources in a listenable fashion. The quiet period will be 2s and the timeout will be 15s

Returns:

the Mono that represents the end of disposal

_disposeLater

protected Mono<Void> _disposeLater(java.time.Duration quietPeriod,
                                   java.time.Duration timeout)

Dispose underlying resources in a listenable fashion. 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 - the quiet period as described above

timeout - 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:

the Mono that represents the end of disposal

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface Disposable

onChannel

public Class<? extends Channel> onChannel(EventLoopGroup group)

Description copied from interface: LoopResources

Callback for client or generic channel factory selection.

Specified by:

onChannel in interface LoopResources

Parameters:

group - the source EventLoopGroup to assign a loop from

Returns:

a Class target for the underlying Channel factory

onChannel

public <CHANNEL extends Channel> CHANNEL onChannel(Class<CHANNEL> channelType,
                                                   EventLoopGroup group)

Description copied from interface: LoopResources

Callback for a Channel selection.

Specified by:

onChannel in interface LoopResources

Type Parameters:

CHANNEL - the Channel implementation

Parameters:

channelType - the channel type

group - the source EventLoopGroup to assign a loop from

Returns:

a Channel instance

onChannelClass

public <CHANNEL extends Channel> Class<? extends CHANNEL> onChannelClass(Class<CHANNEL> channelType,
                                                                         EventLoopGroup group)

Description copied from interface: LoopResources

Callback for a Channel class selection.

Specified by:

onChannelClass in interface LoopResources

Type Parameters:

CHANNEL - the Channel implementation

Parameters:

channelType - the channel type

group - the source EventLoopGroup to assign a loop from

Returns:

a Channel class

onClient

public EventLoopGroup onClient(boolean useNative)

Description copied from interface: LoopResources

Callback for client EventLoopGroup creation.

Specified by:

onClient in interface LoopResources

Parameters:

useNative - should use native group if current environment supports it

Returns:

a new EventLoopGroup

onDatagramChannel

public Class<? extends DatagramChannel> onDatagramChannel(EventLoopGroup group)

Description copied from interface: LoopResources

Callback for UDP channel factory selection.

Specified by:

onDatagramChannel in interface LoopResources

Parameters:

group - the source EventLoopGroup to assign a loop from

Returns:

a Class target for the underlying Channel factory

onServer

public EventLoopGroup onServer(boolean useNative)

Description copied from interface: LoopResources

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

Specified by:

onServer in interface LoopResources

Parameters:

useNative - should use native group if current environment supports it

Returns:

a new EventLoopGroup

onServerChannel

public Class<? extends ServerChannel> onServerChannel(EventLoopGroup group)

Description copied from interface: LoopResources

Callback for server channel factory selection.

Specified by:

onServerChannel in interface LoopResources

Parameters:

group - the source EventLoopGroup to assign a loop from

Returns:

a Class target for the underlying ServerChannel factory

onServerSelect

public EventLoopGroup onServerSelect(boolean useNative)

Description copied from interface: LoopResources

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

Specified by:

onServerSelect in interface LoopResources

Parameters:

useNative - should use native group if current environment supports it

Returns:

a new EventLoopGroup

preferNative

public boolean preferNative()

Description copied from interface: LoopResources

Return true if should default to native EventLoopGroup and Channel

Specified by:

preferNative in interface LoopResources

Returns:

true if should default to native EventLoopGroup and Channel

daemon

public boolean daemon()

Description copied from interface: LoopResources

return true if EventLoopGroup should not be shutdown

Specified by:

daemon in interface LoopResources

Returns:

true if EventLoopGroup should not be shutdown

getOrCreate

protected static UdpResources getOrCreate(@Nullable
                                          LoopResources loops,
                                          java.util.function.Function<LoopResources,UdpResources> onNew,
                                          String name)

Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.

Parameters:

loops - the eventual new LoopResources

onNew - a UdpResources factory

name - a name for resources

Returns:

an existing or new UdpResources