| Modifier and Type | Field and Description |
|---|---|
| private final AsynchronousChannelGroup | |
| private final CloseableExecutorService |
| Access | Constructor and Description |
|---|---|
| public | Nio2ServiceFactory(FactoryManager factoryManager, CloseableExecutorService service, CloseableExecutorService resumeTasks)
|
| Modifier and Type | Method and Description |
|---|---|
| public IoAcceptor | createAcceptor(IoHandler handler)
Implements org.
|
| public IoConnector | createConnector(IoHandler handler)
Implements org.
|
| public Nio2Session | createSession(Nio2Service service, IoHandler handler, AsynchronousSocketChannel socket, SocketAddress address)
|
| protected void | doCloseImmediately()
Overrides org. doCloseImmediately is called once and only once with state == Immediate Overriding methods should always call the base implementation. |
| group | back to summary |
|---|---|
| private final AsynchronousChannelGroup group | |
| resuming | back to summary |
|---|---|
| private final CloseableExecutorService resuming | |
| Nio2ServiceFactory | back to summary |
|---|---|
| public Nio2ServiceFactory(FactoryManager factoryManager, CloseableExecutorService service, CloseableExecutorService resumeTasks) | |
| createAcceptor | back to summary |
|---|---|
| public IoAcceptor createAcceptor(IoHandler handler) Implements org.
| |
| createConnector | back to summary |
|---|---|
| public IoConnector createConnector(IoHandler handler) Implements org.
| |
| createSession | back to summary |
|---|---|
| public Nio2Session createSession(Nio2Service service, IoHandler handler, AsynchronousSocketChannel socket, SocketAddress address) throws Throwable | |
| doCloseImmediately | back to summary |
|---|---|
| protected void doCloseImmediately() Overrides org. Doc from org. doCloseImmediately is called once and only once with state == Immediate Overriding methods should always call the base implementation. It may be called concurrently while preClose() or doCloseGracefully is executing
| |