Package org.jcsp.util.ints
Class BufferInt
- java.lang.Object
-
- org.jcsp.util.ints.BufferInt
-
- All Implemented Interfaces:
java.io.Serializable,java.lang.Cloneable,ChannelDataStoreInt
public class BufferInt extends java.lang.Object implements ChannelDataStoreInt, java.io.Serializable
This is used to create a buffered integer channel that never loses data.Description
BufferInt is an implementation of ChannelDataStoreInt that yields a blocking FIFO buffered semantics for a channel. See the static construction methods ofChannel(Channel.one2oneInt(org.jcsp.util.ints.ChannelDataStoreInt)etc.).The getState method returns EMPTY, NONEMPTYFULL or FULL according to the state of the buffer.
-
-
Field Summary
Fields Modifier and Type Field Description private int[]bufferThe storage for the buffered intsprivate intcounterThe number of ints stored in the BufferIntprivate intfirstIndexThe index of the oldest element (when counter > 0)private intlastIndexThe index of the next free element (when counter < buffer.length)-
Fields inherited from interface org.jcsp.util.ints.ChannelDataStoreInt
EMPTY, FULL, NONEMPTYFULL
-
-
Constructor Summary
Constructors Constructor Description BufferInt(int size)Construct a new BufferInt with the specified size.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Objectclone()Returns a new (and EMPTY) BufferInt with the same creation parameters as this one.voidendGet()Removes the oldest integer from the buffer.intget()Returns the oldest int from the BufferInt and removes it.intgetState()Returns the current state of the BufferInt.voidput(int value)Puts a new int into the BufferInt.voidremoveAll()intstartGet()Returns the oldest integer from the buffer but does not remove it.
-
-
-
Field Detail
-
buffer
private final int[] buffer
The storage for the buffered ints
-
counter
private int counter
The number of ints stored in the BufferInt
-
firstIndex
private int firstIndex
The index of the oldest element (when counter > 0)
-
lastIndex
private int lastIndex
The index of the next free element (when counter < buffer.length)
-
-
Constructor Detail
-
BufferInt
public BufferInt(int size)
Construct a new BufferInt with the specified size.- Parameters:
size- the number of ints the BufferInt can store.- Throws:
BufferIntSizeError- if size is negative. Note: no action should be taken to try/catch this exception - application code generating it is in error and needs correcting.
-
-
Method Detail
-
get
public int get()
Returns the oldest int from the BufferInt and removes it.Pre-condition: getState must not currently return EMPTY.
- Specified by:
getin interfaceChannelDataStoreInt- Returns:
- the oldest int from the BufferInt
-
startGet
public int startGet()
Returns the oldest integer from the buffer but does not remove it. Pre-condition: getState must not currently return EMPTY.- Specified by:
startGetin interfaceChannelDataStoreInt- Returns:
- the oldest int from the Buffer
- See Also:
ChannelDataStoreInt.endGet()
-
endGet
public void endGet()
Removes the oldest integer from the buffer.- Specified by:
endGetin interfaceChannelDataStoreInt- See Also:
ChannelDataStoreInt.startGet()
-
put
public void put(int value)
Puts a new int into the BufferInt.Pre-condition: getState must not currently return FULL.
- Specified by:
putin interfaceChannelDataStoreInt- Parameters:
value- the int to put into the BufferInt
-
getState
public int getState()
Returns the current state of the BufferInt.- Specified by:
getStatein interfaceChannelDataStoreInt- Returns:
- the current state of the BufferInt (EMPTY, NONEMPTYFULL or FULL)
-
clone
public java.lang.Object clone()
Returns a new (and EMPTY) BufferInt with the same creation parameters as this one.Note: Only the size and structure of the BufferInt is cloned, not any stored data.
- Specified by:
clonein interfaceChannelDataStoreInt- Overrides:
clonein classjava.lang.Object- Returns:
- the cloned instance of this BufferInt
-
removeAll
public void removeAll()
- Specified by:
removeAllin interfaceChannelDataStoreInt
-
-