public static class TThreadedSelectorServer.Args extends AbstractNonblockingServer.AbstractNonblockingServerArgs<TThreadedSelectorServer.Args>
Modifier and Type | Class and Description |
---|---|
static class |
TThreadedSelectorServer.Args.AcceptPolicy
Determines the strategy for handling new accepted connections.
|
Modifier and Type | Field and Description |
---|---|
int |
selectorThreads
The number of threads for selecting on already-accepted connections
|
maxReadBufferBytes
Constructor and Description |
---|
TThreadedSelectorServer.Args(TNonblockingServerTransport transport) |
Modifier and Type | Method and 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) |
inputProtocolFactory, inputTransportFactory, outputProtocolFactory, outputTransportFactory, processor, processorFactory, protocolFactory, transportFactory
public int selectorThreads
public TThreadedSelectorServer.Args(TNonblockingServerTransport transport)
public TThreadedSelectorServer.Args selectorThreads(int i)
public int getSelectorThreads()
public TThreadedSelectorServer.Args workerThreads(int i)
public int getWorkerThreads()
public int getStopTimeoutVal()
public TThreadedSelectorServer.Args stopTimeoutVal(int stopTimeoutVal)
public java.util.concurrent.TimeUnit getStopTimeoutUnit()
public TThreadedSelectorServer.Args stopTimeoutUnit(java.util.concurrent.TimeUnit stopTimeoutUnit)
public java.util.concurrent.ExecutorService getExecutorService()
public TThreadedSelectorServer.Args executorService(java.util.concurrent.ExecutorService executorService)
public int getAcceptQueueSizePerThread()
public TThreadedSelectorServer.Args acceptQueueSizePerThread(int acceptQueueSizePerThread)
public TThreadedSelectorServer.Args.AcceptPolicy getAcceptPolicy()
public TThreadedSelectorServer.Args acceptPolicy(TThreadedSelectorServer.Args.AcceptPolicy acceptPolicy)
public void validate()