Struct batch_system::BatchSystem

pub struct BatchSystem<N: Fsm, C: Fsm> {
    name_prefix: Option<String>,
    router: BatchRouter<N, C>,
    receiver: Receiver<FsmTypes<N, C>>,
    low_receiver: Receiver<FsmTypes<N, C>>,
    pool_size: usize,
    max_batch_size: usize,
    workers: Vec<JoinHandle<()>>,
    reschedule_duration: Duration,
    low_priority_pool_size: usize,
}

A system that can poll FSMs concurrently and in batch.

To use the system, two type of FSMs and their PollHandlers need to be defined: Normal and Control. Normal FSM handles the general task while Control FSM creates normal FSM instances.

Fields

name_prefix: Option<String>

router: BatchRouter<N, C>

receiver: Receiver<FsmTypes<N, C>>

low_receiver: Receiver<FsmTypes<N, C>>

pool_size: usize

max_batch_size: usize

workers: Vec<JoinHandle<()>>

reschedule_duration: Duration

low_priority_pool_size: usize

Implementations

impl<N, C> BatchSystem<N, C> where
    N: Fsm + Send + 'static,
    C: Fsm + Send + 'static, 

pub fn router(&self) -> &BatchRouter<N, C>

fn start_poller<B>(&mut self, name: String, priority: Priority, builder: &mut B) where
    B: HandlerBuilder<N, C>,
    B::Handler: Send + 'static, 

pub fn spawn<B>(&mut self, name_prefix: String, builder: B) where
    B: HandlerBuilder<N, C>,
    B::Handler: Send + 'static, 

Start the batch system.

pub fn shutdown(&mut self)

Shutdown the batch system and wait till all background threads exit.