@InterfaceAudience.Private public class FastPathBalancedQueueRpcExecutor extends BalancedQueueRpcExecutor
RpcExecutor.Handler, RpcExecutor.QueueBalancer
queues
currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT
Constructor and Description |
---|
FastPathBalancedQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numCallQueues,
Configuration conf,
Abortable abortable,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass,
java.lang.Object... args) |
FastPathBalancedQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
int maxQueueLength,
Configuration conf,
Abortable abortable) |
Modifier and Type | Method and Description |
---|---|
boolean |
dispatch(CallRunner callTask)
Add the request to the executor queue
|
protected RpcExecutor.Handler |
getHandler(java.lang.String name,
double handlerFailureThreshhold,
java.util.concurrent.BlockingQueue<CallRunner> q)
Override if providing alternate Handler implementation.
|
getQueueLength, getQueues, initializeQueues
getActiveHandlerCount, getBalancer, resizeQueues, start, startHandlers, startHandlers, stop
public FastPathBalancedQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, int maxQueueLength, Configuration conf, Abortable abortable)
public FastPathBalancedQueueRpcExecutor(java.lang.String name, int handlerCount, int numCallQueues, Configuration conf, Abortable abortable, java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass, java.lang.Object... args)
protected RpcExecutor.Handler getHandler(java.lang.String name, double handlerFailureThreshhold, java.util.concurrent.BlockingQueue<CallRunner> q)
RpcExecutor
getHandler
in class RpcExecutor
public boolean dispatch(CallRunner callTask) throws java.lang.InterruptedException
RpcExecutor
dispatch
in class BalancedQueueRpcExecutor
java.lang.InterruptedException