public abstract class AbstractIoServiceFactory extends AbstractCloseable implements IoServiceFactory, FactoryManagerHolder, ExecutorServiceCarrier
AbstractCloseable.State
closeFuture, futureLock, state
log
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
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createAcceptor, createConnector
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
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)
Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.