Package org.apache.thrift.server
Class TThreadedSelectorServer.AcceptThread
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.thrift.server.TThreadedSelectorServer.AcceptThread
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- TThreadedSelectorServer
protected class TThreadedSelectorServer.AcceptThread extends java.lang.Thread
The thread that selects on the server transport (listen socket) and accepts new connections to hand off to the IO selector threads
-
-
Constructor Summary
Constructors Constructor Description AcceptThread(TNonblockingServerTransport serverTransport, TThreadedSelectorServer.SelectorThreadLoadBalancer threadChooser)
Set up the AcceptThead
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
run()
The work loop.void
wakeupSelector()
If the selector is blocked, wake it up.-
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
-
AcceptThread
public AcceptThread(TNonblockingServerTransport serverTransport, TThreadedSelectorServer.SelectorThreadLoadBalancer threadChooser) throws java.io.IOException
Set up the AcceptThead- Throws:
java.io.IOException
-
-
Method Detail
-
run
public void run()
The work loop. Selects on the server transport and accepts. If there was a server transport that had blocking accepts, and returned on blocking client transports, that should be used instead- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
wakeupSelector
public void wakeupSelector()
If the selector is blocked, wake it up.
-
-