org.apache.thrift.server
Class TThreadedSelectorServer.Args

java.lang.Object
  extended by org.apache.thrift.server.TServer.AbstractServerArgs<T>
      extended by org.apache.thrift.server.AbstractNonblockingServer.AbstractNonblockingServerArgs<TThreadedSelectorServer.Args>
          extended by org.apache.thrift.server.TThreadedSelectorServer.Args
Enclosing class:
TThreadedSelectorServer

public static class TThreadedSelectorServer.Args
extends AbstractNonblockingServer.AbstractNonblockingServerArgs<TThreadedSelectorServer.Args>


Nested Class Summary
static class TThreadedSelectorServer.Args.AcceptPolicy
          Determines the strategy for handling new accepted connections.
 
Field Summary
 int selectorThreads
          The number of threads for selecting on already-accepted connections
 
Fields inherited from class org.apache.thrift.server.AbstractNonblockingServer.AbstractNonblockingServerArgs
maxReadBufferBytes
 
Constructor Summary
TThreadedSelectorServer.Args(TNonblockingServerTransport transport)
           
 
Method Summary
 TThreadedSelectorServer.Args acceptPolicy(TThreadedSelectorServer.Args.AcceptPolicy acceptPolicy)
           
 TThreadedSelectorServer.Args acceptQueueSizePerThread(int acceptQueueSizePerThread)
           
 TThreadedSelectorServer.Args executorService(java.util.concurrent.ExecutorService executorService)
           
 TThreadedSelectorServer.Args.AcceptPolicy getAcceptPolicy()
           
 int getAcceptQueueSizePerThread()
           
 java.util.concurrent.ExecutorService getExecutorService()
           
 int getSelectorThreads()
           
 java.util.concurrent.TimeUnit getStopTimeoutUnit()
           
 int getStopTimeoutVal()
           
 int getWorkerThreads()
           
 TThreadedSelectorServer.Args selectorThreads(int i)
           
 TThreadedSelectorServer.Args stopTimeoutUnit(java.util.concurrent.TimeUnit stopTimeoutUnit)
           
 TThreadedSelectorServer.Args stopTimeoutVal(int stopTimeoutVal)
           
 void validate()
           
 TThreadedSelectorServer.Args workerThreads(int i)
           
 
Methods inherited from class org.apache.thrift.server.TServer.AbstractServerArgs
inputProtocolFactory, inputTransportFactory, outputProtocolFactory, outputTransportFactory, processor, processorFactory, protocolFactory, transportFactory
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

selectorThreads

public int selectorThreads
The number of threads for selecting on already-accepted connections

Constructor Detail

TThreadedSelectorServer.Args

public TThreadedSelectorServer.Args(TNonblockingServerTransport transport)
Method Detail

selectorThreads

public TThreadedSelectorServer.Args selectorThreads(int i)

getSelectorThreads

public int getSelectorThreads()

workerThreads

public TThreadedSelectorServer.Args workerThreads(int i)

getWorkerThreads

public int getWorkerThreads()

getStopTimeoutVal

public int getStopTimeoutVal()

stopTimeoutVal

public TThreadedSelectorServer.Args stopTimeoutVal(int stopTimeoutVal)

getStopTimeoutUnit

public java.util.concurrent.TimeUnit getStopTimeoutUnit()

stopTimeoutUnit

public TThreadedSelectorServer.Args stopTimeoutUnit(java.util.concurrent.TimeUnit stopTimeoutUnit)

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

executorService

public TThreadedSelectorServer.Args executorService(java.util.concurrent.ExecutorService executorService)

getAcceptQueueSizePerThread

public int getAcceptQueueSizePerThread()

acceptQueueSizePerThread

public TThreadedSelectorServer.Args acceptQueueSizePerThread(int acceptQueueSizePerThread)

getAcceptPolicy

public TThreadedSelectorServer.Args.AcceptPolicy getAcceptPolicy()

acceptPolicy

public TThreadedSelectorServer.Args acceptPolicy(TThreadedSelectorServer.Args.AcceptPolicy acceptPolicy)

validate

public void validate()