Struct SchedulerLocalExecutor 

pub struct SchedulerLocalExecutor { /* private fields */ }

A !Send executor pinned to a single session. Tasks spawned on it run in order on whichever thread drains the dispatch destination supplied at construction time — typically the main thread for the default session, or a dedicated OS thread for sessions created by spawn_dedicated_thread.

Implementations

impl LocalExecutor

pub fn new( session_id: SessionId, scheduler: Arc<dyn Scheduler>, dispatch: impl Fn(Runnable<RunnableMeta>) + Send + Sync + 'static, ) -> LocalExecutor

Constructs a local executor that runs spawned tasks by sending their runnables through dispatch. The scheduler is retained for access to clocks, timers, and other scheduler-level services.

For the common case of routing runnables through Scheduler::schedule_local, callers pass a closure that does exactly that. spawn_dedicated_thread instead passes a closure that sends to the dedicated thread’s channel.

pub fn session_id(&self) -> SessionId

pub fn scheduler(&self) -> &Arc<dyn Scheduler>

pub fn spawn<F>(&self, future: F) -> Task<<F as Future>::Output>

where F: Future + 'static, <F as Future>::Output: 'static,

pub fn block_on<Fut>(&self, future: Fut) -> <Fut as Future>::Output

where Fut: Future,

pub fn block_with_timeout<Fut>( &self, timeout: Duration, future: Fut, ) -> Result<<Fut as Future>::Output, impl Future<Output = <Fut as Future>::Output> + use<Fut>>

where Fut: Future,

Block until the future completes or timeout occurs. Returns Ok(output) if completed, Err(future) if timed out.

pub fn timer(&self, duration: Duration) -> Timer

pub fn now(&self) -> Instant

pub fn spawn_dedicated<F, Fut>(&self, f: F) -> Task<<Fut as Future>::Output>

where F: FnOnce(LocalExecutor) -> Fut + Send + 'static, Fut: Future + 'static, <Fut as Future>::Output: Send + Sync + 'static,

Spawn a closure on a fresh session pinned to its own LocalExecutor. The closure runs on a new OS thread under PlatformScheduler, or on the test scheduler’s loop under TestScheduler.

The returned Task represents the dedicated work: dropping it cancels the dedicated closure, .awaiting it yields the closure’s return value, .detach()ing it lets the dedicated work run independently of the caller.

Trait Implementations

impl Clone for LocalExecutor

fn clone(&self) -> LocalExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.