public static class TThreadedSelectorServerWithFix.Args extends org.apache.thrift.server.AbstractNonblockingServer.AbstractNonblockingServerArgs<TThreadedSelectorServerWithFix.Args>
Modifier and Type | Class and Description |
---|---|
static class |
TThreadedSelectorServerWithFix.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
|
Constructor and Description |
---|
TThreadedSelectorServerWithFix.Args(org.apache.thrift.transport.TNonblockingServerTransport transport) |
Modifier and Type | Method and Description |
---|---|
TThreadedSelectorServerWithFix.Args |
acceptPolicy(TThreadedSelectorServerWithFix.Args.AcceptPolicy acceptPolicy) |
TThreadedSelectorServerWithFix.Args |
acceptQueueSizePerThread(int acceptQueueSizePerThread) |
TThreadedSelectorServerWithFix.Args |
executorService(ExecutorService executorService) |
TThreadedSelectorServerWithFix.Args.AcceptPolicy |
getAcceptPolicy() |
int |
getAcceptQueueSizePerThread() |
ExecutorService |
getExecutorService() |
int |
getSelectorThreads() |
TimeUnit |
getStopTimeoutUnit() |
int |
getStopTimeoutVal() |
int |
getWorkerThreads() |
TThreadedSelectorServerWithFix.Args |
selectorThreads(int i) |
TThreadedSelectorServerWithFix.Args |
stopTimeoutUnit(TimeUnit stopTimeoutUnit) |
TThreadedSelectorServerWithFix.Args |
stopTimeoutVal(int stopTimeoutVal) |
void |
validate() |
TThreadedSelectorServerWithFix.Args |
workerThreads(int i) |
public int selectorThreads
public TThreadedSelectorServerWithFix.Args(org.apache.thrift.transport.TNonblockingServerTransport transport)
public TThreadedSelectorServerWithFix.Args selectorThreads(int i)
public int getSelectorThreads()
public TThreadedSelectorServerWithFix.Args workerThreads(int i)
public int getWorkerThreads()
public int getStopTimeoutVal()
public TThreadedSelectorServerWithFix.Args stopTimeoutVal(int stopTimeoutVal)
public TimeUnit getStopTimeoutUnit()
public TThreadedSelectorServerWithFix.Args stopTimeoutUnit(TimeUnit stopTimeoutUnit)
public ExecutorService getExecutorService()
public TThreadedSelectorServerWithFix.Args executorService(ExecutorService executorService)
public int getAcceptQueueSizePerThread()
public TThreadedSelectorServerWithFix.Args acceptQueueSizePerThread(int acceptQueueSizePerThread)
public TThreadedSelectorServerWithFix.Args.AcceptPolicy getAcceptPolicy()
public TThreadedSelectorServerWithFix.Args acceptPolicy(TThreadedSelectorServerWithFix.Args.AcceptPolicy acceptPolicy)
public void validate()
Copyright © 2017 The Apache Software Foundation. All rights reserved.