Package io.servicetalk.transport.netty.internal

Class NettyIoExecutors

java.lang.Object

io.servicetalk.transport.netty.internal.NettyIoExecutors

public final class NettyIoExecutors
extends java.lang.Object

A static factory to create or convert to NettyIoExecutor.

Method Summary

Modifier and Type	Method	Description
static io.netty.channel.EventLoopGroup	createEventLoopGroup(int ioThreads, java.util.concurrent.ThreadFactory threadFactory)	Create a new EventLoopGroup.
static EventLoopAwareNettyIoExecutor	createIoExecutor(int ioThreads, java.util.concurrent.ThreadFactory threadFactory)	Create a new NettyIoExecutor.
static EventLoopAwareNettyIoExecutor	createIoExecutor(java.util.concurrent.ThreadFactory threadFactory)	Create a new NettyIoExecutor with the default number of ioThreads.
static NettyIoExecutor	fromNettyEventLoop(io.netty.channel.EventLoop eventLoop)	Creates a new instance of NettyIoExecutor using the passed EventLoop.
static NettyIoExecutor	fromNettyEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)	Creates a new instance of NettyIoExecutor using the passed EventLoopGroup.
static NettyIoExecutor	toNettyIoExecutor(IoExecutor ioExecutor)	Attempts to convert the passed IoExecutor to a NettyIoExecutor.

Methods inherited from class java.lang.Object

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

Method Detail

createIoExecutor

public static EventLoopAwareNettyIoExecutor createIoExecutor(java.util.concurrent.ThreadFactory threadFactory)

Create a new NettyIoExecutor with the default number of ioThreads.

Parameters:

threadFactory - the ThreadFactory to use.

Returns:

The created IoExecutor

createIoExecutor

public static EventLoopAwareNettyIoExecutor createIoExecutor(int ioThreads,
                                                             java.util.concurrent.ThreadFactory threadFactory)

Create a new NettyIoExecutor.

Parameters:

ioThreads - number of threads.

threadFactory - the ThreadFactory to use.

Returns:

The created IoExecutor

createEventLoopGroup

public static io.netty.channel.EventLoopGroup createEventLoopGroup(int ioThreads,
                                                                   java.util.concurrent.ThreadFactory threadFactory)

Create a new EventLoopGroup.

Parameters:

ioThreads - number of threads

threadFactory - the ThreadFactory to use.

Returns:

The created IoExecutor

toNettyIoExecutor

public static NettyIoExecutor toNettyIoExecutor(IoExecutor ioExecutor)

Attempts to convert the passed IoExecutor to a NettyIoExecutor.

Parameters:

ioExecutor - IoExecutor to convert.

Returns:

NettyIoExecutor corresponding to the passed IoExecutor.

Throws:

java.lang.IllegalArgumentException - If IoExecutor is not of type NettyIoExecutor.

fromNettyEventLoop

public static NettyIoExecutor fromNettyEventLoop(io.netty.channel.EventLoop eventLoop)

Creates a new instance of NettyIoExecutor using the passed EventLoop.

Parameters:

eventLoop - EventLoop to use to create a new NettyIoExecutor.

Returns:

New NettyIoExecutor using the passed EventLoop.

fromNettyEventLoopGroup

public static NettyIoExecutor fromNettyEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)

Creates a new instance of NettyIoExecutor using the passed EventLoopGroup.

Parameters:

eventLoopGroup - EventLoopGroup to use to create a new NettyIoExecutor.

Returns:

New NettyIoExecutor using the passed EventLoopGroup.