Class SequentialWriter<T>


  • public class SequentialWriter<T>
    extends java.lang.Object
    • 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()