@InterfaceAudience.Private public class CallQueue extends Object implements BlockingQueue<Runnable>
| Modifier and Type | Class and Description |
|---|---|
static class |
CallQueue.Call |
| Modifier and Type | Field and Description |
|---|---|
private static org.slf4j.Logger |
LOG |
private ThriftMetrics |
metrics |
private BlockingQueue<CallQueue.Call> |
underlyingQueue |
| Constructor and Description |
|---|
CallQueue(BlockingQueue<CallQueue.Call> underlyingQueue,
ThriftMetrics metrics) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
add(Runnable element) |
boolean |
addAll(Collection<? extends Runnable> elements) |
void |
clear() |
boolean |
contains(Object element) |
boolean |
containsAll(Collection<?> elements) |
int |
drainTo(Collection<? super Runnable> destination) |
int |
drainTo(Collection<? super Runnable> destination,
int maxElements) |
Runnable |
element() |
boolean |
isEmpty() |
Iterator<Runnable> |
iterator() |
private static long |
now() |
boolean |
offer(Runnable element) |
boolean |
offer(Runnable element,
long timeout,
TimeUnit unit) |
Runnable |
peek() |
Runnable |
poll() |
Runnable |
poll(long timeout,
TimeUnit unit) |
void |
put(Runnable element) |
int |
remainingCapacity() |
Runnable |
remove() |
boolean |
remove(Object element) |
boolean |
removeAll(Collection<?> elements) |
boolean |
retainAll(Collection<?> elements) |
int |
size() |
Runnable |
take() |
Object[] |
toArray() |
<T> T[] |
toArray(T[] array) |
private void |
updateMetrics(CallQueue.Call result) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitequals, hashCode, parallelStream, removeIf, spliterator, streamprivate static final org.slf4j.Logger LOG
private final BlockingQueue<CallQueue.Call> underlyingQueue
private final ThriftMetrics metrics
public CallQueue(BlockingQueue<CallQueue.Call> underlyingQueue, ThriftMetrics metrics)
private static long now()
private void updateMetrics(CallQueue.Call result)
public Runnable poll(long timeout, TimeUnit unit) throws InterruptedException
poll in interface BlockingQueue<Runnable>InterruptedExceptionpublic Runnable take() throws InterruptedException
take in interface BlockingQueue<Runnable>InterruptedExceptionpublic int drainTo(Collection<? super Runnable> destination)
drainTo in interface BlockingQueue<Runnable>public int drainTo(Collection<? super Runnable> destination, int maxElements)
drainTo in interface BlockingQueue<Runnable>public boolean offer(Runnable element, long timeout, TimeUnit unit) throws InterruptedException
offer in interface BlockingQueue<Runnable>InterruptedExceptionpublic void put(Runnable element) throws InterruptedException
put in interface BlockingQueue<Runnable>InterruptedExceptionpublic boolean add(Runnable element)
add in interface Collection<Runnable>add in interface BlockingQueue<Runnable>add in interface Queue<Runnable>public boolean addAll(Collection<? extends Runnable> elements)
addAll in interface Collection<Runnable>public void clear()
clear in interface Collection<Runnable>public boolean containsAll(Collection<?> elements)
containsAll in interface Collection<Runnable>public boolean isEmpty()
isEmpty in interface Collection<Runnable>public boolean removeAll(Collection<?> elements)
removeAll in interface Collection<Runnable>public boolean retainAll(Collection<?> elements)
retainAll in interface Collection<Runnable>public int size()
size in interface Collection<Runnable>public Object[] toArray()
toArray in interface Collection<Runnable>public <T> T[] toArray(T[] array)
toArray in interface Collection<Runnable>public boolean contains(Object element)
contains in interface Collection<Runnable>contains in interface BlockingQueue<Runnable>public int remainingCapacity()
remainingCapacity in interface BlockingQueue<Runnable>public boolean remove(Object element)
remove in interface Collection<Runnable>remove in interface BlockingQueue<Runnable>Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.