Package 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>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TThreadedSelectorServer.Args.AcceptPolicy
Determines the strategy for handling new accepted connections.
-
Field Summary
Fields Modifier and Type Field Description 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
Constructors Constructor Description Args(TNonblockingServerTransport transport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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
-
-
-
-
Constructor Detail
-
Args
public 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()
-
-