Struct SingleRingSpRuntime 

pub struct SingleRingSpRuntime { /* private fields */ }

In-process SP runtime handle for SingleRing SHM execution.

Implementations

impl SingleRingSpRuntime

pub fn stage_count(&self) -> usize

Number of stage threads in this runtime.

pub fn active_gating(&self) -> usize

Number of active gating cells used by this runtime.

pub fn snapshot(&self) -> Result<SingleRingSnapshot, ExecError>

Snapshot cursor + gating sequences without stopping the runtime.

pub fn any_stage_finished(&self) -> bool

True if any stage thread has exited (successfully or with error).

This is intended for control-plane supervision.

pub fn request_stop(&self)

Request a cooperative stop.

pub fn stop_and_join_bounded(self, timeout: Duration) -> Result<(), ExecError>

Request stop and join stage threads, but return an error if they don’t stop within timeout.

Notes:

• Rust threads cannot be force-killed safely; this is cooperative stop only.
• On timeout, this returns an error that lists unfinished stages.

pub fn stop_and_join(self) -> Result<(), ExecError>

Request stop and join all stage threads.