Package | Description |
---|---|
org.apache.oozie.service | |
org.apache.oozie.util |
Modifier and Type | Class and Description |
---|---|
class |
CallableQueueService.CallableWrapper<E> |
Modifier and Type | Method and Description |
---|---|
PriorityDelayQueue.QueueElement<E> |
PriorityDelayQueue.peek()
Retrieve, but does not remove, the head of this queue, or returns null if this queue is empty.
|
PriorityDelayQueue.QueueElement<E> |
PriorityDelayQueue.poll()
Retrieve and remove the head of this queue, or return null if this queue has no elements with an expired
delay.
|
PriorityDelayQueue.QueueElement<E> |
PollablePriorityDelayQueue.poll()
Retrieve and remove the head of this queue if it is eligible to poll.
|
PriorityDelayQueue.QueueElement<E> |
PriorityDelayQueue.poll(long timeout,
TimeUnit unit)
Retrieve and removes the head of this queue, waiting up to the
specified wait time if necessary for an element to become available.
|
PriorityDelayQueue.QueueElement<E> |
PriorityDelayQueue.take()
Retrieve and removes the head of this queue, waiting if necessary
until an element becomes available.
|
Modifier and Type | Method and Description |
---|---|
Iterator<PriorityDelayQueue.QueueElement<E>> |
PriorityDelayQueue.iterator()
Return an iterator over all the
PriorityDelayQueue.QueueElement elements (both expired and unexpired) in this queue. |
Modifier and Type | Method and Description |
---|---|
boolean |
PriorityDelayQueue.add(PriorityDelayQueue.QueueElement<E> queueElement)
Inserts the specified element into this queue if it is possible to do
so immediately without violating capacity restrictions, returning
true upon success and throwing an
IllegalStateException if no space is currently available.
|
protected boolean |
PollablePriorityDelayQueue.eligibleToPoll(PriorityDelayQueue.QueueElement<?> element)
Method for checking the QueueElement eligible to poll before remove it from queue.
|
boolean |
PriorityDelayQueue.offer(PriorityDelayQueue.QueueElement<E> queueElement)
Insert the specified element into the queue.
|
boolean |
PriorityDelayQueue.offer(PriorityDelayQueue.QueueElement<E> e,
long timeout,
TimeUnit unit)
Insert the specified element into this queue, waiting up to the
specified wait time if necessary for space to become available.
|
void |
PriorityDelayQueue.put(PriorityDelayQueue.QueueElement<E> e)
Insert the specified element into this queue, waiting if necessary
for space to become available.
|
Modifier and Type | Method and Description |
---|---|
int |
PriorityDelayQueue.drainTo(Collection<? super PriorityDelayQueue.QueueElement<E>> c)
Remove all available elements from this queue and adds them
to the given collection.
|
int |
PriorityDelayQueue.drainTo(Collection<? super PriorityDelayQueue.QueueElement<E>> c,
int maxElements)
Remove at most the given number of available elements from
this queue and adds them to the given collection.
|
Copyright © 2016 Apache Software Foundation. All rights reserved.