T
- class ReferenceBlockingQueue<T> extends ReferencedQueue<T> implements java.util.concurrent.BlockingQueue<T>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.BlockingQueue<Referrer<T>> |
queue |
private static long |
serialVersionUID |
Constructor and Description |
---|
ReferenceBlockingQueue(java.util.concurrent.BlockingQueue<Referrer<T>> queue,
Ref type,
boolean gcThreads,
long gcCycle) |
Modifier and Type | Method and Description |
---|---|
int |
drainTo(Collection<? super T> c) |
int |
drainTo(Collection<? super T> c,
int maxElements) |
boolean |
offer(T e,
long timeout,
java.util.concurrent.TimeUnit unit) |
T |
poll(long timeout,
java.util.concurrent.TimeUnit unit) |
void |
put(T e) |
private void |
readObject(ObjectInputStream stream) |
int |
remainingCapacity() |
T |
take() |
element, offer, peek, poll, remove
add, addAll, clear, contains, containsAll, equals, getRef, getRQF, hashCode, isEmpty, iterator, processQueue, remove, size, toString, wrapObj, writeReplace
removeAll, retainAll, toArray, toArray
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
add, contains, offer, remove
addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray
private static final long serialVersionUID
private final java.util.concurrent.BlockingQueue<Referrer<T>> queue
ReferenceBlockingQueue(java.util.concurrent.BlockingQueue<Referrer<T>> queue, Ref type, boolean gcThreads, long gcCycle)
private void readObject(ObjectInputStream stream) throws InvalidObjectException
InvalidObjectException
public void put(T e) throws InterruptedException
put
in interface java.util.concurrent.BlockingQueue<T>
InterruptedException
public boolean offer(T e, long timeout, java.util.concurrent.TimeUnit unit) throws InterruptedException
offer
in interface java.util.concurrent.BlockingQueue<T>
InterruptedException
public T take() throws InterruptedException
take
in interface java.util.concurrent.BlockingQueue<T>
InterruptedException
public T poll(long timeout, java.util.concurrent.TimeUnit unit) throws InterruptedException
poll
in interface java.util.concurrent.BlockingQueue<T>
InterruptedException
public int remainingCapacity()
remainingCapacity
in interface java.util.concurrent.BlockingQueue<T>
public int drainTo(Collection<? super T> c)
drainTo
in interface java.util.concurrent.BlockingQueue<T>
public int drainTo(Collection<? super T> c, int maxElements)
drainTo
in interface java.util.concurrent.BlockingQueue<T>
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.