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, waitadjustSizePostDecr, adjustSizePreIncr, changeMaxSize, getLast, isEmpty, isFirstElemOneAheadOfLastElem, isFull, maxSize, next, oneStepFurther, peek, pop, pop, popNoWait, push, size, status, toArraypublic 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.InterruptedExceptionpublic void pop(ArchiveRingBuffer.PopObject pobj) throws java.lang.InterruptedException
pobj - : vorher zu erzeugendes Objekt zur Übergabe der Werte.java.lang.InterruptedExceptionprotected void copy2NewArray(int newSize)
copy2NewArray in class RingBuffer<ArchiveRingBuffer.PopObject>