public static class TThreadPoolServer.Args extends TServer.AbstractServerArgs<TThreadPoolServer.Args>
Modifier and Type | Field and Description |
---|---|
int |
beBackoffSlotLength |
java.util.concurrent.TimeUnit |
beBackoffSlotLengthUnit |
java.util.concurrent.ExecutorService |
executorService |
int |
maxWorkerThreads |
int |
minWorkerThreads |
int |
requestTimeout |
java.util.concurrent.TimeUnit |
requestTimeoutUnit |
java.util.concurrent.TimeUnit |
stopTimeoutUnit |
int |
stopTimeoutVal |
Constructor and Description |
---|
TThreadPoolServer.Args(TServerTransport transport) |
Modifier and Type | Method and Description |
---|---|
TThreadPoolServer.Args |
beBackoffSlotLength(int n) |
TThreadPoolServer.Args |
beBackoffSlotLengthUnit(java.util.concurrent.TimeUnit tu) |
TThreadPoolServer.Args |
executorService(java.util.concurrent.ExecutorService executorService) |
TThreadPoolServer.Args |
maxWorkerThreads(int n) |
TThreadPoolServer.Args |
minWorkerThreads(int n) |
TThreadPoolServer.Args |
requestTimeout(int n) |
TThreadPoolServer.Args |
requestTimeoutUnit(java.util.concurrent.TimeUnit tu) |
inputProtocolFactory, inputTransportFactory, outputProtocolFactory, outputTransportFactory, processor, processorFactory, protocolFactory, transportFactory
public int minWorkerThreads
public int maxWorkerThreads
public java.util.concurrent.ExecutorService executorService
public int stopTimeoutVal
public java.util.concurrent.TimeUnit stopTimeoutUnit
public int requestTimeout
public java.util.concurrent.TimeUnit requestTimeoutUnit
public int beBackoffSlotLength
public java.util.concurrent.TimeUnit beBackoffSlotLengthUnit
public TThreadPoolServer.Args(TServerTransport transport)
public TThreadPoolServer.Args minWorkerThreads(int n)
public TThreadPoolServer.Args maxWorkerThreads(int n)
public TThreadPoolServer.Args requestTimeout(int n)
public TThreadPoolServer.Args requestTimeoutUnit(java.util.concurrent.TimeUnit tu)
public TThreadPoolServer.Args beBackoffSlotLength(int n)
public TThreadPoolServer.Args beBackoffSlotLengthUnit(java.util.concurrent.TimeUnit tu)
public TThreadPoolServer.Args executorService(java.util.concurrent.ExecutorService executorService)