Struct Executor 

pub struct Executor<K: QueueKey> { /* private fields */ }

The priority executor: single-thread polling + class vruntime selection.

Implementations

impl<K: QueueKey> Executor<K>

pub fn new( options: ExecutorOptions, queues: Vec<Queue<K>>, ) -> Result<Rc<Self>, String>

Create an executor with N classes, each with a weight (share).

pub fn queue(self: &Rc<Self>, qid: K) -> Result<QueueHandle<K>, SpawnError<K>>

Get a handle to a queue through which tasks can be spawned

pub fn stats(&self) -> ExecutorStats

Get the current executor stats.

pub fn qstats(&self) -> Vec<QueueStats<K>>

Get the current queue stats.

pub async fn run_until<F: Future>(&self, until: F) -> F::Output

Run the executor loop until the given future completes.

Panic behavior: if any task panics while being polled, the executor panics (propagates) unless executor has been configured to catch panics with with_panic_on_task_panic(false).

The executor will continue running tasks until until completes, then returns. When the executor stops, pending tasks remain pending and will resume if run_until is called again (Tokio-like behavior).