@Singleton @Requires(property="micronaut.server.netty.use-native-transport",value="true",defaultValue="false") @Requires(classes=io.netty.channel.kqueue.KQueue.class,condition=io.micronaut.http.server.netty.KQueueAvailabilityCondition.class) @Internal public class KQueueEventLoopGroupFactory extends Object implements EventLoopGroupFactory
| Constructor and Description |
|---|
KQueueEventLoopGroupFactory() |
| Modifier and Type | Method and Description |
|---|---|
io.netty.channel.EventLoopGroup |
createEventLoopGroup(Integer ioRatio)
Creates a default KQueueEventLoopGroup.
|
io.netty.channel.EventLoopGroup |
createEventLoopGroup(int threads,
Executor executor,
Integer ioRatio)
Creates a KQueueEventLoopGroup.
|
io.netty.channel.EventLoopGroup |
createEventLoopGroup(int threads,
Integer ioRatio)
Creates a KQueueEventLoopGroup.
|
io.netty.channel.EventLoopGroup |
createEventLoopGroup(int threads,
ThreadFactory threadFactory,
Integer ioRatio)
Creates a KQueueEventLoopGroup.
|
Class<? extends io.netty.channel.socket.ServerSocketChannel> |
serverSocketChannelClass()
Returns the server channel class.
|
public io.netty.channel.EventLoopGroup createEventLoopGroup(int threads,
@Nullable
Integer ioRatio)
createEventLoopGroup in interface EventLoopGroupFactorythreads - The number of threads to use.ioRatio - The io ratio.public io.netty.channel.EventLoopGroup createEventLoopGroup(int threads,
ThreadFactory threadFactory,
@Nullable
Integer ioRatio)
createEventLoopGroup in interface EventLoopGroupFactorythreads - The number of threads to use.threadFactory - The thread factory.ioRatio - The io ratio.public io.netty.channel.EventLoopGroup createEventLoopGroup(int threads,
Executor executor,
@Nullable
Integer ioRatio)
createEventLoopGroup in interface EventLoopGroupFactorythreads - The number of threads to use.executor - An Executor.ioRatio - The io ratio.public io.netty.channel.EventLoopGroup createEventLoopGroup(@Nullable Integer ioRatio)
createEventLoopGroup in interface EventLoopGroupFactoryioRatio - The io ratio.public Class<? extends io.netty.channel.socket.ServerSocketChannel> serverSocketChannelClass()
serverSocketChannelClass in interface EventLoopGroupFactory