Package sk.antons.tempdb.sequence
Class SequenceDb<T>
- java.lang.Object
-
- sk.antons.tempdb.base.AbstractDb
-
- sk.antons.tempdb.sequence.SequenceDb<T>
-
public class SequenceDb<T> extends AbstractDb
Sequence (FIFO) type of database. Data are stored and read simultaneously.- Author:
- antons
-
-
Field Summary
Fields Modifier and Type Field Description protected BytesDeserializer<T>deserializerprotected longindexprotected RandomAccessFilerafprotected BytesSerializer<T>serializerprotected longsize-
Fields inherited from class sk.antons.tempdb.base.AbstractDb
dbfile
-
-
Constructor Summary
Constructors Constructor Description SequenceDb(DbFile dbfile, BytesSerializer<T> serializer, BytesDeserializer<T> deserializer)Creates new database
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidadd(T value)Add new value to end positionvoidclose()Closes resources used by this db.Tnext()Reads next value from first unread position-
Methods inherited from class sk.antons.tempdb.base.AbstractDb
dbfile, delete
-
-
-
-
Field Detail
-
serializer
protected BytesSerializer<T> serializer
-
deserializer
protected BytesDeserializer<T> deserializer
-
raf
protected RandomAccessFile raf
-
index
protected long index
-
size
protected long size
-
-
Constructor Detail
-
SequenceDb
public SequenceDb(DbFile dbfile, BytesSerializer<T> serializer, BytesDeserializer<T> deserializer)
Creates new database- Parameters:
dbfile-serializer-deserializer-
-
-
Method Detail
-
close
public void close()
Description copied from class:AbstractDbCloses resources used by this db.- Specified by:
closein classAbstractDb
-
add
public void add(T value)
Add new value to end position- Parameters:
value-
-
next
public T next()
Reads next value from first unread position- Returns:
- value or null if no value exists
-
-