Modifier and Type	Class and Description
pack-priv static class	DefaultLoopResources.EventLoop
pack-priv static class	DefaultLoopResources.EventLoopFactory

Modifier and Type	Field and Description
pack-priv final AtomicReference<EventLoopGroup>	cacheNativeClientLoops
pack-priv final AtomicReference<EventLoopGroup>	cacheNativeSelectLoops
pack-priv final AtomicReference<EventLoopGroup>	cacheNativeServerLoops
pack-priv final AtomicReference<EventLoopGroup>	clientLoops
pack-priv final boolean	colocate
pack-priv final boolean	daemon
pack-priv final String	prefix
pack-priv final AtomicBoolean	running
pack-priv final int	selectCount
pack-priv final AtomicReference<EventLoopGroup>	serverLoops
pack-priv final AtomicReference<EventLoopGroup>	serverSelectLoops
pack-priv final int	workerCount

Access	Constructor and Description
pack-priv	DefaultLoopResources(String prefix, int workerCount, boolean daemon)
pack-priv	DefaultLoopResources(String prefix, int selectCount, int workerCount, boolean daemon)
pack-priv	DefaultLoopResources(String prefix, int selectCount, int workerCount, boolean daemon, boolean colocate)

Method Summary

Modifier and Type	Method and Description
pack-priv EventLoopGroup	cacheNativeClientLoops()
pack-priv EventLoopGroup	cacheNativeSelectLoops()
pack-priv EventLoopGroup	cacheNativeServerLoops()
pack-priv EventLoopGroup	cacheNioClientLoops()
pack-priv EventLoopGroup	cacheNioSelectLoops()
pack-priv EventLoopGroup	cacheNioServerLoops()
public Mono<Void>	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) Overrides default reactor.netty.resources.LoopResources.disposeLater. Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
public boolean	isDisposed() Overrides default reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed.
public EventLoopGroup	onClient(boolean should use native group if current environment supports it useNative) Overrides default reactor.netty.resources.LoopResources.onClient. Callback for client `EventLoopGroup` creation.
public EventLoopGroup	onServer(boolean should use native group if current environment supports it useNative) Implements reactor.netty.resources.LoopResources.onServer. Callback for server `EventLoopGroup` creation, this is the `EventLoopGroup` for the child channel.
public EventLoopGroup	onServerSelect(boolean should use native group if current environment supports it useNative) Overrides default reactor.netty.resources.LoopResources.onServerSelect. Callback for server select `EventLoopGroup` creation, this is the `EventLoopGroup` for the acceptor channel.
pack-priv static ThreadFactory	threadFactory(DefaultLoopResources parent, String prefix)
public String	toString() Overrides java.util.concurrent.atomic.AtomicLong.toString. Returns the String representation of the current value.

Field Detail

cacheNativeClientLoops	back to summary
pack-priv final AtomicReference<EventLoopGroup> cacheNativeClientLoops

cacheNativeSelectLoops	back to summary
pack-priv final AtomicReference<EventLoopGroup> cacheNativeSelectLoops

cacheNativeServerLoops	back to summary
pack-priv final AtomicReference<EventLoopGroup> cacheNativeServerLoops

clientLoops	back to summary
pack-priv final AtomicReference<EventLoopGroup> clientLoops

colocate	back to summary
pack-priv final boolean colocate

daemon	back to summary
pack-priv final boolean daemon

prefix	back to summary
pack-priv final String prefix

running	back to summary
pack-priv final AtomicBoolean running

selectCount	back to summary
pack-priv final int selectCount

serverLoops	back to summary
pack-priv final AtomicReference<EventLoopGroup> serverLoops

serverSelectLoops	back to summary
pack-priv final AtomicReference<EventLoopGroup> serverSelectLoops

workerCount	back to summary
pack-priv final int workerCount

Constructor Detail

DefaultLoopResources	back to summary
pack-priv DefaultLoopResources(String prefix, int workerCount, boolean daemon)

DefaultLoopResources	back to summary
pack-priv DefaultLoopResources(String prefix, int selectCount, int workerCount, boolean daemon)

DefaultLoopResources	back to summary
pack-priv DefaultLoopResources(String prefix, int selectCount, int workerCount, boolean daemon, boolean colocate)

Method Detail

cacheNativeClientLoops	back to summary
pack-priv EventLoopGroup cacheNativeClientLoops()

cacheNativeSelectLoops	back to summary
pack-priv EventLoopGroup cacheNativeSelectLoops() Annotations @SuppressWarnings:FutureReturnValueIgnored

cacheNativeServerLoops	back to summary
pack-priv EventLoopGroup cacheNativeServerLoops() Annotations @SuppressWarnings:FutureReturnValueIgnored

cacheNioClientLoops	back to summary
pack-priv EventLoopGroup cacheNioClientLoops()

cacheNioSelectLoops	back to summary
pack-priv EventLoopGroup cacheNioSelectLoops() Annotations @SuppressWarnings:FutureReturnValueIgnored

cacheNioServerLoops	back to summary
pack-priv EventLoopGroup cacheNioServerLoops() Annotations @SuppressWarnings:FutureReturnValueIgnored

disposeLater back to summary

disposeLater	back to summary
public Mono<Void> disposeLater(Duration quietPeriod, Duration timeout) Overrides default reactor.netty.resources.LoopResources.disposeLater. Doc from reactor.netty.resources.LoopResources.disposeLater. 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. Annotations @Override @SuppressWarnings:unchecked

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

