Package org.apache.hadoop.hbase.ipc

Class RandomQueueBalancer

java.lang.Object

org.apache.hadoop.hbase.ipc.RandomQueueBalancer

All Implemented Interfaces:

QueueBalancer

@Private
@Stable
public class RandomQueueBalancer
extends Object
implements QueueBalancer

Queue balancer that just randomly selects a queue in the range [0, num queues).

Field Summary

Fields

Modifier and Type	Field	Description
private final List<BlockingQueue<CallRunner>>	queues
private final int	queueSize

Constructor Summary

Constructors

Constructor	Description
RandomQueueBalancer(org.apache.hadoop.conf.Configuration conf, String executorName, List<BlockingQueue<CallRunner>> queues)

Method Summary

Modifier and Type	Method	Description
int	getNextQueue(CallRunner callRunner)	Returns the index of the next queue to which a request should be inserted
(package private) List<BlockingQueue<CallRunner>>	getQueues()	Exposed for use in tests

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

queueSize

private final int queueSize

queues

private final List<BlockingQueue<CallRunner>> queues

Constructor Details

RandomQueueBalancer

public RandomQueueBalancer(org.apache.hadoop.conf.Configuration conf,
 String executorName,
 List<BlockingQueue<CallRunner>> queues)

Method Details

getNextQueue

public int getNextQueue(CallRunner callRunner)

Description copied from interface: QueueBalancer

Returns the index of the next queue to which a request should be inserted

Specified by:

getNextQueue in interface QueueBalancer

getQueues

List<BlockingQueue<CallRunner>> getQueues()

Exposed for use in tests