| Modifier and Type | Field | Description |
|---|---|---|
protected java.util.concurrent.BlockingQueue<T> |
queue |
| Constructor | Description |
|---|---|
LimitedQueueBuffer(java.util.concurrent.BlockingQueue<T> queue) |
| Modifier and Type | Method | Description |
|---|---|---|
void |
close() |
Does nothing
|
T |
get() |
Non-blocking get implementation
|
int |
get(java.util.List<T> buffer,
int maxCount) |
Non-blocking bulk get implementation
|
LimitedQueueBuffer<T> |
getInput() |
Make a
Input instance from this. |
boolean |
isEmpty() |
|
int |
put(java.util.List<T> items) |
|
int |
put(java.util.List<T> buffer,
int from,
int to) |
Non-blocking bulk put implementation
|
boolean |
put(T item) |
Non-blocking put implementation
|
void |
reset() |
Does nothing
|
int |
size() |
|
long |
skip(long itemsCount) |
Skip some items.
|
java.lang.String |
toString() |
protected final java.util.concurrent.BlockingQueue<T> queue
public LimitedQueueBuffer(java.util.concurrent.BlockingQueue<T> queue)
public boolean put(T item)
public int put(java.util.List<T> buffer, int from, int to) throws java.io.IOException
public final int put(java.util.List<T> items) throws java.io.IOException
public LimitedQueueBuffer<T> getInput() throws java.io.IOException
OutputInput instance from this.public T get() throws java.io.IOException
public int get(java.util.List<T> buffer, int maxCount) throws java.io.IOException
public long skip(long itemsCount)
throws java.io.IOException
Inputpublic final boolean isEmpty()
public final int size()
public void reset()
throws java.io.IOException
public void close()
throws java.io.IOException
close in interface java.lang.AutoCloseableclose in interface java.io.Closeablejava.io.IOException - doesn't throwpublic java.lang.String toString()
toString in class java.lang.Object