public class CoDelBlockingQueue<E extends CDQEntry>
extends java.util.concurrent.LinkedBlockingQueue<E>
コンストラクタ | 説明 |
---|---|
CoDelBlockingQueue(I2PAppContext ctx,
java.lang.String name,
int capacity) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
boolean |
add(E o) |
|
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 almost full?
|
boolean |
offer(E o) |
|
boolean |
offer(E o,
long timeout,
java.util.concurrent.TimeUnit unit) |
|
E |
poll() |
|
void |
put(E o) |
|
E |
take() |
addAll, containsAll, equals, hashCode, isEmpty, parallelStream, stream
contains, forEach, iterator, peek, poll, remainingCapacity, remove, removeAll, removeIf, retainAll, size, spliterator, toArray, toArray, toString
public CoDelBlockingQueue(I2PAppContext ctx, java.lang.String name, int capacity)
name
- for statspublic boolean offer(E o)
public boolean offer(E o, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
public void put(E o) throws java.lang.InterruptedException
public 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()