@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public class RWQueueRpcExecutor extends RpcExecutor
RpcExecutor.Handler, RpcExecutor.QueueBalancer
currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT
Constructor and Description |
---|
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
float scanShare,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass,
java.lang.Object[] writeQueueInitArgs,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
java.lang.Object[] readQueueInitArgs) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
float scanShare,
int maxQueueLength) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
float scanShare,
int maxQueueLength,
Configuration conf,
Abortable abortable) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
float scanShare,
int maxQueueLength,
Configuration conf,
Abortable abortable,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
java.lang.Object... readQueueInitArgs) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
int maxQueueLength,
Configuration conf,
Abortable abortable) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
int maxQueueLength,
Configuration conf,
Abortable abortable,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
java.lang.Object... readQueueInitArgs) |
RWQueueRpcExecutor(java.lang.String name,
int writeHandlers,
int readHandlers,
int numWriteQueues,
int numReadQueues,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass,
java.lang.Object[] writeQueueInitArgs,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
java.lang.Object[] readQueueInitArgs) |
RWQueueRpcExecutor(java.lang.String name,
int writeHandlers,
int readHandlers,
int numWriteQueues,
int numReadQueues,
float scanShare,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass,
java.lang.Object[] writeQueueInitArgs,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
java.lang.Object[] readQueueInitArgs) |
Modifier and Type | Method and Description |
---|---|
boolean |
dispatch(CallRunner callTask)
Add the request to the executor queue
|
int |
getQueueLength()
Returns the length of the pending queue
|
protected java.util.List<java.util.concurrent.BlockingQueue<CallRunner>> |
getQueues()
Returns the list of request queues
|
protected void |
startHandlers(int port) |
getActiveHandlerCount, getBalancer, getHandler, resizeQueues, start, startHandlers, stop
public RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, int maxQueueLength, Configuration conf, Abortable abortable)
public RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength)
public RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength, Configuration conf, Abortable abortable)
public RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, int maxQueueLength, Configuration conf, Abortable abortable, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object... readQueueInitArgs)
public RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength, Configuration conf, Abortable abortable, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object... readQueueInitArgs)
public RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass, java.lang.Object[] writeQueueInitArgs, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object[] readQueueInitArgs)
public RWQueueRpcExecutor(java.lang.String name, int writeHandlers, int readHandlers, int numWriteQueues, int numReadQueues, java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass, java.lang.Object[] writeQueueInitArgs, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object[] readQueueInitArgs)
public RWQueueRpcExecutor(java.lang.String name, int writeHandlers, int readHandlers, int numWriteQueues, int numReadQueues, float scanShare, java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass, java.lang.Object[] writeQueueInitArgs, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object[] readQueueInitArgs)
protected void startHandlers(int port)
startHandlers
in class RpcExecutor
public boolean dispatch(CallRunner callTask) throws java.lang.InterruptedException
RpcExecutor
dispatch
in class RpcExecutor
java.lang.InterruptedException
public int getQueueLength()
RpcExecutor
getQueueLength
in class RpcExecutor
protected java.util.List<java.util.concurrent.BlockingQueue<CallRunner>> getQueues()
RpcExecutor
getQueues
in class RpcExecutor