public abstract class AbstractIoServiceFactory extends AbstractCloseable implements IoServiceFactory, FactoryManagerHolder, ExecutorServiceCarrier
AbstractCloseable.State
Modifier and Type | Field and Description |
---|---|
private IoServiceEventListener |
eventListener |
private CloseableExecutorService |
executor |
private FactoryManager |
manager |
closeFuture, futureLock, state
log
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Modifier | Constructor and Description |
---|---|
protected |
AbstractIoServiceFactory(FactoryManager factoryManager,
CloseableExecutorService executorService) |
Modifier and Type | Method and Description |
---|---|
protected <S extends IoService> |
autowireCreatedService(S service) |
protected void |
doCloseImmediately()
doCloseImmediately is called once and only once with state == Immediate
|
CloseableExecutorService |
getExecutorService() |
FactoryManager |
getFactoryManager() |
IoServiceEventListener |
getIoServiceEventListener() |
static int |
getNioWorkers(FactoryManager manager) |
void |
setIoServiceEventListener(IoServiceEventListener listener) |
addCloseFutureListener, builder, close, doCloseGracefully, getFutureLock, isClosed, isClosing, preClose, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createAcceptor, createConnector
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
private IoServiceEventListener eventListener
private final FactoryManager manager
private final CloseableExecutorService executor
protected AbstractIoServiceFactory(FactoryManager factoryManager, CloseableExecutorService executorService)
public final FactoryManager getFactoryManager()
getFactoryManager
in interface FactoryManagerHolder
FactoryManager
public final CloseableExecutorService getExecutorService()
getExecutorService
in interface ExecutorServiceCarrier
CloseableExecutorService
to usepublic IoServiceEventListener getIoServiceEventListener()
getIoServiceEventListener
in interface IoServiceEventListenerManager
public void setIoServiceEventListener(IoServiceEventListener listener)
setIoServiceEventListener
in interface IoServiceEventListenerManager
protected void doCloseImmediately()
AbstractCloseable
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
doCloseImmediately
in class AbstractCloseable
protected <S extends IoService> S autowireCreatedService(S service)
public static int getNioWorkers(FactoryManager manager)