@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, wait
equals, hashCode, parallelStream, removeIf, spliterator, stream
private 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>
InterruptedException
public Runnable take() throws InterruptedException
take
in interface BlockingQueue<Runnable>
InterruptedException
public 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>
InterruptedException
public void put(Runnable element) throws InterruptedException
put
in interface BlockingQueue<Runnable>
InterruptedException
public 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–2020 The Apache Software Foundation. All rights reserved.