public class Nio2ServiceFactory extends AbstractIoServiceFactory
AbstractCloseable.State| Modifier and Type | Field and Description |
|---|---|
private java.nio.channels.AsynchronousChannelGroup |
group |
private CloseableExecutorService |
resuming |
closeFuture, futureLock, statelog| Constructor and Description |
|---|
Nio2ServiceFactory(FactoryManager factoryManager,
CloseableExecutorService service,
CloseableExecutorService resumeTasks) |
| Modifier and Type | Method and Description |
|---|---|
IoAcceptor |
createAcceptor(IoHandler handler) |
IoConnector |
createConnector(IoHandler handler) |
protected void |
doCloseImmediately()
doCloseImmediately is called once and only once with state == Immediate
|
autowireCreatedService, getExecutorService, getFactoryManager, getIoServiceEventListener, getNioWorkers, setIoServiceEventListeneraddCloseFutureListener, builder, close, doCloseGracefully, getFutureLock, isClosed, isClosing, preClose, removeCloseFutureListenerdebug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warnclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListenerprivate final java.nio.channels.AsynchronousChannelGroup group
private final CloseableExecutorService resuming
public Nio2ServiceFactory(FactoryManager factoryManager, CloseableExecutorService service, CloseableExecutorService resumeTasks)
public IoConnector createConnector(IoHandler handler)
public IoAcceptor createAcceptor(IoHandler handler)
protected void doCloseImmediately()
AbstractCloseabledoCloseImmediately 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
doCloseImmediately in class AbstractIoServiceFactory