Package org.apache.thrift.server
Class TNonblockingServer.SelectAcceptThread
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.thrift.server.AbstractNonblockingServer.AbstractSelectThread
-
- org.apache.thrift.server.TNonblockingServer.SelectAcceptThread
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- TNonblockingServer
protected class TNonblockingServer.SelectAcceptThread extends AbstractNonblockingServer.AbstractSelectThread
The thread that will be doing all the selecting, managing new connections and those that still need to be read.
-
-
Field Summary
-
Fields inherited from class org.apache.thrift.server.AbstractNonblockingServer.AbstractSelectThread
selectInterestChanges, selector
-
-
Constructor Summary
Constructors Constructor Description SelectAcceptThread(TNonblockingServerTransport serverTransport)
Set up the thread that will handle the non-blocking accepts, reads, and writes.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isStopped()
void
run()
The work loop.-
Methods inherited from class org.apache.thrift.server.AbstractNonblockingServer.AbstractSelectThread
cleanupSelectionKey, handleRead, handleWrite, processInterestChanges, requestSelectInterestChange, wakeupSelector
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Constructor Detail
-
SelectAcceptThread
public SelectAcceptThread(TNonblockingServerTransport serverTransport) throws java.io.IOException
Set up the thread that will handle the non-blocking accepts, reads, and writes.- Throws:
java.io.IOException
-
-