Struct ActorSystem 

pub struct ActorSystem { /* private fields */ }

Unified system for all concurrent work.

Provides:

• Actor spawning on a shared work-stealing pool
• CPU-bound compute with admission control
• Graceful shutdown via cancellation token

Implementations

impl ActorSystem

pub fn new(config: ActorSystemConfig) -> Self

Create a new actor system with the given configuration.

pub fn scope(&self) -> Self

pub fn cancellation_token(&self) -> CancellationToken

Get the cancellation token for this system.

pub fn is_cancelled(&self) -> bool

Check if the system has been cancelled.

pub fn shutdown(&self)

Signal shutdown to all actors and the timer scheduler.

Cancels all actors, wakes any that are parked, then drops the waker and keepalive references so actor cells can be freed.

pub fn join(&self) -> Result<(), JoinError>

Wait for all actors to finish after shutdown, with a default 5-second timeout.

pub fn join_timeout(&self, timeout: Duration) -> Result<(), JoinError>

Wait for all actors to finish after shutdown, with a custom timeout.

pub fn scheduler(&self) -> &SchedulerHandle

Get the timer scheduler for scheduling delayed/periodic callbacks.

pub fn spawn<A: Actor>(&self, name: &str, actor: A) -> ActorHandle<A::Message>

where A::State: Send,

Spawn an actor on the shared work-stealing pool.

Returns a handle to the spawned actor.

pub fn install<R, F>(&self, f: F) -> R

where R: Send, F: FnOnce() -> R + Send,

Executes a closure on the rayon thread pool directly.

Synchronous and bypasses admission control. Use this when you’re already in a synchronous context and need parallel execution.

pub async fn compute<R, F>(&self, f: F) -> Result<R, JoinError>

where R: Send + 'static, F: FnOnce() -> R + Send + 'static,

Runs a CPU-bound function on the compute pool.

The task is scheduled via spawn_blocking and executed on the dedicated rayon pool using install. Admission control ensures no more than max_in_flight tasks run concurrently.

Trait Implementations

impl Clone for ActorSystem

fn clone(&self) -> ActorSystem

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActorSystem

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

Formats the value using the given formatter.