Struct ActorScheduler 

pub struct ActorScheduler { /* private fields */ }

Work-stealing actor scheduler.

Implementations

impl ActorScheduler

pub fn new(config: SchedulerConfig) -> Self

Create a new actor scheduler.

pub fn with_executor( config: SchedulerConfig, executor: Arc<dyn ActorExecutor>, ) -> Self

Create a new scheduler with an executor.

pub fn with_resource_policy( config: SchedulerConfig, executor: Arc<dyn ActorExecutor>, resource_policy: Arc<dyn ResourcePolicy>, ) -> Self

Create a new scheduler with an executor and a resource policy.

The policy gates actor spawns and message sends; see crate::policy::ResourcePolicy for the (cheap, non-blocking) contract.

pub fn set_executor(&mut self, executor: Arc<dyn ActorExecutor>)

Set the executor for WASM execution.

pub fn set_degradation_with_monitor( &mut self, monitor: Arc<dyn ResourceMonitor>, elevated_batch_factor: f64, )

Set the degradation controller for OS-level admission control.

When set, spawn_named will check resource pressure before creating a new actor. Critical pressure returns an error; Elevated logs a debug message but allows the spawn.

pub fn start(&self) -> Result<(), Error>

Start the scheduler.

pub fn stop(&self)

Stop the scheduler.

pub fn spawn(&self) -> Result<ActorId>

Spawn a new actor.

pub fn spawn_named(&self, name: Option<String>) -> Result<ActorId>

Spawn a new actor with a name.

pub fn kill(&self, id: &ActorId) -> Result<()>

Kill an actor.

pub fn set_actor_running(&self, id: &ActorId) -> Result<()>

Set an actor to running state.

pub fn set_actor_state(&self, id: &ActorId, state: ActorState) -> Result<()>

Set an actor state.

pub async fn send(&self, target: ActorId, message: Message) -> Result<()>

Send a message to an actor.

pub async fn send_batch( &self, target: ActorId, messages: Vec<Message>, ) -> Result<()>

Send a batch of messages to an actor in a single queue operation.

This is more efficient than calling send in a loop because it performs one quota/rate-limit check and pushes a single Task to the work-stealing queue for the entire batch.

pub fn try_send(&self, target: ActorId, message: Message) -> Result<()>

Try to send a message (non-blocking).

pub fn registry(&self) -> &Arc<ActorRegistry>

Get the actor registry.

pub fn stats(&self) -> SchedulerStats

Get scheduler statistics.

Trait Implementations

impl Drop for ActorScheduler

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.