Struct dvcompute::simulation::process::ProcessId

pub struct ProcessId { /* fields omitted */ }

The computation identifier.

Implementations

impl ProcessId

pub fn new() -> NewProcessId

Create a new computation identifier.

pub fn observable(&self) -> Publish<ProcessEvent>

Returns the observable of computation events.

pub fn cancel_initiating(
    &self
) -> impl Observable<Message = ProcessEvent> + Clone

Signal when the cancellation is initiated.

pub fn is_cancel_initiated(
    pid: Rc<ProcessId>
) -> impl Event<Item = bool> + Clone

Whether the cancellation was initiated.

pub fn cancel(pid: Rc<ProcessId>) -> CancelById

Cancel a process with the specified identifier.

pub fn begin_preemption(pid: Rc<ProcessId>) -> impl Event<Item = ()> + Clone

Preempt the computation.

pub fn end_preemption(pid: Rc<ProcessId>) -> impl Event<Item = ()> + Clone

Proceed with the computation after it was preempted earlier.

pub fn preemption_initiating(
    &self
) -> impl Observable<Message = ProcessEvent> + Clone

Signal when the computation is preempted.

pub fn preemption_ending(
    &self
) -> impl Observable<Message = ProcessEvent> + Clone

Signal when the computation is proceeded after it was preempted.

pub fn interrupt(pid: Rc<ProcessId>) -> Interrupt

Interrupt a process with the specified identifier if the process is held by computation hold_process. Returns an Event computation.

pub fn is_interrupted(pid: Rc<ProcessId>) -> IsInterrupted

Test whether the process with the specified identifier was interrupted. Returns an Event computation.

pub fn interruption_time(pid: Rc<ProcessId>) -> InterruptionTime

Return the expected interruption time after finishing the hold_process computation, which value may change if the corresponding process is preempted. Returns an Event computation.

pub fn is_passivated(pid: Rc<ProcessId>) -> IsPassivated

Test whether the process with the specified identifier was passivated. Returns an Event computation.

pub fn reactivate(pid: Rc<ProcessId>) -> Reactivate

Reactivate a process with the specified identifier.

pub fn reactivate_immediately(pid: Rc<ProcessId>) -> ReactivateImmediately

Reactivate immediately a process with the specified identifier.

pub fn reactivate_many_immediately<I>(
    pids: I
) -> ReactivateManyImmediately<I::IntoIter> where
    I: IntoIterator<Item = Rc<ProcessId>> + 'static, 

Reactivate immediately the processes with specfified identifies.

Trait Implementations

impl PartialEq<ProcessId> for ProcessId

fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl Eq for ProcessId