public class ArchiveRingBuffer extends RingBuffer<ArchiveRingBuffer.PopObject>
Modifier and Type | Class | Description |
---|---|---|
class |
ArchiveRingBuffer.PopObject |
Mit dieser Klasse kann man Paare in einem Aufruf aus dem Ringpuffer poppen.
|
buf, chunkSize, firstElem, isEmpty, lastElem, maxSize, MIN_CHUNK_SIZE, noOfChunks, UNBOUNDED_SIZE
Constructor | Description |
---|---|
ArchiveRingBuffer(int chunkSize,
int mxsize) |
Modifier and Type | Method | Description |
---|---|---|
protected void |
copy2NewArray(int newSize) |
|
void |
pop(ArchiveRingBuffer.PopObject pobj) |
Fügt die ersten Element der beiden Warteschlange in das uebergebene PopObject ein.
|
boolean |
push(java.lang.Object elem,
long time,
long timeout) |
Fügt ein Objekt in die Warteschlange an letzter Stelle ein.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
adjustSizePostDecr, adjustSizePreIncr, changeMaxSize, getLast, isEmpty, isFirstElemOneAheadOfLastElem, isFull, maxSize, next, oneStepFurther, peek, pop, pop, popNoWait, push, size, status, toArray
public ArchiveRingBuffer(int chunkSize, int mxsize)
chunkSize
- : Größe der Blöcke, um die das Feld der Warteschlange wächst und schrumpft.mxsize
- : Maximale Groesse der Warteschlange. Wird diese ueberschritten, liefert RingBuffer.push(Object)
falsepublic boolean push(java.lang.Object elem, long time, long timeout) throws java.lang.InterruptedException
elem
- : Einzufügendes Objekttime
- : Einfügezeitpunktjava.lang.InterruptedException
public void pop(ArchiveRingBuffer.PopObject pobj) throws java.lang.InterruptedException
pobj
- : vorher zu erzeugendes Objekt zur Übergabe der Werte.java.lang.InterruptedException
protected void copy2NewArray(int newSize)
copy2NewArray
in class RingBuffer<ArchiveRingBuffer.PopObject>