Package org.citydb.writer
Class SequentialWriter<T>
- java.lang.Object
-
- org.citydb.writer.SequentialWriter<T>
-
public class SequentialWriter<T> extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description SequentialWriter(WorkerPool<T> writerPool)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getCurrentSequenceId()
void
interrupt()
boolean
isInterrupted()
long
reset()
void
updateSequenceId(long sequenceId)
void
write(T object, long sequenceId)
void
writeCache()
-
-
-
Constructor Detail
-
SequentialWriter
public SequentialWriter(WorkerPool<T> writerPool)
-
-
Method Detail
-
reset
public long reset()
-
getCurrentSequenceId
public long getCurrentSequenceId()
-
write
public void write(T object, long sequenceId) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
updateSequenceId
public void updateSequenceId(long sequenceId) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
writeCache
public void writeCache()
-
isInterrupted
public boolean isInterrupted()
-
interrupt
public void interrupt()
-
-