executor

executor.rs

# 执行线程
stage = "idle"
LOOP {
    CASE stage {
        "idle" => state = stage_idle();
        "executing_proposal" => state = stage_executing_proposal();
    }
}

FUNCTION stage_executing_proposal() {
    LOOP {
        IF an interruption event come {
            handle_interrupt()
            RETURN "idle"
        } ELSE IF already done processing proposal {
            handle_done_proposal()
            RETURN "idle"
        } ELSE {
            continue to process next transaction
        }
    }
}

FUNCTION stage_idle() {
    SWITCH {
        receive ConsensusBlock event => ...
        receive SyncBlock event => ...
    }
}