protected class TDisruptorServer.AcceptorThread extends TDisruptorServer.AbstractSelectorThread
Thread.State, Thread.UncaughtExceptionHandler
selector
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
AcceptorThread(String name,
org.apache.thrift.transport.TNonblockingServerTransport serverTransport)
Set up the thread that will handle the non-blocking accepts.
|
Modifier and Type | Method and Description |
---|---|
protected void |
processKey(SelectionKey key)
Process each individual key that reported ready state
|
protected void |
selectorIterationComplete()
Called after each selector event loop completion, useful for booking (e.g.
|
cleanupSelectionKey, close, isStopped, run, wakeupSelector
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, toString, yield
public AcceptorThread(String name, org.apache.thrift.transport.TNonblockingServerTransport serverTransport) throws IOException
IOException
protected void processKey(SelectionKey key) throws IOException
TDisruptorServer.AbstractSelectorThread
processKey
in class TDisruptorServer.AbstractSelectorThread
key
- The key to processIOException
- any I/O related errorprotected void selectorIterationComplete()
TDisruptorServer.AbstractSelectorThread
selectorIterationComplete
in class TDisruptorServer.AbstractSelectorThread
Copyright © 2013–2017. All rights reserved.