org.apache.thrift.server
Class TThreadedSelectorServer.Args
java.lang.Object
org.apache.thrift.server.TServer.AbstractServerArgs<T>
org.apache.thrift.server.AbstractNonblockingServer.AbstractNonblockingServerArgs<TThreadedSelectorServer.Args>
org.apache.thrift.server.TThreadedSelectorServer.Args
- Enclosing class:
- TThreadedSelectorServer
public static class TThreadedSelectorServer.Args
- extends AbstractNonblockingServer.AbstractNonblockingServerArgs<TThreadedSelectorServer.Args>
Field Summary |
int |
selectorThreads
The number of threads for selecting on already-accepted connections |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
selectorThreads
public int selectorThreads
- The number of threads for selecting on already-accepted connections
TThreadedSelectorServer.Args
public TThreadedSelectorServer.Args(TNonblockingServerTransport transport)
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()