Struct Executor 

pub struct Executor { /* private fields */ }

A dual-queue executor optimized for singlethreaded usecase, with support for multithreaded wakes.

Same-thread wakes (Waker::wake) will schedule tasks within the queue directly; cross-thread wakes will send task id’s to a channel, and piggybacked to singlethreaded wakes or ticks. This ensures maximum performance for singlethreaded scenario at the trade-off of worse tail latency for multithreaded wake-ups.

Optionally, all Wakers generated from this executor can contain an extra data, parameterized as E.

Implementations

impl Executor

pub fn new() -> Self

Create a new executor.

pub fn with_config(config: ExecutorConfig) -> Self

Create a new executor with config.

pub fn spawn<F: Future + 'static>(&self, fut: F) -> JoinHandle<F::Output>

Spawn a future onto the executor.

pub fn tick(&self) -> bool

Retrieve all sync tasks, schedule those to the tail of hot queue and run at most max_interval tasks.

Running start with hot tasks, then cold ones. Finished tasks will be pushed back to tail of cold queue.

Return whether there are still hot tasks after the tick.

pub fn clear(&self)

Clear the executor, drop all tasks.

This should be called only in context of the runtime, if any future may use it. Any panic happened during dropping the future will cause the process to abort. If this was not called before dropping, all tasks will be leakded.

Trait Implementations

impl Debug for Executor

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

Formats the value using the given formatter.

impl Default for Executor

fn default() -> Self

Returns the “default value” for a type.

impl Drop for Executor

fn drop(&mut self)

Executes the destructor for this type.