Struct Executor 

pub struct Executor { /* private fields */ }

Core task execution engine for the Luminal runtime

The Executor is responsible for scheduling and executing tasks. It maintains a global task queue and a set of worker threads that process tasks using a work-stealing algorithm.

Implementations

impl Executor

pub fn new() -> Self

Creates a new executor

This initializes a new executor with worker threads based on the number of available CPU cores.

Returns

A new Executor instance

pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawns a future onto the executor

This wraps the future in a task and schedules it for execution, returning a JoinHandle that can be used to await its completion.

Type Parameters

• F - The future type

Parameters

• future - The future to execute

Returns

A JoinHandle for the spawned task

pub fn block_on<F>(&self, future: F) -> F::Output

where F: Future + Send + 'static, F::Output: Send + 'static,

Blocks the current thread until the provided future completes

This spawns the future as a task and then actively helps execute tasks from the queue until the specified future completes.

Type Parameters

• F - The future type

Parameters

• future - The future to execute and wait for

Returns

The output of the future

Panics

Panics if the task times out (after 30 seconds) or the task channel is disconnected

pub fn run(&self)

Runs the executor until the task queue is empty

This method is primarily used for testing and benchmarking.

pub fn stats(&self) -> (usize, usize)

Returns statistics about the executor

Returns

A tuple containing the current queue length and the number of tasks processed