public static class TThreadedSelectorServer.Args extends AbstractNonblockingServer.AbstractNonblockingServerArgs<TThreadedSelectorServer.Args>
Modifier and Type | Class | Description |
---|---|---|
static class |
TThreadedSelectorServer.Args.AcceptPolicy |
Determines the strategy for handling new accepted connections.
|
Modifier and Type | Field | Description |
---|---|---|
int |
selectorThreads |
The number of threads for selecting on already-accepted connections
|
maxReadBufferBytes
Constructor | Description |
---|---|
Args(TNonblockingServerTransport transport) |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
inputProtocolFactory, inputTransportFactory, outputProtocolFactory, outputTransportFactory, processor, processorFactory, protocolFactory, transportFactory
public int selectorThreads
public 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()