Overrides default reactor.netty.resources.LoopResources.disposeLater.

Doc from reactor.netty.resources.LoopResources.disposeLater.

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.

Annotations

@Override
@SuppressWarnings:unchecked

isDisposed	back to summary
public boolean isDisposed() Overrides default reactor.core.Disposable.isDisposed. Doc from reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed. Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed. Returns:boolean true when there's a guarantee the resource or task is disposed. Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Overrides default reactor.core.Disposable.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

Returns:boolean

true when there's a guarantee the resource or task is disposed.

Annotations

@Override

onClient back to summary

onClient	back to summary
public EventLoopGroup onClient(boolean useNative) Overrides default reactor.netty.resources.LoopResources.onClient. Doc from reactor.netty.resources.LoopResources.onClient. Callback for client `EventLoopGroup` creation. Parameters useNative:boolean should use native group if current environment supports it Returns:EventLoopGroup a new `EventLoopGroup` Annotations @Override

public EventLoopGroup onClient(boolean useNative)

Overrides default reactor.netty.resources.LoopResources.onClient.

Doc from reactor.netty.resources.LoopResources.onClient.

Callback for client EventLoopGroup creation.

Parameters

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

Returns:EventLoopGroup

a new EventLoopGroup

Annotations

@Override

onServer back to summary

onServer	back to summary
public EventLoopGroup onServer(boolean useNative) Implements reactor.netty.resources.LoopResources.onServer. Doc from reactor.netty.resources.LoopResources.onServer. 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` Annotations @Override

public EventLoopGroup onServer(boolean useNative)

Implements reactor.netty.resources.LoopResources.onServer.

Doc from reactor.netty.resources.LoopResources.onServer.

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

Annotations

@Override

onServerSelect back to summary

onServerSelect	back to summary
public EventLoopGroup onServerSelect(boolean useNative) Overrides default reactor.netty.resources.LoopResources.onServerSelect. Doc from reactor.netty.resources.LoopResources.onServerSelect. 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` Annotations @Override

public EventLoopGroup onServerSelect(boolean useNative)

Overrides default reactor.netty.resources.LoopResources.onServerSelect.

Doc from reactor.netty.resources.LoopResources.onServerSelect.

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

Annotations

@Override

threadFactory	back to summary
pack-priv static ThreadFactory threadFactory(DefaultLoopResources parent, String prefix)

toString	back to summary
public String toString() Overrides java.util.concurrent.atomic.AtomicLong.toString. Doc from java.util.concurrent.atomic.AtomicLong.toString. Returns the String representation of the current value. Returns:String the String representation of the current value Annotations @Override

toString

back to summary

public String toString()

Overrides java.util.concurrent.atomic.AtomicLong.toString.

Doc from java.util.concurrent.atomic.AtomicLong.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations

@Override

reactor.netty.resources back to summary

pack-priv final Class DefaultLoopResources.EventLoop

Class Inheritance

extends FastThreadLocalThread
implements NonBlocking

java.lang.Object
java.lang.Thread
io.netty.util.concurrent.FastThreadLocalThread
reactor.netty.resources.DefaultLoopResources.EventLoop

All Implemented Interfaces

reactor.core.scheduler.NonBlocking

Constructor Summary

Access	Constructor and Description
pack-priv	EventLoop(Runnable target)

Method Summary

Inherited from io.netty.util.concurrent.FastThreadLocalThread:: permitBlockingCalls setThreadLocalMap threadLocalMap willCleanupFastThreadLocals willCleanupFastThreadLocals

Constructor Detail

EventLoop	back to summary
pack-priv EventLoop(Runnable target)

reactor.netty.resources back to summary

pack-priv final Class DefaultLoopResources.EventLoopFactory

Class Inheritance

extends Object
implements ThreadFactory

java.lang.Object
reactor.netty.resources.DefaultLoopResources.EventLoopFactory

All Implemented Interfaces

java.util.concurrent.ThreadFactory

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicLong	counter
pack-priv final boolean	daemon
pack-priv final String	prefix

Constructor Summary

Access	Constructor and Description
pack-priv	EventLoopFactory(boolean daemon, String prefix, AtomicLong counter)

Method Summary

Modifier and Type	Method and Description
public Thread	newThread(Runnable a runnable to be executed by new thread instance r) Implements java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

counter	back to summary
pack-priv final AtomicLong counter

daemon	back to summary
pack-priv final boolean daemon

prefix	back to summary
pack-priv final String prefix

Constructor Detail

EventLoopFactory	back to summary
pack-priv EventLoopFactory(boolean daemon, String prefix, AtomicLong counter)

Method Detail

newThread back to summary

newThread	back to summary
public Thread newThread(Runnable r) Implements java.util.concurrent.ThreadFactory.newThread. Doc from java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable. Parameters r:Runnable a runnable to be executed by new thread instance Returns:Thread constructed thread, or `null` if the request to create a thread is rejected Annotations @Override

public Thread newThread(Runnable r)

Implements java.util.concurrent.ThreadFactory.newThread.

Doc from java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.

Parameters

r:Runnable: a runnable to be executed by new thread instance

Returns:Thread

constructed thread, or null if the request to create a thread is rejected

Annotations

@Override

pack-priv final Class DefaultLoopResources

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class DefaultLoopResources.EventLoop

Constructor Summary

Method Summary

Constructor Detail

pack-priv final Class DefaultLoopResources.EventLoopFactory

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail