org.apache.thrift.server
Class TThreadedSelectorServer.AcceptThread

java.lang.Object
  extended by java.lang.Thread
      extended by 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


Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
TThreadedSelectorServer.AcceptThread(TNonblockingServerTransport serverTransport, TThreadedSelectorServer.SelectorThreadLoadBalancer threadChooser)
          Set up the AcceptThead
 
Method Summary
 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, 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
 
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

TThreadedSelectorServer.AcceptThread

public TThreadedSelectorServer.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 interface java.lang.Runnable
Overrides:
run in class java.lang.Thread

wakeupSelector

public void wakeupSelector()
If the selector is blocked, wake it up.