Struct batch_system::fsm::FsmState

pub struct FsmState<N> {
    status: AtomicUsize,
    data: AtomicPtr<N>,
    state_cnt: Arc<AtomicUsize>,
}

Fields

status: AtomicUsize

data: AtomicPtr<N>

state_cnt: Arc<AtomicUsize>

Implementations

impl<N: Fsm> FsmState<N>

pub fn new(data: Box<N>, state_cnt: Arc<AtomicUsize>) -> FsmState<N>

pub fn take_fsm(&self) -> Option<Box<N>>

Take the fsm if it’s IDLE.

pub fn notify<S: FsmScheduler<Fsm = N>>(
    &self,
    scheduler: &S,
    mailbox: Cow<'_, BasicMailbox<N>>
)

Notify fsm via a FsmScheduler.

pub fn release(&self, fsm: Box<N>)

Put the owner back to the state.

It’s not required that all messages should be consumed before releasing a fsm. However, a fsm is guaranteed to be notified only when new messages arrives after it’s released.

pub fn clear(&self)

Clear the fsm.

Trait Implementations

impl<N> Drop for FsmState<N>

fn drop(&mut self)

Executes the destructor for this type.