Struct ParallelismStats 

pub struct ParallelismStats {
    pub total_nodes: usize,
    pub num_layers: usize,
    pub max_parallel_nodes: usize,
    pub avg_parallel_nodes: f64,
    pub theoretical_speedup: f64,
    pub layers: Vec<ExecutionLayer>,
}

Statistics about parallelism in a graph

Fields

total_nodes: usize

num_layers: usize

max_parallel_nodes: usize

avg_parallel_nodes: f64

theoretical_speedup: f64

layers: Vec<ExecutionLayer>

Implementations

impl ParallelismStats

pub fn print_summary(&self)

Examples found in repository

examples/parallel_execution.rs (line 305)

async fn analyze_and_execute(def: GraphDef) -> anyhow::Result<()> {
    // Create parallel executor
    let mut executor = ParallelExecutor::new(ParallelConfig {
        max_concurrent: 10,
        verbose: true,
    });

    // Register nodes
    for node_id in def.nodes.keys() {
        let node: Box<dyn Node> = Box::new(RuleNode::new(node_id, "true"));
        executor.register_node(node);
    }

    // Analyze parallelism
    let stats = executor.get_parallelism_stats(&def)?;
    stats.print_summary();

    // Execute the graph
    let mut graph = Graph::new(def);
    let start = Instant::now();
    executor.execute(&mut graph).await?;
    let duration = start.elapsed();

    println!("Execution completed in {:?}", duration);

    Ok(())
}

Trait Implementations

impl Debug for ParallelismStats

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

Formats the value using the given formatter.