public class BoundedBuffer extends SynchronizedBuffer implements BoundedCollection
Buffer
to ensure a fixed maximum size.
Note: This class should only be used if you need to add bounded
behaviour to another buffer. If you just want a bounded buffer then
you should use BoundedFifoBuffer
or CircularFifoBuffer
.
The decoration methods allow you to specify a timeout value. This alters the behaviour of the add methods when the buffer is full. Normally, when the buffer is full, the add method will throw an exception. With a timeout, the add methods will wait for up to the timeout period to try and add the elements.
Modifier and Type | Method and Description |
---|---|
boolean |
add(java.lang.Object o) |
boolean |
addAll(java.util.Collection c) |
static BoundedBuffer |
decorate(Buffer buffer,
int maximumSize)
Factory method to create a bounded buffer.
|
static BoundedBuffer |
decorate(Buffer buffer,
int maximumSize,
long timeout)
Factory method to create a bounded buffer that blocks for a maximum
amount of time.
|
boolean |
isFull()
Returns true if this collection is full and no new elements can be added.
|
java.util.Iterator |
iterator()
Iterators must be manually synchronized.
|
int |
maxSize()
Gets the maximum size of the collection (the bound).
|
java.lang.Object |
remove()
Gets and removes the next object from the buffer.
|
decorate, get
clear, contains, containsAll, decorate, equals, hashCode, isEmpty, remove, removeAll, retainAll, size, toArray, toArray, toString
public static BoundedBuffer decorate(Buffer buffer, int maximumSize)
When the buffer is full, it will immediately throw a
BufferOverflowException
on calling add()
.
buffer
- the buffer to decorate, must not be nullmaximumSize
- the maximum size, must be size one or greaterjava.lang.IllegalArgumentException
- if the buffer is nulljava.lang.IllegalArgumentException
- if the maximum size is zero or lesspublic static BoundedBuffer decorate(Buffer buffer, int maximumSize, long timeout)
buffer
- the buffer to decorate, must not be nullmaximumSize
- the maximum size, must be size one or greatertimeout
- the maximum amount of time to wait in millisecondsjava.lang.IllegalArgumentException
- if the buffer is nulljava.lang.IllegalArgumentException
- if the maximum size is zero or lesspublic java.lang.Object remove()
Buffer
remove
in interface Buffer
remove
in class SynchronizedBuffer
public boolean add(java.lang.Object o)
add
in interface java.util.Collection
add
in class SynchronizedCollection
public boolean addAll(java.util.Collection c)
addAll
in interface java.util.Collection
addAll
in class SynchronizedCollection
public java.util.Iterator iterator()
SynchronizedCollection
synchronized (coll) { Iterator it = coll.iterator(); // do stuff with iterator }
iterator
in interface java.lang.Iterable
iterator
in interface java.util.Collection
iterator
in class SynchronizedCollection
public boolean isFull()
BoundedCollection
isFull
in interface BoundedCollection
true
if the collection is fullpublic int maxSize()
BoundedCollection
maxSize
in interface BoundedCollection
Copyright © 2010 - 2020 Adobe. All Rights Reserved