Struct ParallelOrchestrator 

pub struct ParallelOrchestrator { /* private fields */ }

Orchestrates the execution of multiple solver stages respecting dependencies.

Example

use oxiphysics_core::parallel_orchestrator::{ParallelOrchestrator, SolverStage};

struct SimpleStage { name: String, cost: f64, step_count: u64 }

impl SolverStage for SimpleStage {
    fn name(&self) -> &str { &self.name }
    fn step(&mut self, _dt: f64) { self.step_count += 1; }
    fn estimated_cost(&self) -> f64 { self.cost }
}

let mut orch = ParallelOrchestrator::new();
let a = orch.add_stage("broadphase", &[]);
let b = orch.add_stage("narrowphase", &[a]);
let c = orch.add_stage("solver", &[b]);

let mut stages: Vec<Box<dyn SolverStage>> = vec![
    Box::new(SimpleStage { name: "broadphase".into(), cost: 1.0, step_count: 0 }),
    Box::new(SimpleStage { name: "narrowphase".into(), cost: 2.0, step_count: 0 }),
    Box::new(SimpleStage { name: "solver".into(), cost: 3.0, step_count: 0 }),
];

orch.execute(&mut stages, 0.016).expect("execution failed");

Implementations

impl ParallelOrchestrator

pub fn new() -> Self

Creates a new empty orchestrator.

pub fn add_stage(&mut self, name: &str, depends_on: &[usize]) -> usize

Registers a new stage with the given name and dependency list.

Returns the index of the newly added stage, which can be used as a dependency for later stages.

Arguments

• name - Human-readable stage name.
• depends_on - Indices of stages that must run before this one.

pub fn num_stages(&self) -> usize

Returns the number of registered stages.

pub fn stage_names(&self) -> &[String]

Returns the registered stage names.

pub fn compute_schedule(&self) -> Result<PipelineSchedule, OrchestratorError>

Computes a PipelineSchedule by topologically sorting stages into waves.

Returns an error if the dependency graph contains a cycle or references an invalid stage index.

pub fn execute( &mut self, stages: &mut [Box<dyn SolverStage>], dt: f64, ) -> Result<(), OrchestratorError>

Executes all registered stages in dependency order.

Stages within the same wave are currently run sequentially. The timings for each stage are accumulated across repeated calls to execute.

Errors

Returns an error if scheduling fails (cycle or invalid index) or if a scheduled stage index is out of range for the provided stages slice.

pub fn timings(&self) -> &[f64]

Returns per-stage accumulated wall-clock timings in seconds.

pub fn total_time(&self) -> f64

Returns the total accumulated wall-clock time across all stages.

pub fn reset_timings(&mut self)

Resets all accumulated timings to zero.

Trait Implementations

impl Clone for ParallelOrchestrator

fn clone(&self) -> ParallelOrchestrator

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ParallelOrchestrator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ParallelOrchestrator

fn default() -> Self

Returns the “default value” for a type.