public static class TDisruptorServer.Args extends org.apache.thrift.server.AbstractNonblockingServer.AbstractNonblockingServerArgs<TDisruptorServer.Args>
Constructor and Description |
---|
Args(org.apache.thrift.transport.TNonblockingServerTransport transport) |
Modifier and Type | Method and Description |
---|---|
TDisruptorServer.Args |
alwaysReallocateBuffers(boolean flag) |
TDisruptorServer.Args |
invocationExecutor(ThreadPoolExecutor executor)
Executor if set takes precedence over numWorkersPerSelector.
|
TDisruptorServer.Args |
maxFrameSizeInBytes(int maxFrameSizeInBytes) |
TDisruptorServer.Args |
numAcceptors(int numAcceptors) |
TDisruptorServer.Args |
numSelectors(int numSelectors) |
TDisruptorServer.Args |
numWorkersPerSelector(int numWorkers) |
TDisruptorServer.Args |
ringSizePerSelector(int ringSize) |
TDisruptorServer.Args |
useHeapBasedAllocation(boolean flag) |
public Args(org.apache.thrift.transport.TNonblockingServerTransport transport)
public TDisruptorServer.Args numAcceptors(int numAcceptors)
public TDisruptorServer.Args numSelectors(int numSelectors)
public TDisruptorServer.Args numWorkersPerSelector(int numWorkers)
public TDisruptorServer.Args ringSizePerSelector(int ringSize)
public TDisruptorServer.Args useHeapBasedAllocation(boolean flag)
public TDisruptorServer.Args maxFrameSizeInBytes(int maxFrameSizeInBytes)
public TDisruptorServer.Args alwaysReallocateBuffers(boolean flag)
public TDisruptorServer.Args invocationExecutor(ThreadPoolExecutor executor)
executor
- The executor to use for message execution.Copyright © 2013–2017. All rights reserved.