public class NioManagerIoThread extends NioManagerThread
NioManagerThread
that reads from and writes to connections.NioManagerThread.NioManagerThreadStatus, NioManagerThread.Request<I,O>
Thread.State, Thread.UncaughtExceptionHandler
exception, fsm, fsmInternal, log, queue, requests, selector, status
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Modifier | Constructor and Description |
---|---|
protected |
NioManagerIoThread(String name,
NioManagerDispatchThread parent)
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
doReadyOps(int readyOps,
SelectionKey key)
Performs actions stipulated by a ready operations bit vector on the given
SelectionKey . |
protected void |
handleDispatch(NioConnection conn)
Handles a connection dispatch notification.
|
protected void |
handleGetConnections(NioManagerThread.Request<?,List<NioConnection>> request)
Handles a request to get the list of connections.
|
protected void |
onStart()
On thread start.
|
protected void |
onStop()
On thread stop.
|
protected void |
purge(NioConnection conn)
A sequence of actions to take when deleting a connection, as far as this thread is concerned.
|
close, debug, debug, getStatus, handleClose, handleClosingEos, handleClosingUser, handleError, handleInvoke, handleOp, handleShutdown, initFsms, onLocal, request, run, setStatus, toString
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield
protected NioManagerIoThread(String name, NioManagerDispatchThread parent)
protected void onStart()
NioManagerThread
onStart
in class NioManagerThread
protected void onStop()
NioManagerThread
onStop
in class NioManagerThread
protected void doReadyOps(int readyOps, SelectionKey key)
NioManagerThread
SelectionKey
.doReadyOps
in class NioManagerThread
protected void handleDispatch(NioConnection conn)
protected void handleGetConnections(NioManagerThread.Request<?,List<NioConnection>> request)
protected void purge(NioConnection conn)
NioManagerThread
purge
in class NioManagerThread