CoDelPriorityBlockingQueue
public class PriBlockingQueue<E extends PQEntry>
extends java.util.concurrent.PriorityBlockingQueue<E>
修飾子とタイプ | フィールド | 説明 |
---|---|---|
protected I2PAppContext |
_context |
|
protected Log |
_log |
|
protected java.lang.String |
_name |
|
protected static int |
BACKLOG_SIZE |
|
protected static int |
MAX_SIZE |
|
protected static long[] |
RATES |
コンストラクタ | 説明 |
---|---|
PriBlockingQueue(I2PAppContext ctx,
java.lang.String name,
int initialCapacity) |
Bounded queue with a hardcoded failsafe max size,
except when using put(), which is unbounded.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
boolean |
add(E o) |
推奨されていません。
use offer(o)
|
boolean |
isBacklogged() |
Is the queue too big?
|
boolean |
offer(E o) |
Returns false if full
|
boolean |
offer(E o,
long timeout,
java.util.concurrent.TimeUnit unit) |
推奨されていません。
use offer(o)
|
void |
put(E o) |
推奨されていません。
use offer(o)
|
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
protected final transient I2PAppContext _context
protected final transient Log _log
protected final java.lang.String _name
protected static final long[] RATES
protected static final int BACKLOG_SIZE
protected static final int MAX_SIZE
public PriBlockingQueue(I2PAppContext ctx, java.lang.String name, int initialCapacity)
@Deprecated public boolean add(E o)
public boolean offer(E o)
@Deprecated public boolean offer(E o, long timeout, java.util.concurrent.TimeUnit unit)
@Deprecated public void put(E o)
public boolean isBacklogged()
protected void timestamp(E o)