Struct batch_system::batch::Batch

pub struct Batch<N, C> {
    normals: Vec<Box<N>>,
    timers: Vec<Instant>,
    control: Option<Box<C>>,
}

A basic struct for a round of polling.

Fields

normals: Vec<Box<N>>

timers: Vec<Instant>

control: Option<Box<C>>

Implementations

impl<N: Fsm, C: Fsm> Batch<N, C>

pub fn with_capacity(cap: usize) -> Batch<N, C>

Create a a batch with given batch size.

fn push(&mut self, fsm: FsmTypes<N, C>) -> bool

fn is_empty(&self) -> bool

fn clear(&mut self)

pub fn release(&mut self, index: usize, checked_len: usize)

Put back the FSM located at index.

Only when channel length is larger than checked_len will trigger further notification. This function may fail if channel length is larger than the given value before FSM is released.

pub fn remove(&mut self, index: usize)

Remove the normal FSM located at index.

This method should only be called when the FSM is stopped. If there are still messages in channel, the FSM is untouched and the function will return false to let caller to keep polling.

pub fn reschedule(&mut self, router: &BatchRouter<N, C>, index: usize)

Schedule the normal FSM located at index.

pub fn release_control(
    &mut self,
    control_box: &BasicMailbox<C>,
    checked_len: usize
) -> bool

Same as release, but working on control FSM.

pub fn remove_control(&mut self, control_box: &BasicMailbox<C>)

Same as remove, but working on control FSM.