Package com.linkedin.alpini.base.queuing
Class AbstractQOSBasedQueue<T extends QOSBasedRequestRunnable>
- java.lang.Object
-
- com.linkedin.alpini.base.queuing.AbstractQOS
-
- com.linkedin.alpini.base.queuing.AbstractQOSBasedQueue<T>
-
- All Implemented Interfaces:
SimpleQueue<T>
- Direct Known Subclasses:
QOSBasedMultiQueue
,QOSBasedQueue
public abstract class AbstractQOSBasedQueue<T extends QOSBasedRequestRunnable> extends AbstractQOS implements SimpleQueue<T>
Abstract base class for QOS priority queues.
-
-
Field Summary
-
Fields inherited from class com.linkedin.alpini.base.queuing.AbstractQOS
_allocationTotal, _log, _qosBasedAllocations
-
-
Constructor Summary
Constructors Constructor Description AbstractQOSBasedQueue(java.util.Map<QOS,java.lang.Integer> qosBasedAllocations)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected QOS
getQOS(T e)
protected java.lang.String
getQueueName(T e)
T
poll()
-
Methods inherited from class com.linkedin.alpini.base.queuing.AbstractQOS
getDefaultQOSAllocation, getQueuePollOrder
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.linkedin.alpini.base.queuing.SimpleQueue
add, isEmpty, size
-
-
-
-
Constructor Detail
-
AbstractQOSBasedQueue
public AbstractQOSBasedQueue(java.util.Map<QOS,java.lang.Integer> qosBasedAllocations)
-
-
Method Detail
-
getQueueName
protected java.lang.String getQueueName(T e)
-
poll
public T poll()
- Specified by:
poll
in interfaceSimpleQueue<T extends QOSBasedRequestRunnable>
- See Also:
Queue.poll()
-
-