public class CoDelPriorityBlockingQueue<E extends CDPQEntry> extends PriBlockingQueue<E>
修飾子とタイプ | フィールド | 説明 |
---|---|---|
(package private) static java.util.concurrent.atomic.AtomicLong |
__id |
debugging
|
static int |
DONT_DROP_PRIORITY |
if priority is >= this, never drop
|
static int |
MIN_PRIORITY |
_context, _log, _name, BACKLOG_SIZE, MAX_SIZE, RATES
コンストラクタ | 説明 |
---|---|
CoDelPriorityBlockingQueue(I2PAppContext ctx,
java.lang.String name,
int initialCapacity) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
clear() |
|
int |
drainAllTo(java.util.Collection<? super E> c) |
Drains all, without updating stats or dropping.
|
int |
drainTo(java.util.Collection<? super E> c) |
Updates stats and possibly drops while draining.
|
int |
drainTo(java.util.Collection<? super E> c,
int maxElements) |
Updates stats and possibly drops while draining.
|
boolean |
isBacklogged() |
Has the head of the queue been waiting too long,
or is the queue too big?
|
E |
poll() |
|
E |
take() |
|
protected void |
timestamp(E o) |
addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, stream
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, offer, offer, put
static final java.util.concurrent.atomic.AtomicLong __id
public static final int MIN_PRIORITY
public static final int DONT_DROP_PRIORITY
public CoDelPriorityBlockingQueue(I2PAppContext ctx, java.lang.String name, int initialCapacity)
name
- for statspublic void clear()
public E take() throws java.lang.InterruptedException
public E poll()
public int drainTo(java.util.Collection<? super E> c)
public int drainTo(java.util.Collection<? super E> c, int maxElements)
public int drainAllTo(java.util.Collection<? super E> c)
public boolean isBacklogged()
isBacklogged
クラス内 PriBlockingQueue<E extends CDPQEntry>
protected void timestamp(E o)
timestamp
クラス内 PriBlockingQueue<E extends CDPQEntry>