Struct Executor 

pub struct Executor { /* private fields */ }

Concurrent scheduler-dispatch executor.

Implementations

impl Executor

pub fn new() -> Self

pub fn with_config(config: ExecutorConfig) -> Self

pub fn register_actor( &self, root_id: ProjectRootId, ctx: Arc<AppContext>, ) -> bool

Register an actor if one is not already present.

Existing actors keep their current context and scheduler state; subc routing reuses them and reconfigures through the Mutating lane rather than replacing the per-root AppContext. Returns true when a new actor was inserted.

pub fn remove_actor(&self, root_id: &ProjectRootId)

Remove an actor from scheduler state.

This is intentionally minimal: subc uses it only for a just-created RouteBind actor whose configure failed before any route was installed, so there is no in-flight work to quiesce. The removed AppContext is dropped after releasing the scheduler lock so watcher/LSP teardown never runs under that mutex.

pub fn actor_contexts(&self) -> Vec<Arc<AppContext>>

Snapshot the registered actor contexts.

The returned Arcs keep contexts alive after the scheduler lock is released, so callers can run teardown without holding executor state.

pub fn submit( &self, root_id: ProjectRootId, lane: Lane, request_id: String, job: ExecutorJob, ) -> CompletionHandle

pub fn submit_async( &self, root_id: ProjectRootId, lane: Lane, request_id: String, job: ExecutorJob, ) -> Receiver<Response>

pub fn pool_size(&self) -> usize

pub fn actor_cap(&self) -> usize

pub fn read_cap(&self) -> usize

pub fn heavy_permits(&self) -> usize

pub fn nonrunnable_dispatch_count(&self) -> usize

pub fn actor_is_fatal(&self, root_id: &ProjectRootId) -> bool

Trait Implementations

impl Default for Executor

fn default() -> Self

Returns the “default value” for a type.