Struct dvcompute::simulation::process::ProcessId

pub struct ProcessId { /* private fields */ }

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: Grc<ProcessId>, ) -> impl Event<Item = bool> + Clone

Whether the cancellation was initiated.

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

Cancel a process with the specified identifier.

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

Preempt the computation.

pub fn end_preemption(pid: Grc<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: Grc<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: Grc<ProcessId>) -> IsInterrupted

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

pub fn interruption_time(pid: Grc<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: Grc<ProcessId>) -> IsPassivated

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

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

Reactivate a process with the specified identifier.

pub fn reactivate_immediately(pid: Grc<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 = Grc<ProcessId>> + 'static,

Reactivate immediately the processes with specfified identifies.

Trait Implementations

impl PartialEq 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 !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ProcessId