org.apache.thrift.server

Class TThreadedSelectorServerWithFix.AcceptThread

java.lang.Object

java.lang.Thread

org.apache.thrift.server.TThreadedSelectorServerWithFix.AcceptThread

All Implemented Interfaces:

Runnable

Enclosing class:

TThreadedSelectorServerWithFix

protected class TThreadedSelectorServerWithFix.AcceptThread
extends 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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AcceptThread(org.apache.thrift.transport.TNonblockingServerTransport serverTransport, TThreadedSelectorServerWithFix.SelectorThreadLoadBalancer threadChooser) Set up the AcceptThead

Method Summary

Modifier and Type	Method and 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, 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

AcceptThread

public AcceptThread(org.apache.thrift.transport.TNonblockingServerTransport serverTransport,
                    TThreadedSelectorServerWithFix.SelectorThreadLoadBalancer threadChooser)
             throws IOException

Set up the AcceptThead

Throws:

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 Runnable

Overrides:

run in class Thread

wakeupSelector

public void wakeupSelector()

If the selector is blocked, wake it up.