[−][src]Trait disrustor::Sequencer

pub trait Sequencer {
    type Barrier: SequenceBarrier;
    fn next(&self, count: usize) -> (Sequence, Sequence);
    fn publish(&self, highest: Sequence);
    fn create_barrier(
        &mut self, 
        gating_sequences: Vec<Arc<AtomicSequence>>
    ) -> Self::Barrier;
    fn add_gating_sequence(&mut self, gating_sequence: Arc<AtomicSequence>);
    fn get_cursor(&self) -> Arc<AtomicSequence>;
    fn drain(self);
}

Associated Types

`type Barrier: SequenceBarrier`

Loading content...

Required methods

`fn next(&self, count: usize) -> (Sequence, Sequence)`

`fn publish(&self, highest: Sequence)`

`fn create_barrier( &mut self, gating_sequences: Vec<Arc<AtomicSequence>> ) -> Self::Barrier`

`fn add_gating_sequence(&mut self, gating_sequence: Arc<AtomicSequence>)`

`fn get_cursor(&self) -> Arc<AtomicSequence>`

`fn drain(self)`

Loading content...

Implementors

`impl<W: WaitStrategy> Sequencer for SingleProducerSequencer<W>`[src]

`type Barrier = ProcessingSequenceBarrier<W>`

`fn next(&self, count: usize) -> (Sequence, Sequence)`[src]

`fn publish(&self, highest: Sequence)`[src]

`fn create_barrier( &mut self, gating_sequences: Vec<Arc<AtomicSequence>> ) -> ProcessingSequenceBarrier<W>`[src]

`fn add_gating_sequence(&mut self, gating_sequence: Arc<AtomicSequence>)`[src]

`fn get_cursor(&self) -> Arc<AtomicSequence>`[src]

`fn drain(self)`[src]

Loading content...